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

Packages that use TimestampedCollector

Package	Description
org.apache.flink.streaming.api.operators.async.queue
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.
org.apache.flink.table.runtime.operators.join.stream
org.apache.flink.table.runtime.operators.window

Uses of TimestampedCollector in org.apache.flink.streaming.api.operators.async.queue

Methods in org.apache.flink.streaming.api.operators.async.queue with parameters of type TimestampedCollector

Modifier and Type	Method and Description
void	UnorderedStreamElementQueue.emitCompletedElement(TimestampedCollector<OUT> output)
void	OrderedStreamElementQueue.emitCompletedElement(TimestampedCollector<OUT> output)
void	StreamElementQueue.emitCompletedElement(TimestampedCollector<OUT> output) Emits one completed element from the head of this queue into the given output.

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>	LegacyKeyedCoProcessOperator.getCollector() Deprecated.
protected TimestampedCollector<OUT>	KeyedCoProcessOperator.getCollector()
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.

Uses of TimestampedCollector in org.apache.flink.table.runtime.operators.join.stream

Fields in org.apache.flink.table.runtime.operators.join.stream declared as TimestampedCollector

Modifier and Type	Field and Description
protected TimestampedCollector<RowData>	AbstractStreamingJoinOperator.collector

Uses of TimestampedCollector in org.apache.flink.table.runtime.operators.window

Fields in org.apache.flink.table.runtime.operators.window declared as TimestampedCollector

Modifier and Type	Field and Description
protected TimestampedCollector<RowData>	WindowOperator.collector This is used for emitting elements with a given timestamp.