@PublicEvolving public interface StateInitializationContext extends FunctionInitializationContext
Similar to the managed state from
ManagedInitializationContext and in general, raw operator state is
available to all operators, while raw keyed state is only available for operators after keyBy.
For the purpose of initialization, the context signals if all state is empty (new operator) or if any state was restored from a previous execution of this operator.
|Modifier and Type||Method and Description|
Returns an iterable to obtain input streams for previously stored keyed state partitions that are assigned to this operator.
Returns an iterable to obtain input streams for previously stored operator state partitions that are assigned to this operator.
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.