Hi, I am not very familiar with the State Processor API, but from a brief look at it, I think you are right. I think the State Processor API does not support mixing different kinds of states in a single operator for now. At least not in a nice way. Probably you could implement the KeyedBroadcastStateBootstrapFunction yourself and us it with KeyedOperatorTransformation#transform(org.apache.flink.state.api.SavepointWriterOperatorFactory). I understand this is probably not the easiest task.
I am not aware if there are plans to support that out of the box, but I cc'ed Gordon and Seth who if I remember correctly worked on that API. I hope they might give you some more insights. Best, Dawid On 23/03/2020 17:36, Mark Niehe wrote: > Hey all, > > I have another question about the State Processor API. I can't seem to > find a way to create a KeyedBroadcastStateBootstrapFunction operator. > The two options currently available to bootstrap a savepoint with > state are KeyedStateBootstrapFunction and > BroadcastStateBootstrapFunction. Because these are the only two > options, it's not possible to bootstrap both keyed and broadcast state > for the same operator. Are there any plans to add that functionality > or did I miss it entirely when going through the API docs? > > Thanks, > -- > <http://segment.com/> > Mark Niehe · Software Engineer > Integrations > <https://segment.com/catalog?utm_source=signature&utm_medium=email> · Blog > <https://segment.com/blog?utm_source=signature&utm_medium=email> · We're > Hiring! <https://segment.com/jobs?utm_source=signature&utm_medium=email>
signature.asc
Description: OpenPGP digital signature
