Package org.apache.flink.datastream.impl.operators

Class TwoOutputProcessOperator.SideOutputCollector

java.lang.Object

org.apache.flink.datastream.impl.common.TimestampCollector<OUT_SIDE>

org.apache.flink.datastream.impl.operators.TwoOutputProcessOperator.SideOutputCollector

All Implemented Interfaces:

Collector<OUT_SIDE>

Enclosing class:

TwoOutputProcessOperator<IN,OUT_MAIN,OUT_SIDE>

protected class TwoOutputProcessOperator.SideOutputCollector
extends TimestampCollector<OUT_SIDE>

This is a special implementation of TimestampCollector that using side-output mechanism to emit data.

Field Summary

Fields inherited from class org.apache.flink.datastream.impl.common.TimestampCollector

reuse

Constructor Summary

Constructors

Constructor	Description
SideOutputCollector(Output<StreamRecord<OUT_MAIN>> output)

Method Summary

Modifier and Type	Method	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.

Methods inherited from class org.apache.flink.datastream.impl.common.TimestampCollector

eraseTimestamp, setTimestamp, setTimestampFromStreamRecord

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SideOutputCollector

public SideOutputCollector(Output<StreamRecord<OUT_MAIN>> output)

Method Detail

collect

public void collect(OUT_SIDE outputRecord)

Description copied from interface: Collector

Collect record to output stream.

Parameters:

outputRecord - to be collected.

collectAndOverwriteTimestamp

public void collectAndOverwriteTimestamp(OUT_SIDE record,
                                         long timestamp)

Description copied from interface: Collector

Overwrite the timestamp of this record and collect it to output stream.

Parameters:

record - to be collected.

timestamp - of the processed data.