FFR] = null
>
>
>
> override def snapshotState(context: FunctionSnapshotContext): Unit = {
>
> }
>
>
>
> override def initializeState(context: FunctionInitializationContext):
> Unit = {
>
> val fFRStateDescriptor = new ListStateDescriptor[FFR](&
user@flink.apache.org
Subject: Re: Bootstrapping multiple state within same operator
⚠EXTERNAL MESSAGE – CAUTION: Think Before You Click ⚠
Not familiar with the implementation but thinking some options:
- composable transformations
- underlying MultiMap
- ...
On Wed, Mar 22, 2023
Not familiar with the implementation but thinking some options:
- composable transformations
- underlying MultiMap
- ...
On Wed, Mar 22, 2023 at 10:24 AM Hang Ruan wrote:
> Hi, David,
> I also read the code about the `SavepointWriter#withOperator`. The
> transformations are stored in a `Map` wh
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 `XXXStateBoots
