protected class TwoOutputProcessOperator.SideOutputCollector extends TimestampCollector<OUT_SIDE>
TimestampCollector
that using side-output
mechanism to emit data.reuse
Constructor and Description |
---|
SideOutputCollector(Output<StreamRecord<OUT_MAIN>> output) |
Modifier and Type | Method and Description |
---|---|
void |
collect(OUT_SIDE outputRecord)
Collect record to output stream.
|
void |
collectAndOverwriteTimestamp(OUT_SIDE record,
long timestamp)
Overwrite the timestamp of this record and collect it to output stream.
|
eraseTimestamp, setTimestamp, setTimestampFromStreamRecord
public SideOutputCollector(Output<StreamRecord<OUT_MAIN>> output)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.