public class KeyCheckedOutputCollector<KEY,OUT> extends TimestampCollector<OUT>
reuse
Constructor and Description |
---|
KeyCheckedOutputCollector(TimestampCollector<OUT> collector,
KeySelector<OUT,KEY> outKeySelector,
java.util.function.Supplier<KEY> currentKeyGetter) |
Modifier and Type | Method and Description |
---|---|
void |
collect(OUT outputRecord)
Collect record to output stream.
|
void |
collectAndOverwriteTimestamp(OUT outputRecord,
long timestamp)
Overwrite the timestamp of this record and collect it to output stream.
|
eraseTimestamp, setTimestamp, setTimestampFromStreamRecord
public KeyCheckedOutputCollector(TimestampCollector<OUT> collector, KeySelector<OUT,KEY> outKeySelector, java.util.function.Supplier<KEY> currentKeyGetter)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.