org.apache.flink.datastream.impl.operators

类 TwoOutputProcessOperator.SideOutputCollector

java.lang.Object

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

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

所有已实现的接口:

org.apache.flink.datastream.api.common.Collector<OUT_SIDE>

封闭类:

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.

字段概要

从类继承的字段 org.apache.flink.datastream.impl.common.TimestampCollector

reuse

构造器概要

构造器

构造器和说明
SideOutputCollector(org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<OUT_MAIN>> output)

方法概要

限定符和类型	方法和说明
void	collect(OUT_SIDE outputRecord)
void	collectAndOverwriteTimestamp(OUT_SIDE record, long timestamp)

从类继承的方法 org.apache.flink.datastream.impl.common.TimestampCollector

eraseTimestamp, setTimestamp, setTimestampFromStreamRecord

从类继承的方法 java.lang.Object

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

构造器详细资料

SideOutputCollector

public SideOutputCollector(org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<OUT_MAIN>> output)

方法详细资料

collect

public void collect(OUT_SIDE outputRecord)

collectAndOverwriteTimestamp

public void collectAndOverwriteTimestamp(OUT_SIDE record,
                                         long timestamp)