public class ProxyStreamOperatorStateContext extends Object implements org.apache.flink.streaming.api.operators.StreamOperatorStateContext
StreamOperatorStateContext
for the wrapped operator.Constructor and Description |
---|
ProxyStreamOperatorStateContext(org.apache.flink.streaming.api.operators.StreamOperatorStateContext wrapped,
String stateNamePrefix,
Iterator<org.apache.flink.runtime.state.StatePartitionStreamProvider> rawOperatorStates,
int numberOfRawOperatorStateEntries) |
Modifier and Type | Method and Description |
---|---|
OptionalLong |
getRestoredCheckpointId() |
org.apache.flink.streaming.api.operators.InternalTimeServiceManager<?> |
internalTimerServiceManager() |
boolean |
isRestored() |
org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<?> |
keyedStateBackend() |
org.apache.flink.runtime.state.OperatorStateBackend |
operatorStateBackend() |
org.apache.flink.util.CloseableIterable<org.apache.flink.runtime.state.KeyGroupStatePartitionStreamProvider> |
rawKeyedStateInputs() |
org.apache.flink.util.CloseableIterable<org.apache.flink.runtime.state.StatePartitionStreamProvider> |
rawOperatorStateInputs() |
public boolean isRestored()
isRestored
in interface org.apache.flink.streaming.api.operators.StreamOperatorStateContext
public OptionalLong getRestoredCheckpointId()
getRestoredCheckpointId
in interface org.apache.flink.streaming.api.operators.StreamOperatorStateContext
public org.apache.flink.runtime.state.OperatorStateBackend operatorStateBackend()
operatorStateBackend
in interface org.apache.flink.streaming.api.operators.StreamOperatorStateContext
public org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<?> keyedStateBackend()
keyedStateBackend
in interface org.apache.flink.streaming.api.operators.StreamOperatorStateContext
public org.apache.flink.streaming.api.operators.InternalTimeServiceManager<?> internalTimerServiceManager()
internalTimerServiceManager
in interface org.apache.flink.streaming.api.operators.StreamOperatorStateContext
public org.apache.flink.util.CloseableIterable<org.apache.flink.runtime.state.StatePartitionStreamProvider> rawOperatorStateInputs()
rawOperatorStateInputs
in interface org.apache.flink.streaming.api.operators.StreamOperatorStateContext
public org.apache.flink.util.CloseableIterable<org.apache.flink.runtime.state.KeyGroupStatePartitionStreamProvider> rawKeyedStateInputs()
rawKeyedStateInputs
in interface org.apache.flink.streaming.api.operators.StreamOperatorStateContext
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.