类的使用
org.apache.flink.datastream.impl.common.TimestampCollector

使用TimestampCollector的程序包

程序包	说明
org.apache.flink.datastream.impl.common
org.apache.flink.datastream.impl.operators

org.apache.flink.datastream.impl.common中TimestampCollector的使用

org.apache.flink.datastream.impl.common中TimestampCollector的子类

限定符和类型	类和说明
class	KeyCheckedOutputCollector<KEY,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.
class	OutputCollector<OUT> The default implementation of Collector.

参数类型为TimestampCollector的org.apache.flink.datastream.impl.common中的构造器

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

org.apache.flink.datastream.impl.operators中TimestampCollector的使用

org.apache.flink.datastream.impl.operators中TimestampCollector的子类

限定符和类型	类和说明
protected class	TwoOutputProcessOperator.SideOutputCollector This is a special implementation of TimestampCollector that using side-output mechanism to emit data.

声明为TimestampCollector的org.apache.flink.datastream.impl.operators中的字段

限定符和类型	字段和说明
protected TimestampCollector<OUT>	TwoInputNonBroadcastProcessOperator.collector
protected TimestampCollector<OUT>	TwoInputBroadcastProcessOperator.collector
protected TimestampCollector<OUT_MAIN>	TwoOutputProcessOperator.mainCollector
protected TimestampCollector<OUT>	ProcessOperator.outputCollector
protected TimestampCollector<OUT_SIDE>	TwoOutputProcessOperator.sideCollector

返回TimestampCollector的org.apache.flink.datastream.impl.operators中的方法

限定符和类型	方法和说明
protected TimestampCollector<OUT_MAIN>	KeyedTwoOutputProcessOperator.getMainCollector()
protected TimestampCollector<OUT_MAIN>	TwoOutputProcessOperator.getMainCollector()
protected TimestampCollector<OUT>	TwoInputNonBroadcastProcessOperator.getOutputCollector()
protected TimestampCollector<OUT>	ProcessOperator.getOutputCollector()
protected TimestampCollector<OUT>	KeyedProcessOperator.getOutputCollector()
protected TimestampCollector<OUT>	KeyedTwoInputNonBroadcastProcessOperator.getOutputCollector()
protected TimestampCollector<OUT>	KeyedTwoInputBroadcastProcessOperator.getOutputCollector()
protected TimestampCollector<OUT>	TwoInputBroadcastProcessOperator.getOutputCollector()
TimestampCollector<OUT_SIDE>	KeyedTwoOutputProcessOperator.getSideCollector()
TimestampCollector<OUT_SIDE>	TwoOutputProcessOperator.getSideCollector()