org.apache.flink.table.runtime.operators.multipleinput.output

Class OutputBase

java.lang.Object

org.apache.flink.table.runtime.operators.multipleinput.output.OutputBase

All Implemented Interfaces:

Output<StreamRecord<RowData>>, Collector<StreamRecord<RowData>>

Direct Known Subclasses:

CopyingSecondInputOfTwoInputStreamOperatorOutput, FirstInputOfTwoInputStreamOperatorOutput, OneInputStreamOperatorOutput, SecondInputOfTwoInputStreamOperatorOutput

public abstract class OutputBase
extends Object
implements Output<StreamRecord<RowData>>

Base Output that can be used to emit elements and other messages in MultipleInputStreamOperatorBase.

Constructor Summary

Constructors

Constructor and Description
OutputBase(StreamOperator<?> operator)

Method Summary

Modifier and Type	Method and Description
void	close() Closes the collector.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.streaming.api.operators.Output

collect, emitLatencyMarker, emitRecordAttributes, emitWatermark, emitWatermarkStatus

Methods inherited from interface org.apache.flink.util.Collector

collect

Constructor Detail

OutputBase

public OutputBase(StreamOperator<?> operator)

Method Detail

close

public void close()

Description copied from interface: Collector

Closes the collector. If any data was buffered, that data will be flushed.

Specified by:

close in interface Collector<StreamRecord<RowData>>