public class AbstractStreamOperator.CountingOutput extends Object implements Output<StreamRecord<OUT>>
Constructor and Description |
---|
CountingOutput(Output<StreamRecord<OUT>> output,
Counter counter) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the collector.
|
void |
collect(StreamRecord<OUT> record)
Emits a record.
|
void |
emitLatencyMarker(LatencyMarker latencyMarker) |
void |
emitWatermark(Watermark mark)
Emits a
Watermark from an operator. |
public CountingOutput(Output<StreamRecord<OUT>> output, Counter counter)
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.
emitWatermark
in interface Output<StreamRecord<OUT>>
public void emitLatencyMarker(LatencyMarker latencyMarker)
emitLatencyMarker
in interface Output<StreamRecord<OUT>>
public void collect(StreamRecord<OUT> record)
Collector
collect
in interface Collector<StreamRecord<OUT>>
record
- The record to collect.public void close()
Collector
close
in interface Collector<StreamRecord<OUT>>
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.