Uses of Interface
org.apache.flink.api.common.functions.ReduceFunction

Packages that use ReduceFunction

Package	Description
org.apache.flink.api.common.functions
org.apache.flink.api.common.operators.base
org.apache.flink.api.common.state
org.apache.flink.api.java
org.apache.flink.api.java.functions
org.apache.flink.api.java.operators
org.apache.flink.api.java.operators.translation
org.apache.flink.examples.java.clustering
org.apache.flink.examples.java.misc
org.apache.flink.examples.java.ml
org.apache.flink.graph.asm.degree.annotate	The degree annotation package provides a collection of edge-centric graph algorithms for counting the vertex degree of directed and undirected graphs.
org.apache.flink.graph.utils
org.apache.flink.runtime.operators
org.apache.flink.runtime.operators.hash
org.apache.flink.state.api
org.apache.flink.state.api.input.operator
org.apache.flink.state.api.input.operator.window
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.api.functions.aggregation
org.apache.flink.streaming.api.functions.windowing
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.transformations
org.apache.flink.streaming.runtime.operators.windowing	This package contains the operators that implement the various window operations on data streams.

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

Classes in org.apache.flink.api.common.functions that implement ReduceFunction

Modifier and Type	Class and Description
class	RichReduceFunction<T> Rich variant of the ReduceFunction.

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

Classes in org.apache.flink.api.common.operators.base with type parameters of type ReduceFunction

Modifier and Type	Class and Description
class	ReduceOperatorBase<T,FT extends ReduceFunction<T>> Base data flow operator for Reduce user-defined functions.

Uses of ReduceFunction in org.apache.flink.api.common.state

Methods in org.apache.flink.api.common.state that return ReduceFunction

Modifier and Type	Method and Description
ReduceFunction<T>	ReducingStateDescriptor.getReduceFunction() Returns the reduce function to be used for the reducing state.

Constructors in org.apache.flink.api.common.state with parameters of type ReduceFunction

Constructor and Description
ReducingStateDescriptor(String name, ReduceFunction<T> reduceFunction, Class<T> typeClass) Creates a new ReducingStateDescriptor with the given name, type, and default value.
ReducingStateDescriptor(String name, ReduceFunction<T> reduceFunction, TypeInformation<T> typeInfo) Creates a new ReducingStateDescriptor with the given name and default value.
ReducingStateDescriptor(String name, ReduceFunction<T> reduceFunction, TypeSerializer<T> typeSerializer) Creates a new ValueStateDescriptor with the given name and default value.

Uses of ReduceFunction in org.apache.flink.api.java

Methods in org.apache.flink.api.java with parameters of type ReduceFunction

Modifier and Type	Method and Description
ReduceOperator<T>	DataSet.reduce(ReduceFunction<T> reducer) Applies a Reduce transformation on a non-grouped DataSet.

Uses of ReduceFunction in org.apache.flink.api.java.functions

Classes in org.apache.flink.api.java.functions that implement ReduceFunction

Modifier and Type	Class and Description
class	SelectByMaxFunction<T extends Tuple> Function that enables selection by maximal value of a field.
class	SelectByMinFunction<T extends Tuple> Function that enables selection by minimal value of a field.

Uses of ReduceFunction in org.apache.flink.api.java.operators

Methods in org.apache.flink.api.java.operators that return ReduceFunction

Modifier and Type	Method and Description
protected ReduceFunction<IN>	ReduceOperator.getFunction()

Methods in org.apache.flink.api.java.operators with parameters of type ReduceFunction

Modifier and Type	Method and Description
ReduceOperator<T>	UnsortedGrouping.reduce(ReduceFunction<T> reducer) Applies a Reduce transformation on a grouped DataSet.

Constructors in org.apache.flink.api.java.operators with parameters of type ReduceFunction

Constructor and Description
ReduceOperator(DataSet<IN> input, ReduceFunction<IN> function, String defaultName) This is the case for a reduce-all case (in contrast to the reduce-per-group case).
ReduceOperator(Grouping<IN> input, ReduceFunction<IN> function, String defaultName)

Uses of ReduceFunction in org.apache.flink.api.java.operators.translation

Constructors in org.apache.flink.api.java.operators.translation with parameters of type ReduceFunction

Constructor and Description
PlanUnwrappingReduceOperator(ReduceFunction<T> udf, Keys.SelectorFunctionKeys<T,K> key, String name, TypeInformation<T> type, TypeInformation<Tuple2<K,T>> typeInfoWithKey)

Uses of ReduceFunction in org.apache.flink.examples.java.clustering

Classes in org.apache.flink.examples.java.clustering that implement ReduceFunction

Modifier and Type	Class and Description
static class	KMeans.CentroidAccumulator Sums and counts point coordinates.

Uses of ReduceFunction in org.apache.flink.examples.java.misc

Classes in org.apache.flink.examples.java.misc that implement ReduceFunction

Modifier and Type	Class and Description
static class	PiEstimation.SumReducer Simply sums up all long values.

Uses of ReduceFunction in org.apache.flink.examples.java.ml

Classes in org.apache.flink.examples.java.ml that implement ReduceFunction

Modifier and Type	Class and Description
static class	LinearRegression.UpdateAccumulator Accumulator all the update.

Uses of ReduceFunction in org.apache.flink.graph.asm.degree.annotate

Classes in org.apache.flink.graph.asm.degree.annotate that implement ReduceFunction

Modifier and Type	Class and Description
static class	DegreeAnnotationFunctions.DegreeCount<K> Combines the vertex degree count.

Uses of ReduceFunction in org.apache.flink.graph.utils

Classes in org.apache.flink.graph.utils that implement ReduceFunction

Modifier and Type	Class and Description
static class	GraphUtils.AddLongValue Add LongValue elements.

Uses of ReduceFunction in org.apache.flink.runtime.operators

Methods in org.apache.flink.runtime.operators that return types with arguments of type ReduceFunction

Modifier and Type	Method and Description
Class<ReduceFunction<T>>	ReduceCombineDriver.getStubType()
Class<ReduceFunction<T>>	AllReduceDriver.getStubType()
Class<ReduceFunction<T>>	ReduceDriver.getStubType()

Method parameters in org.apache.flink.runtime.operators with type arguments of type ReduceFunction

Modifier and Type	Method and Description
void	ReduceCombineDriver.setup(TaskContext<ReduceFunction<T>,T> context)
void	AllReduceDriver.setup(TaskContext<ReduceFunction<T>,T> context)
void	ReduceDriver.setup(TaskContext<ReduceFunction<T>,T> context)

Uses of ReduceFunction in org.apache.flink.runtime.operators.hash

Constructors in org.apache.flink.runtime.operators.hash with parameters of type ReduceFunction

Constructor and Description
ReduceFacade(ReduceFunction<T> reducer, Collector<T> outputCollector, boolean objectReuseEnabled)

Uses of ReduceFunction in org.apache.flink.state.api

Methods in org.apache.flink.state.api with parameters of type ReduceFunction

Modifier and Type	Method and Description
BootstrapTransformation<T>	WindowedOperatorTransformation.reduce(ReduceFunction<T> function) Applies a reduce function to the window.
<R> BootstrapTransformation<T>	WindowedOperatorTransformation.reduce(ReduceFunction<T> reduceFunction, ProcessWindowFunction<T,R,K,W> function) Applies the given window function to each window.
<R> BootstrapTransformation<T>	WindowedOperatorTransformation.reduce(ReduceFunction<T> reduceFunction, WindowFunction<T,R,K,W> function) Applies the given window function to each window.
<T,K> DataSet<T>	EvictingWindowReader.reduce(String uid, ReduceFunction<T> function, TypeInformation<K> keyType, TypeInformation<T> reduceType) Reads window state generated using a ReduceFunction.
<T,K> DataSet<T>	WindowReader.reduce(String uid, ReduceFunction<T> function, TypeInformation<K> keyType, TypeInformation<T> reduceType) Reads window state generated using a ReduceFunction.
<K,T,OUT> DataSet<OUT>	EvictingWindowReader.reduce(String uid, ReduceFunction<T> function, WindowReaderFunction<T,OUT,K,W> readerFunction, TypeInformation<K> keyType, TypeInformation<T> reduceType, TypeInformation<OUT> outputType) Reads window state generated using a ReduceFunction.
<K,T,OUT> DataSet<OUT>	WindowReader.reduce(String uid, ReduceFunction<T> function, WindowReaderFunction<T,OUT,K,W> readerFunction, TypeInformation<K> keyType, TypeInformation<T> reduceType, TypeInformation<OUT> outputType) Reads window state generated using a ReduceFunction.

Uses of ReduceFunction in org.apache.flink.state.api.input.operator

Methods in org.apache.flink.state.api.input.operator with parameters of type ReduceFunction

Modifier and Type	Method and Description
static <KEY,T,W extends Window,OUT> WindowReaderOperator<?,KEY,T,W,OUT>	WindowReaderOperator.reduce(ReduceFunction<T> function, WindowReaderFunction<T,OUT,KEY,W> reader, TypeInformation<KEY> keyType, TypeSerializer<W> windowSerializer, TypeInformation<T> inputType)

Uses of ReduceFunction in org.apache.flink.state.api.input.operator.window

Constructors in org.apache.flink.state.api.input.operator.window with parameters of type ReduceFunction

Constructor and Description
ReduceEvictingWindowReaderFunction(WindowReaderFunction<IN,OUT,KEY,W> wrappedFunction, ReduceFunction<IN> reduceFunction)

Uses of ReduceFunction in org.apache.flink.streaming.api.datastream

Methods in org.apache.flink.streaming.api.datastream with parameters of type ReduceFunction

Modifier and Type	Method and Description
<R> SingleOutputStreamOperator<R>	AllWindowedStream.apply(ReduceFunction<T> reduceFunction, AllWindowFunction<T,R,W> function) Deprecated. Use AllWindowedStream.reduce(ReduceFunction, AllWindowFunction) instead.
<R> SingleOutputStreamOperator<R>	AllWindowedStream.apply(ReduceFunction<T> reduceFunction, AllWindowFunction<T,R,W> function, TypeInformation<R> resultType) Deprecated. Use AllWindowedStream.reduce(ReduceFunction, AllWindowFunction, TypeInformation) instead.
<R> SingleOutputStreamOperator<R>	WindowedStream.apply(ReduceFunction<T> reduceFunction, WindowFunction<T,R,K,W> function) Deprecated. Use WindowedStream.reduce(ReduceFunction, WindowFunction) instead.
<R> SingleOutputStreamOperator<R>	WindowedStream.apply(ReduceFunction<T> reduceFunction, WindowFunction<T,R,K,W> function, TypeInformation<R> resultType) Deprecated. Use WindowedStream.reduce(ReduceFunction, WindowFunction, TypeInformation) instead.
SingleOutputStreamOperator<T>	KeyedStream.reduce(ReduceFunction<T> reducer) Applies a reduce transformation on the grouped data stream grouped on by the given key position.
SingleOutputStreamOperator<T>	WindowedStream.reduce(ReduceFunction<T> function) Applies a reduce function to the window.
SingleOutputStreamOperator<T>	AllWindowedStream.reduce(ReduceFunction<T> function) Applies a reduce function to the window.
<R> SingleOutputStreamOperator<R>	AllWindowedStream.reduce(ReduceFunction<T> reduceFunction, AllWindowFunction<T,R,W> function) Applies the given window function to each window.
<R> SingleOutputStreamOperator<R>	AllWindowedStream.reduce(ReduceFunction<T> reduceFunction, AllWindowFunction<T,R,W> function, TypeInformation<R> resultType) Applies the given window function to each window.
<R> SingleOutputStreamOperator<R>	AllWindowedStream.reduce(ReduceFunction<T> reduceFunction, ProcessAllWindowFunction<T,R,W> function) Applies the given window function to each window.
<R> SingleOutputStreamOperator<R>	AllWindowedStream.reduce(ReduceFunction<T> reduceFunction, ProcessAllWindowFunction<T,R,W> function, TypeInformation<R> resultType) Applies the given window function to each window.
<R> SingleOutputStreamOperator<R>	WindowedStream.reduce(ReduceFunction<T> reduceFunction, ProcessWindowFunction<T,R,K,W> function) Applies the given window function to each window.
<R> SingleOutputStreamOperator<R>	WindowedStream.reduce(ReduceFunction<T> reduceFunction, ProcessWindowFunction<T,R,K,W> function, TypeInformation<R> resultType) Applies the given window function to each window.
<R> SingleOutputStreamOperator<R>	WindowedStream.reduce(ReduceFunction<T> reduceFunction, WindowFunction<T,R,K,W> function) Applies the given window function to each window.
<R> SingleOutputStreamOperator<R>	WindowedStream.reduce(ReduceFunction<T> reduceFunction, WindowFunction<T,R,K,W> function, TypeInformation<R> resultType) Applies the given window function to each window.

Uses of ReduceFunction in org.apache.flink.streaming.api.functions.aggregation

Classes in org.apache.flink.streaming.api.functions.aggregation that implement ReduceFunction

Modifier and Type	Class and Description
class	AggregationFunction<T> Holder class for aggregation types that can be used on a windowed stream or keyed stream.
class	ComparableAggregator<T> An AggregationFunction that computes values based on comparisons of Comparables.
class	SumAggregator<T> An AggregationFunction that sums up fields.

Uses of ReduceFunction in org.apache.flink.streaming.api.functions.windowing

Constructors in org.apache.flink.streaming.api.functions.windowing with parameters of type ReduceFunction

Constructor and Description
ReduceApplyAllWindowFunction(ReduceFunction<T> reduceFunction, AllWindowFunction<T,R,W> windowFunction)
ReduceApplyProcessAllWindowFunction(ReduceFunction<T> reduceFunction, ProcessAllWindowFunction<T,R,W> windowFunction)
ReduceApplyProcessWindowFunction(ReduceFunction<T> reduceFunction, ProcessWindowFunction<T,R,K,W> windowFunction)
ReduceApplyWindowFunction(ReduceFunction<T> reduceFunction, WindowFunction<T,R,K,W> windowFunction)

Uses of ReduceFunction in org.apache.flink.streaming.api.operators

Constructors in org.apache.flink.streaming.api.operators with parameters of type ReduceFunction

Constructor and Description
BatchGroupedReduceOperator(ReduceFunction<IN> reducer, TypeSerializer<IN> serializer)
StreamGroupedReduceOperator(ReduceFunction<IN> reducer, TypeSerializer<IN> serializer)

Uses of ReduceFunction in org.apache.flink.streaming.api.transformations

Methods in org.apache.flink.streaming.api.transformations that return ReduceFunction

Modifier and Type	Method and Description
ReduceFunction<IN>	ReduceTransformation.getReducer()

Constructors in org.apache.flink.streaming.api.transformations with parameters of type ReduceFunction

Constructor and Description
ReduceTransformation(String name, int parallelism, Transformation<IN> input, ReduceFunction<IN> reducer, KeySelector<IN,K> keySelector, TypeInformation<K> keyTypeInfo)

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

Methods in org.apache.flink.streaming.runtime.operators.windowing with parameters of type ReduceFunction

Modifier and Type	Method and Description
V	KeyMap.putOrAggregate(K key, V value, ReduceFunction<V> aggregator) Inserts or aggregates a value into the hash map.
<R> WindowOperator<K,T,?,R,W>	WindowOperatorBuilder.reduce(ReduceFunction<T> reduceFunction, ProcessWindowFunction<T,R,K,W> function)
<R> WindowOperator<K,T,?,R,W>	WindowOperatorBuilder.reduce(ReduceFunction<T> reduceFunction, WindowFunction<T,R,K,W> function)