org.apache.flink.datastream.impl.common

类 KeyCheckedOutputCollector<KEY,OUT>

java.lang.Object

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

org.apache.flink.datastream.impl.common.KeyCheckedOutputCollector<KEY,OUT>

所有已实现的接口:

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

public class KeyCheckedOutputCollector<KEY,OUT>
extends TimestampCollector<OUT>

This output checks whether the current key of the output record and the key extracted with a specific key selector are exactly the same.

字段概要

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

reuse

构造器概要

构造器

构造器和说明
KeyCheckedOutputCollector(TimestampCollector<OUT> collector, org.apache.flink.api.java.functions.KeySelector<OUT,KEY> outKeySelector, Supplier<KEY> currentKeyGetter)

方法概要

限定符和类型	方法和说明
void	collect(OUT outputRecord)
void	collectAndOverwriteTimestamp(OUT outputRecord, 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

构造器详细资料

KeyCheckedOutputCollector

public KeyCheckedOutputCollector(TimestampCollector<OUT> collector,
                                 org.apache.flink.api.java.functions.KeySelector<OUT,KEY> outKeySelector,
                                 Supplier<KEY> currentKeyGetter)

方法详细资料

collect

public void collect(OUT outputRecord)

collectAndOverwriteTimestamp

public void collectAndOverwriteTimestamp(OUT outputRecord,
                                         long timestamp)