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. -
-
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 Description voidOrderedStreamElementQueue. emitCompletedElement(TimestampedCollector<OUT> output)voidStreamElementQueue. emitCompletedElement(TimestampedCollector<OUT> output)Emits one completed element from the head of this queue into the given output.voidUnorderedStreamElementQueue. emitCompletedElement(TimestampedCollector<OUT> 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 Description protected TimestampedCollector<OUT>CoStreamFlatMap. getCollector()protected TimestampedCollector<OUT>KeyedCoProcessOperator. getCollector()protected TimestampedCollector<OUT>LegacyKeyedCoProcessOperator. getCollector()Deprecated. -
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 Description protected TimestampedCollector<OUT>WindowOperator. timestampedCollectorThis is given to theInternalWindowFunctionfor emitting elements with a given timestamp.
-