@Internal public class CoStreamMap<IN1,IN2,OUT> extends AbstractUdfStreamOperator<OUT,CoMapFunction<IN1,IN2,OUT>> implements TwoInputStreamOperator<IN1,IN2,OUT>
AbstractStreamOperator.CountingOutput
userFunction
chainingStrategy, LOG, metrics, output
Constructor and Description |
---|
CoStreamMap(CoMapFunction<IN1,IN2,OUT> mapper) |
Modifier and Type | Method and Description |
---|---|
void |
processElement1(StreamRecord<IN1> element)
Processes one element that arrived on the first input of this two-input operator.
|
void |
processElement2(StreamRecord<IN2> element)
Processes one element that arrived on the second input of this two-input operator.
|
void |
processWatermark1(Watermark mark)
Processes a
Watermark that arrived on the first input of this two-input operator. |
void |
processWatermark2(Watermark mark)
Processes a
Watermark that arrived on the second input of this two-input operator. |
close, dispose, getUserFunction, getUserFunctionParameters, notifyOfCompletedCheckpoint, open, restoreState, setOutputType, setup, snapshotOperatorState
getChainingStrategy, getContainingTask, getCurrentProcessingTime, getExecutionConfig, getMetricGroup, getOperatorConfig, getOperatorName, getPartitionedState, getPartitionedState, getRuntimeContext, getStateBackend, getUserCodeClassloader, registerTimer, setChainingStrategy, setKeyContext, setKeyContextElement1, setKeyContextElement2
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, dispose, getChainingStrategy, getMetricGroup, notifyOfCompletedCheckpoint, open, restoreState, setChainingStrategy, setKeyContextElement1, setKeyContextElement2, setup, snapshotOperatorState
public CoStreamMap(CoMapFunction<IN1,IN2,OUT> mapper)
public void processElement1(StreamRecord<IN1> element) throws Exception
TwoInputStreamOperator
processElement1
in interface TwoInputStreamOperator<IN1,IN2,OUT>
Exception
public void processElement2(StreamRecord<IN2> element) throws Exception
TwoInputStreamOperator
processElement2
in interface TwoInputStreamOperator<IN1,IN2,OUT>
Exception
public void processWatermark1(Watermark mark) throws Exception
TwoInputStreamOperator
Watermark
that arrived on the first input of this two-input operator.
This method is guaranteed to not be called concurrently with other methods of the operator.processWatermark1
in interface TwoInputStreamOperator<IN1,IN2,OUT>
Exception
Watermark
public void processWatermark2(Watermark mark) throws Exception
TwoInputStreamOperator
Watermark
that arrived on the second input of this two-input operator.
This method is guaranteed to not be called concurrently with other methods of the operator.processWatermark2
in interface TwoInputStreamOperator<IN1,IN2,OUT>
Exception
Watermark
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.