public class ProxyOutput<T> extends Object implements org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<T>>
Constructor and Description |
---|
ProxyOutput(org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<T>>> output) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
<X> void |
collect(org.apache.flink.util.OutputTag<X> outputTag,
org.apache.flink.streaming.runtime.streamrecord.StreamRecord<X> record) |
void |
collect(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<T> record) |
void |
emitLatencyMarker(org.apache.flink.streaming.runtime.streamrecord.LatencyMarker latencyMarker) |
void |
emitWatermark(org.apache.flink.streaming.api.watermark.Watermark mark) |
void |
emitWatermarkStatus(org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus watermarkStatus) |
void |
setContextRound(Integer contextRound) |
public ProxyOutput(org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<T>>> output)
public void setContextRound(Integer contextRound)
public void emitWatermark(org.apache.flink.streaming.api.watermark.Watermark mark)
emitWatermark
in interface org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<T>>
public void emitWatermarkStatus(org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus watermarkStatus)
emitWatermarkStatus
in interface org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<T>>
public <X> void collect(org.apache.flink.util.OutputTag<X> outputTag, org.apache.flink.streaming.runtime.streamrecord.StreamRecord<X> record)
collect
in interface org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<T>>
public void emitLatencyMarker(org.apache.flink.streaming.runtime.streamrecord.LatencyMarker latencyMarker)
emitLatencyMarker
in interface org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<T>>
public void collect(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<T> record)
collect
in interface org.apache.flink.util.Collector<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<T>>
public void close()
close
in interface org.apache.flink.util.Collector<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<T>>
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.