Package | Description |
---|---|
org.apache.flink.state.api.input.operator |
Modifier and Type | Method and Description |
---|---|
Iterator<Tuple2<KEY,VoidNamespace>> |
KeyedStateReaderOperator.getKeysAndNamespaces(SavepointRuntimeContext ctx) |
abstract Iterator<Tuple2<KEY,N>> |
StateReaderOperator.getKeysAndNamespaces(SavepointRuntimeContext ctx) |
void |
StateReaderOperator.setup(ExecutionConfig executionConfig,
KeyedStateBackend<KEY> keyKeyedStateBackend,
InternalTimeServiceManager<KEY> timerServiceManager,
SavepointRuntimeContext ctx) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.