Uses of Interface
org.apache.flink.util.Collector

Packages that use Collector

Package	Description
org.apache.flink.api.common.functions
org.apache.flink.api.common.functions.util
org.apache.flink.api.common.operators.base
org.apache.flink.api.common.serialization

Uses of Collector in org.apache.flink.api.common.functions

Methods in org.apache.flink.api.common.functions with parameters of type Collector

Modifier and Type	Method	Description
void	CoGroupFunction.coGroup(Iterable<IN1> first, Iterable<IN2> second, Collector<O> out)	This method must be implemented to provide a user implementation of a coGroup.
abstract void	RichCoGroupFunction.coGroup(Iterable<IN1> first, Iterable<IN2> second, Collector<OUT> out)
void	GroupCombineFunction.combine(Iterable<IN> values, Collector<OUT> out)	The combine method, called (potentially multiple timed) with subgroups of elements.
abstract void	RichGroupCombineFunction.combine(Iterable<IN> values, Collector<OUT> out)
void	FlatMapFunction.flatMap(T value, Collector<O> out)	The core method of the FlatMapFunction.
abstract void	RichFlatMapFunction.flatMap(IN value, Collector<OUT> out)
void	FlatJoinFunction.join(IN1 first, IN2 second, Collector<OUT> out)	The join method, called once per joined pair of elements.
abstract void	RichFlatJoinFunction.join(IN1 first, IN2 second, Collector<OUT> out)
void	MapPartitionFunction.mapPartition(Iterable<T> values, Collector<O> out)	A user-implemented function that modifies or transforms an incoming object.
abstract void	RichMapPartitionFunction.mapPartition(Iterable<I> values, Collector<O> out)
void	GroupReduceFunction.reduce(Iterable<T> values, Collector<O> out)	The reduce method.
abstract void	RichGroupReduceFunction.reduce(Iterable<IN> values, Collector<OUT> out)

Uses of Collector in org.apache.flink.api.common.functions.util

Classes in org.apache.flink.api.common.functions.util that implement Collector

Modifier and Type	Class	Description
class	CopyingListCollector<T>	A Collector that collects deep copies of its elements in a list.
class	ListCollector<T>	A Collector that puts the collected elements into a given list.

Uses of Collector in org.apache.flink.api.common.operators.base

Methods in org.apache.flink.api.common.operators.base with parameters of type Collector

Modifier and Type	Method	Description
void	BulkIterationBase.TerminationCriterionMapper.flatMap(X in, Collector<X> out)

Uses of Collector in org.apache.flink.api.common.serialization

Methods in org.apache.flink.api.common.serialization with parameters of type Collector

Modifier and Type	Method	Description
default void	DeserializationSchema.deserialize(byte[] message, Collector<T> out)	Deserializes the byte message.