KEY
- The key type read from the state backend.OUT
- The output type of the function.@Internal public class KeyedStateReaderOperator<KEY,OUT> extends StateReaderOperator<KeyedStateReaderFunction<KEY,OUT>,KEY,VoidNamespace,OUT>
StateReaderOperator
for executing a KeyedStateReaderFunction
.function, namespaceSerializer
Constructor and Description |
---|
KeyedStateReaderOperator(KeyedStateReaderFunction<KEY,OUT> function,
TypeInformation<KEY> keyType) |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<Tuple2<KEY,VoidNamespace>> |
getKeysAndNamespaces(SavepointRuntimeContext ctx) |
void |
open() |
void |
processElement(KEY key,
VoidNamespace namespace,
Collector<OUT> out) |
close, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyType, setCurrentKey, setup
public KeyedStateReaderOperator(KeyedStateReaderFunction<KEY,OUT> function, TypeInformation<KEY> keyType)
public void open() throws Exception
open
in class StateReaderOperator<KeyedStateReaderFunction<KEY,OUT>,KEY,VoidNamespace,OUT>
Exception
public void processElement(KEY key, VoidNamespace namespace, Collector<OUT> out) throws Exception
processElement
in class StateReaderOperator<KeyedStateReaderFunction<KEY,OUT>,KEY,VoidNamespace,OUT>
Exception
public CloseableIterator<Tuple2<KEY,VoidNamespace>> getKeysAndNamespaces(SavepointRuntimeContext ctx) throws Exception
getKeysAndNamespaces
in class StateReaderOperator<KeyedStateReaderFunction<KEY,OUT>,KEY,VoidNamespace,OUT>
Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.