public class KeyedMapBundleOperator<K,V,IN,OUT> extends AbstractMapBundleOperator<K,V,IN,OUT>
KeyedMapBundleOperator
uses framework's key as bundle map key, thus can only be
used on KeyedStream
.AbstractStreamOperator.CountingOutput<OUT>
chainingStrategy, config, latencyStats, LOG, metrics, output, timeServiceManager
Constructor and Description |
---|
KeyedMapBundleOperator(MapBundleFunction<K,V,IN,OUT> function,
BundleTrigger<IN> bundleTrigger) |
Modifier and Type | Method and Description |
---|---|
protected K |
getKey(IN input)
Get the key for current processing element, which will be used as the map bundle's key.
|
close, finishBundle, open, prepareSnapshotPreBarrier, processElement, processWatermark
dispose, getChainingStrategy, getContainingTask, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorID, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getUserCodeClassloader, initializeState, initializeState, notifyCheckpointComplete, numEventTimeTimers, numProcessingTimeTimers, processLatencyMarker, processLatencyMarker1, processLatencyMarker2, processWatermark1, processWatermark2, reportOrForwardLatencyMarker, setChainingStrategy, setCurrentKey, setKeyContextElement1, setKeyContextElement2, setup, snapshotState, snapshotState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
processLatencyMarker
dispose, getChainingStrategy, getMetricGroup, getOperatorID, initializeState, setChainingStrategy, setKeyContextElement1, setKeyContextElement2, snapshotState
notifyCheckpointComplete
getCurrentKey, setCurrentKey
public KeyedMapBundleOperator(MapBundleFunction<K,V,IN,OUT> function, BundleTrigger<IN> bundleTrigger)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.