Not familiar with the implementation but thinking some options: - composable transformations - underlying MultiMap - ...
On Wed, Mar 22, 2023 at 10:24 AM Hang Ruan <ruanhang1...@gmail.com> wrote: > Hi, David, > I also read the code about the `SavepointWriter#withOperator`. The > transformations are stored 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 > > David Artiga <david.art...@gmail.com> 于2023年3月22日周三 15:22写道： > >> We are using state >> <https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/libs/state_processor_api/> >> processor >> API >> <https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/libs/state_processor_api/> >> to >> bootstrap the state of some operators. It has been working fine until now, >> when we tried to bootstrap an operator that has both a keyed state and a >> broadcasted state. Seems the API does not provide a convenient method to >> apply multiple transformations on the same *uid...* >> >> Is there a way to do that and we just missed it? Any insights appreciated. >> >> Cheers, >> /David >> >
