Re: Re: Is it possible to use OperatorState, when NOT implementing a source or sink function?

2021-06-06 Thread Yun Gao
wrote: Hi,please use `CheckpointedFunction`, you could initialize your operator state in `initializeState` method by using context.getOperatorStateStore().*** Best regards, JING ZHANG Marco Villalobos 于2021年6月5日周六 下午1:55写道: Is it possible to use OperatorState, when NOT implementing a sour

Re: Is it possible to use OperatorState, when NOT implementing a source or sink function?

2021-06-05 Thread Marco Villalobos
; >> Hi, >> please use `CheckpointedFunction`, you could initialize your operator >> state in `initializeState` method by using >> context.getOperatorStateStore().*** >> >> Best regards, >> JING ZHANG >> >> >> Marco Villalobos 于2021年6月5日周六 下午1:5

Re: Re: Is it possible to use OperatorState, when NOT implementing a source or sink function?

2021-06-05 Thread Yun Gao
:2021/06/05 19:56:08 Recipient:JING ZHANG Cc:user Theme:Re: Is it possible to use OperatorState, when NOT implementing a source or sink function? Does that work in the DataStream API in Batch Execution Mode? On Sat, Jun 5, 2021 at 12:04 AM JING ZHANG wrote: Hi,please use `CheckpointedFunction

Re: Is it possible to use OperatorState, when NOT implementing a source or sink function?

2021-06-05 Thread Marco Villalobos
> Best regards, > JING ZHANG > > > Marco Villalobos 于2021年6月5日周六 下午1:55写道: > >> Is it possible to use OperatorState, when NOT implementing a source or >> sink function? >> >> If yes, then how? >> >

Re: Is it possible to use OperatorState, when NOT implementing a source or sink function?

2021-06-05 Thread JING ZHANG
Hi, please use `CheckpointedFunction`, you could initialize your operator state in `initializeState` method by using context.getOperatorStateStore().*** Best regards, JING ZHANG Marco Villalobos 于2021年6月5日周六 下午1:55写道: > Is it possible to use OperatorState, when NOT implementing a source

Is it possible to use OperatorState, when NOT implementing a source or sink function?

2021-06-04 Thread Marco Villalobos
Is it possible to use OperatorState, when NOT implementing a source or sink function? If yes, then how?