Uses of Class
org.apache.flink.streaming.api.operators.TimestampedCollector

Packages that use TimestampedCollector

Package	Description
org.apache.flink.storm.wrappers
org.apache.flink.streaming.api.operators.co
org.apache.flink.streaming.runtime.operators.windowing	This package contains the operators that implement the various window operations on data streams.

Uses of TimestampedCollector in org.apache.flink.storm.wrappers

Fields in org.apache.flink.storm.wrappers declared as TimestampedCollector

Modifier and Type	Field and Description
protected TimestampedCollector<OUT>	BoltWrapper.flinkCollector We have to use this because Operators must output StreamRecord.

Uses of TimestampedCollector in org.apache.flink.streaming.api.operators.co

Methods in org.apache.flink.streaming.api.operators.co that return TimestampedCollector

Modifier and Type	Method and Description
protected TimestampedCollector<OUT>	CoStreamFlatMap.getCollector()

Uses of TimestampedCollector in org.apache.flink.streaming.runtime.operators.windowing

Fields in org.apache.flink.streaming.runtime.operators.windowing declared as TimestampedCollector

Modifier and Type	Field and Description
protected TimestampedCollector<OUT>	WindowOperator.timestampedCollector This is given to the InternalWindowFunction for emitting elements with a given timestamp.
protected TimestampedCollector<OUT>	NonKeyedWindowOperator.timestampedCollector This is given to the WindowFunction for emitting elements with a given timestamp.