@Experimental public interface Collector<OUT>
Modifier and Type | Method and 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.
|
void collect(OUT record)
record
- to be collected.void collectAndOverwriteTimestamp(OUT record, long timestamp)
record
- to be collected.timestamp
- of the processed data.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.