CloseableIterator<Tuple2<KEY,VoidNamespace>> |
KeyedStateReaderOperator.getKeysAndNamespaces(SavepointRuntimeContext ctx) |
abstract CloseableIterator<Tuple2<KEY,N>> |
StateReaderOperator.getKeysAndNamespaces(SavepointRuntimeContext ctx) |
CloseableIterator<Tuple2<KEY,W>> |
WindowReaderOperator.getKeysAndNamespaces(SavepointRuntimeContext ctx) |
void |
StateReaderOperator.setup(ExecutionConfig executionConfig,
KeyedStateBackend<KEY> keyKeyedStateBackend,
InternalTimeServiceManager<KEY> timerServiceManager,
SavepointRuntimeContext ctx) |