Re: Bootstrapping multiple state within same operator

2023-03-24 Thread David Artiga
= null > > > > override def snapshotState(context: FunctionSnapshotContext): Unit = { > > } > > > > override def initializeState(context: FunctionInitializationContext): > Unit = { > > val fFRStateDescriptor = new ListStateDescriptor[FFR]("

Re: Bootstrapping multiple state within same operator

2023-03-22 Thread David Artiga
in a `Map` whose key is `OperatorID`. I don't > come up with a way that we could register multi transformations for one > operator with the provided API. > > Maybe we need a new type of `XXXStateBootstrapFunction` to change more > states at one time. > > Best, > Hang > &

Bootstrapping multiple state within same operator

2023-03-22 Thread David Artiga
We are using state processor API to bootstrap the state of some operators. It has been working fine until now,