DataStream??state????

?g???U?[???? Mon, 06 Jul 2020 21:17:39 -0700

Deal all:


??????,????state????ttl??????????????????????&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; 
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; StateTtlConfig ttlConfig = StateTtlConfig
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; 
&nbsp; &nbsp; &nbsp; .newBuilder(Time.days(1))
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; 
&nbsp; &nbsp; &nbsp; .setUpdateType(StateTtlConfig.UpdateType.OnCreateAndWrite)
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; 
&nbsp; &nbsp; &nbsp; 
.setStateVisibility(StateTtlConfig.StateVisibility.NeverReturnExpired)
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; 
&nbsp; &nbsp; &nbsp; .build();



??????1????????????????????2020-07-07 
08:30:00????????job????????????????????????2020-07-07 00:00:00~2020-07-07 
23:59:59??????job??????????2020-07-07 08:30:00~2020-07-08 08:30:00???????????


Thanks
Jiazhi

DataStream??state????

回复