public class TwoInputBroadcastWrapperOperator<IN1,IN2,OUT> extends AbstractBroadcastWrapperOperator<OUT,org.apache.flink.streaming.api.operators.TwoInputStreamOperator<IN1,IN2,OUT>> implements org.apache.flink.streaming.api.operators.TwoInputStreamOperator<IN1,IN2,OUT>, org.apache.flink.streaming.api.operators.BoundedMultiInput
TwoInputStreamOperator
.broadcastStreamNames, broadcastVariablesReady, containingTask, dataCacheWriters, hasPendingElements, indexOfSubtask, inTypes, isBlocked, mailboxExecutor, metrics, numInputs, operatorFactory, output, parameters, stateHandler, streamConfig, timeServiceManager, wrappedOperator
Modifier and Type | Method and Description |
---|---|
void |
endInput(int inputId) |
void |
processElement1(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IN1> streamRecord) |
void |
processElement2(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IN2> streamRecord) |
void |
processLatencyMarker1(org.apache.flink.streaming.runtime.streamrecord.LatencyMarker latencyMarker) |
void |
processLatencyMarker2(org.apache.flink.streaming.runtime.streamrecord.LatencyMarker latencyMarker) |
void |
processWatermark1(org.apache.flink.streaming.api.watermark.Watermark watermark) |
void |
processWatermark2(org.apache.flink.streaming.api.watermark.Watermark watermark) |
void |
processWatermarkStatus1(org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus watermarkStatus) |
void |
processWatermarkStatus2(org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus watermarkStatus) |
areBroadcastVariablesReady, close, endInputX, finish, getCurrentKey, getMetricGroup, getOperatorID, initializeState, initializeState, notifyCheckpointAborted, notifyCheckpointComplete, open, prepareSnapshotPreBarrier, processElementX, processWatermarkX, setCurrentKey, setKeyContextElement1, setKeyContextElement2, snapshotState, snapshotState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, finish, getMetricGroup, getOperatorID, initializeState, open, prepareSnapshotPreBarrier, setKeyContextElement1, setKeyContextElement2, snapshotState
public void processElement1(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IN1> streamRecord) throws Exception
public void processElement2(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IN2> streamRecord) throws Exception
public void endInput(int inputId) throws Exception
endInput
in interface org.apache.flink.streaming.api.operators.BoundedMultiInput
Exception
public void processWatermark1(org.apache.flink.streaming.api.watermark.Watermark watermark) throws Exception
public void processWatermark2(org.apache.flink.streaming.api.watermark.Watermark watermark) throws Exception
public void processLatencyMarker1(org.apache.flink.streaming.runtime.streamrecord.LatencyMarker latencyMarker) throws Exception
public void processLatencyMarker2(org.apache.flink.streaming.runtime.streamrecord.LatencyMarker latencyMarker) throws Exception
public void processWatermarkStatus1(org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus watermarkStatus) throws Exception
public void processWatermarkStatus2(org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus watermarkStatus) throws Exception
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.