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? >
