public class CopyingSecondInputOfTwoInputStreamOperatorOutput extends OutputBase
Output
that can be used to emit copying elements and other messages for the second
input of TwoInputStreamOperator
.Constructor and Description |
---|
CopyingSecondInputOfTwoInputStreamOperatorOutput(TwoInputStreamOperator<RowData,RowData,RowData> operator,
TypeSerializer<RowData> serializer) |
Modifier and Type | Method and Description |
---|---|
<X> void |
collect(OutputTag<X> outputTag,
StreamRecord<X> record)
Emits a record to the side output identified by the given
OutputTag . |
void |
collect(StreamRecord<RowData> record)
Emits a record.
|
void |
emitLatencyMarker(LatencyMarker latencyMarker) |
void |
emitRecordAttributes(RecordAttributes recordAttributes)
Emits a
RecordAttributes from an operator. |
void |
emitWatermark(Watermark mark)
Emits a
Watermark from an operator. |
void |
emitWatermarkStatus(WatermarkStatus watermarkStatus) |
protected <X> void |
pushToOperator(StreamRecord<X> record) |
close
public CopyingSecondInputOfTwoInputStreamOperatorOutput(TwoInputStreamOperator<RowData,RowData,RowData> operator, TypeSerializer<RowData> serializer)
public void emitWatermark(Watermark mark)
Output
Watermark
from an operator. This watermark is broadcast to all downstream
operators.
A watermark specifies that no element with a timestamp lower or equal to the watermark timestamp will be emitted in the future.
public void emitWatermarkStatus(WatermarkStatus watermarkStatus)
public void emitLatencyMarker(LatencyMarker latencyMarker)
public void emitRecordAttributes(RecordAttributes recordAttributes)
Output
RecordAttributes
from an operator. This element is broadcast to all
downstream operators.public void collect(StreamRecord<RowData> record)
Collector
record
- The record to collect.public <X> void collect(OutputTag<X> outputTag, StreamRecord<X> record)
Output
OutputTag
.record
- The record to collect.protected <X> void pushToOperator(StreamRecord<X> record)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.