public class KeyedCoProcessOperatorWithWatermarkDelay<K,IN1,IN2,OUT> extends LegacyKeyedCoProcessOperator<K,IN1,IN2,OUT>
KeyedCoProcessOperator
that supports holding back watermarks with a static delay.AbstractStreamOperator.CountingOutput<OUT>
userFunction
chainingStrategy, config, latencyStats, LOG, metrics, output, timeServiceManager
Constructor and Description |
---|
KeyedCoProcessOperatorWithWatermarkDelay(CoProcessFunction<IN1,IN2,OUT> flatMapper,
long watermarkDelay) |
Modifier and Type | Method and Description |
---|---|
void |
processWatermark(Watermark mark) |
getCollector, onEventTime, onProcessingTime, open, processElement1, processElement2
close, dispose, getUserFunction, getUserFunctionParameters, initializeState, notifyCheckpointComplete, setOutputType, setup, snapshotState
getChainingStrategy, getContainingTask, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorID, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getUserCodeClassloader, initializeState, numEventTimeTimers, numProcessingTimeTimers, prepareSnapshotPreBarrier, processLatencyMarker, processLatencyMarker1, processLatencyMarker2, processWatermark1, processWatermark2, reportOrForwardLatencyMarker, setChainingStrategy, setCurrentKey, setKeyContextElement1, setKeyContextElement2, snapshotState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
processLatencyMarker1, processLatencyMarker2, processWatermark1, processWatermark2
close, dispose, getChainingStrategy, getMetricGroup, getOperatorID, initializeState, prepareSnapshotPreBarrier, setChainingStrategy, setKeyContextElement1, setKeyContextElement2, snapshotState
notifyCheckpointComplete
getCurrentKey, setCurrentKey
public KeyedCoProcessOperatorWithWatermarkDelay(CoProcessFunction<IN1,IN2,OUT> flatMapper, long watermarkDelay)
public void processWatermark(Watermark mark) throws Exception
processWatermark
in class AbstractStreamOperator<OUT>
Exception
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.