Interface Collector<OUT>
-
- All Known Implementing Classes:
KeyCheckedOutputCollector
,OutputCollector
,TimestampCollector
,TwoOutputProcessOperator.SideOutputCollector
@Experimental public interface Collector<OUT>
This class take response for collecting data to output stream.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
collect(OUT record)
Collect record to output stream.void
collectAndOverwriteTimestamp(OUT record, long timestamp)
Overwrite the timestamp of this record and collect it to output stream.
-
-
-
Method Detail
-
collect
void collect(OUT record)
Collect record to output stream.- Parameters:
record
- to be collected.
-
collectAndOverwriteTimestamp
void collectAndOverwriteTimestamp(OUT record, long timestamp)
Overwrite the timestamp of this record and collect it to output stream.- Parameters:
record
- to be collected.timestamp
- of the processed data.
-
-