public interface StreamTaskStateInitializer
StreamOperatorStateContextto their operators. Operators, in turn, can use the context to initialize everything connected to their state, such as backends or a timer service manager.
|Modifier and Type||Method and Description|
StreamOperatorStateContext streamOperatorStateContext(@Nonnull OperatorID operatorID, @Nonnull String operatorClassName, @Nonnull ProcessingTimeService processingTimeService, @Nonnull KeyContext keyContext, @Nullable TypeSerializer<?> keySerializer, @Nonnull CloseableRegistry streamTaskCloseableRegistry, @Nonnull MetricGroup metricGroup, double managedMemoryFraction, boolean isUsingCustomRawKeyedState) throws Exception
AbstractStreamOperatorthat runs in the stream task that owns this manager.
operatorID- the id of the operator for which the context is created. Cannot be null.
operatorClassName- the classname of the operator instance for which the context is created. Cannot be null.
keyContext- the key context of the operator instance for which the context is created Cannot be null.
keySerializer- the key-serializer for the operator. Can be null.
streamTaskCloseableRegistry- the closeable registry to which created closeable objects will be registered.
metricGroup- the parent metric group for all statebackend metrics
managedMemoryFraction- the managed memory fraction of the operator for state backend
isUsingCustomRawKeyedState- flag indicating whether or not the
AbstractStreamOperatoris writing custom raw keyed state.
Exception- when something went wrong while creating the context.
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.