Modifier and Type | Class and Description |
---|---|
class |
RichReduceFunction<T>
Rich variant of the
ReduceFunction . |
Modifier and Type | Class and Description |
---|---|
class |
ReduceOperatorBase<T,FT extends ReduceFunction<T>>
Base data flow operator for Reduce user-defined functions.
|
Modifier and Type | Method and Description |
---|---|
ReduceFunction<T> |
ReducingStateDescriptor.getReduceFunction()
Returns the reduce function to be used for the reducing state.
|
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. |
Modifier and Type | Method and Description |
---|---|
ReduceOperator<T> |
DataSet.reduce(ReduceFunction<T> reducer)
Applies a Reduce transformation on a non-grouped
DataSet .The transformation consecutively calls a RichReduceFunction
until only a single element remains which is the result of the transformation. |
Modifier and Type | Class and Description |
---|---|
class |
SelectByMaxFunction<T extends Tuple> |
class |
SelectByMinFunction<T extends Tuple> |
Modifier and Type | Method and Description |
---|---|
protected ReduceFunction<IN> |
ReduceOperator.getFunction() |
Modifier and Type | Method and Description |
---|---|
ReduceOperator<T> |
UnsortedGrouping.reduce(ReduceFunction<T> reducer)
Applies a Reduce transformation on a grouped
DataSet .For each group, the transformation consecutively calls a RichReduceFunction
until only a single element for each group remains. |
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) |
Modifier and Type | Class and Description |
---|---|
static class |
PlanUnwrappingReduceOperator.ReduceWrapper<T,K> |
Constructor and Description |
---|
PlanUnwrappingReduceOperator(ReduceFunction<T> udf,
Keys.SelectorFunctionKeys<T,K> key,
String name,
TypeInformation<T> type,
TypeInformation<Tuple2<K,T>> typeInfoWithKey) |
Modifier and Type | Method and Description |
---|---|
DataSet<T> |
GroupedDataSet.reduce(ReduceFunction<T> reducer)
Creates a new
DataSet by merging the elements of each group (elements with the same key)
using an associative reduce function. |
DataSet<T> |
DataSet.reduce(ReduceFunction<T> reducer)
Creates a new
DataSet by merging the elements of this DataSet using an associative reduce
function. |
Modifier and Type | Class and Description |
---|---|
static class |
KMeans.CentroidAccumulator
Sums and counts point coordinates.
|
Modifier and Type | Class and Description |
---|---|
static class |
PiEstimation.SumReducer
Simply sums up all long values.
|
Modifier and Type | Class and Description |
---|---|
static class |
LinearRegression.UpdateAccumulator
Accumulator all the update.
|
Modifier and Type | Method and Description |
---|---|
Class<ReduceFunction<T>> |
ReduceDriver.getStubType() |
Class<ReduceFunction<T>> |
ReduceCombineDriver.getStubType() |
Class<ReduceFunction<T>> |
AllReduceDriver.getStubType() |
Modifier and Type | Method and Description |
---|---|
void |
ReduceDriver.setup(TaskContext<ReduceFunction<T>,T> context) |
void |
ReduceCombineDriver.setup(TaskContext<ReduceFunction<T>,T> context) |
void |
AllReduceDriver.setup(TaskContext<ReduceFunction<T>,T> context) |
Constructor and Description |
---|
GenericReducingState(ValueState<T> wrappedState,
ReduceFunction<T> reduceFunction)
Creates a new
ReducingState that wraps the given ValueState . |
Modifier and Type | Method and Description |
---|---|
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.apply(ReduceFunction<T> preAggregator,
AllWindowFunction<T,R,W> function)
Applies the given window function to each window.
|
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.apply(ReduceFunction<T> preAggregator,
AllWindowFunction<T,R,W> function,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<R> SingleOutputStreamOperator<R> |
WindowedStream.apply(ReduceFunction<T> reduceFunction,
WindowFunction<T,R,K,W> function)
Applies the given window function to each window.
|
<R> SingleOutputStreamOperator<R> |
WindowedStream.apply(ReduceFunction<T> reduceFunction,
WindowFunction<T,R,K,W> function,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
SingleOutputStreamOperator<T> |
WindowedStream.reduce(ReduceFunction<T> function)
Applies a reduce function to the window.
|
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> |
AllWindowedStream.reduce(ReduceFunction<T> function)
Applies a reduce function to the window.
|
Modifier and Type | Class and Description |
---|---|
class |
AggregationFunction<T> |
class |
ComparableAggregator<T> |
class |
SumAggregator<T> |
Constructor and Description |
---|
ReduceApplyAllWindowFunction(ReduceFunction<T> reduceFunction,
AllWindowFunction<T,R,W> windowFunction) |
ReduceApplyWindowFunction(ReduceFunction<T> reduceFunction,
WindowFunction<T,R,K,W> windowFunction) |
ReduceIterableAllWindowFunction(ReduceFunction<T> reduceFunction) |
ReduceIterableWindowFunction(ReduceFunction<T> reduceFunction) |
Constructor and Description |
---|
StreamGroupedReduce(ReduceFunction<IN> reducer,
TypeSerializer<IN> serializer) |
Modifier and Type | Method and Description |
---|---|
<R> DataStream<R> |
AllWindowedStream.apply(ReduceFunction<T> preAggregator,
AllWindowFunction<T,R,W> windowFunction,
TypeInformation<R> evidence$5)
Applies the given window function to each window.
|
<R> DataStream<R> |
WindowedStream.apply(ReduceFunction<T> preAggregator,
WindowFunction<T,R,K,W> function,
TypeInformation<R> evidence$5)
Applies the given window function to each window.
|
DataStream<T> |
AllWindowedStream.reduce(ReduceFunction<T> function)
Applies a reduce function to the window.
|
DataStream<T> |
WindowedStream.reduce(ReduceFunction<T> function)
Applies a reduce function to the window.
|
DataStream<T> |
KeyedStream.reduce(ReduceFunction<T> reducer)
Creates a new
DataStream by reducing the elements of this DataStream
using an associative reduce function. |
Modifier and Type | Class and Description |
---|---|
class |
ScalaReduceFunction<T>
A wrapper function that exposes a Scala Function2 as a
ReduceFunction . |
Modifier and Type | Class and Description |
---|---|
static class |
GroupedProcessingTimeWindowExample.SummingReducer |
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.
|
Constructor and Description |
---|
AggregatingKeyedTimePanes(KeySelector<Type,Key> keySelector,
ReduceFunction<Type> reducer) |
AggregatingProcessingTimeWindowOperator(ReduceFunction<IN> function,
KeySelector<IN,KEY> keySelector,
TypeSerializer<KEY> keySerializer,
TypeSerializer<IN> aggregateSerializer,
long windowLength,
long windowSlide) |
Constructor and Description |
---|
Factory(ReduceFunction<T> reduceFunction,
TypeSerializer<T> serializer) |
ReducingWindowBuffer(ReduceFunction<T> reduceFunction,
StreamRecord<T> data,
TypeSerializer<T> serializer) |
ReducingWindowBuffer(ReduceFunction<T> reduceFunction,
TypeSerializer<T> serializer) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.