Package | Description |
---|---|
org.apache.flink.streaming.api.operators |
Modifier and Type | Method and Description |
---|---|
StreamOperatorStateContext |
StreamTaskStateInitializerImpl.streamOperatorStateContext(OperatorID operatorID,
String operatorClassName,
KeyContext keyContext,
TypeSerializer<?> keySerializer,
CloseableRegistry streamTaskCloseableRegistry,
MetricGroup metricGroup) |
StreamOperatorStateContext |
StreamTaskStateInitializer.streamOperatorStateContext(OperatorID operatorID,
String operatorClassName,
KeyContext keyContext,
TypeSerializer<?> keySerializer,
CloseableRegistry streamTaskCloseableRegistry,
MetricGroup metricGroup)
Returns the
StreamOperatorStateContext for an AbstractStreamOperator that runs in the stream
task that owns this manager. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.