Package | Description |
---|---|
org.apache.flink.runtime.state | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.api.operators.sorted.state |
Modifier and Type | Method and Description |
---|---|
KeyedStateCheckpointOutputStream |
StateSnapshotContextSynchronousImpl.getRawKeyedOperatorStateOutput() |
KeyedStateCheckpointOutputStream |
StateSnapshotContext.getRawKeyedOperatorStateOutput()
Returns an output stream for keyed state
|
Modifier and Type | Method and Description |
---|---|
void |
InternalTimeServiceManagerImpl.snapshotToRawKeyedState(KeyedStateCheckpointOutputStream out,
String operatorName) |
void |
InternalTimeServiceManager.snapshotToRawKeyedState(KeyedStateCheckpointOutputStream stateCheckpointOutputStream,
String operatorName)
Snapshots the timers to raw keyed state.
|
Modifier and Type | Method and Description |
---|---|
void |
BatchExecutionInternalTimeServiceManager.snapshotToRawKeyedState(KeyedStateCheckpointOutputStream context,
String operatorName) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.