Interface OutputWithChainingCheck<OUT>
-
- All Superinterfaces:
AutoCloseable
,Closeable
,Collector<OUT>
,Output<OUT>
,WatermarkGaugeExposingOutput<OUT>
- All Known Implementing Classes:
RecordWriterOutput
@Internal public interface OutputWithChainingCheck<OUT> extends WatermarkGaugeExposingOutput<OUT>
This is a wrapper for outputs to check whether the collected record has been emitted to a downstream subtask or to a chained operator.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description <X> boolean
collectAndCheckIfChained(OutputTag<X> outputTag, StreamRecord<X> record)
boolean
collectAndCheckIfChained(OUT record)
-
Methods inherited from interface org.apache.flink.streaming.api.operators.Output
collect, emitLatencyMarker, emitRecordAttributes, emitWatermark, emitWatermarkStatus
-
Methods inherited from interface org.apache.flink.streaming.runtime.tasks.WatermarkGaugeExposingOutput
getWatermarkGauge
-
-
-
-
Method Detail
-
collectAndCheckIfChained
boolean collectAndCheckIfChained(OUT record)
- Returns:
- true if the collected record has been emitted to a downstream subtask. Otherwise, false.
-
collectAndCheckIfChained
<X> boolean collectAndCheckIfChained(OutputTag<X> outputTag, StreamRecord<X> record)
- Returns:
- true if the collected record has been emitted to a downstream subtask. Otherwise, false.
-
-