Does that work in the DataStream API in Batch Execution Mode? On Sat, Jun 5, 2021 at 12:04 AM JING ZHANG <beyond1...@gmail.com> wrote:
> Hi, > please use `CheckpointedFunction`, you could initialize your operator > state in `initializeState` method by using > context.getOperatorStateStore().*** > > Best regards, > JING ZHANG > > > Marco Villalobos <mvillalo...@kineteque.com> 于2021年6月5日周六 下午1:55写道： > >> Is it possible to use OperatorState, when NOT implementing a source or >> sink function? >> >> If yes, then how? >> >
