Modifier and Type | Class and Description |
---|---|
class |
RichGroupReduceFunction<IN,OUT>
Rich variant of the
GroupReduceFunction . |
Modifier and Type | Class and Description |
---|---|
class |
GroupReduceOperatorBase<IN,OUT,FT extends GroupReduceFunction<IN,OUT>> |
Modifier and Type | Method and Description |
---|---|
<R> GroupReduceOperator<T,R> |
DataSet.reduceGroup(GroupReduceFunction<T,R> reducer)
Applies a GroupReduce transformation on a non-grouped
DataSet .The transformation calls a RichGroupReduceFunction once with the full DataSet. |
Modifier and Type | Class and Description |
---|---|
class |
FirstReducer<T> |
class |
GroupReduceIterator<IN,OUT> |
class |
SampleInCoordinator<T>
SampleInCoordinator wraps the sample logic of the coordinator side (the second phase of
distributed sample algorithm).
|
Modifier and Type | Class and Description |
---|---|
static class |
AggregateOperator.AggregatingUdf<T extends Tuple> |
Modifier and Type | Method and Description |
---|---|
protected GroupReduceFunction<IN,OUT> |
GroupReduceOperator.getFunction() |
Modifier and Type | Method and Description |
---|---|
protected GroupReduceOperatorBase<IN,IN,GroupReduceFunction<IN,IN>> |
AggregateOperator.translateToDataFlow(Operator<IN> input) |
Modifier and Type | Method and Description |
---|---|
<R> GroupReduceOperator<T,R> |
UnsortedGrouping.reduceGroup(GroupReduceFunction<T,R> reducer)
Applies a GroupReduce transformation on a grouped
DataSet .The transformation calls a RichGroupReduceFunction for each group of the DataSet. |
<R> GroupReduceOperator<T,R> |
SortedGrouping.reduceGroup(GroupReduceFunction<T,R> reducer)
Applies a GroupReduce transformation on a grouped and sorted
DataSet .The transformation calls a RichGroupReduceFunction for each group of the DataSet. |
Constructor and Description |
---|
GroupReduceOperator(DataSet<IN> input,
TypeInformation<OUT> resultType,
GroupReduceFunction<IN,OUT> function,
String defaultName)
Constructor for a non-grouped reduce (all reduce).
|
GroupReduceOperator(Grouping<IN> input,
TypeInformation<OUT> resultType,
GroupReduceFunction<IN,OUT> function,
String defaultName)
Constructor for a grouped reduce.
|
Modifier and Type | Class and Description |
---|---|
class |
CombineToGroupCombineWrapper<IN,OUT,F extends CombineFunction<IN,IN> & GroupReduceFunction<IN,OUT>>
A wrapper the wraps a function that implements both
CombineFunction and GroupReduceFunction interfaces
and makes it look like a function that implements GroupCombineFunction and GroupReduceFunction to the runtime. |
Constructor and Description |
---|
PlanUnwrappingReduceGroupOperator(GroupReduceFunction<IN,OUT> udf,
Keys.SelectorFunctionKeys<IN,K> key,
String name,
TypeInformation<OUT> outType,
TypeInformation<Tuple2<K,IN>> typeInfoWithKey,
boolean combinable) |
PlanUnwrappingSortedReduceGroupOperator(GroupReduceFunction<IN,OUT> udf,
Keys.SelectorFunctionKeys<IN,K1> groupingKey,
Keys.SelectorFunctionKeys<IN,K2> sortingKey,
String name,
TypeInformation<OUT> outType,
TypeInformation<Tuple3<K1,K2,IN>> typeInfoWithKey,
boolean combinable) |
Modifier and Type | Method and Description |
---|---|
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getGroupReduceReturnTypes(GroupReduceFunction<IN,OUT> groupReduceInterface,
TypeInformation<IN> inType) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getGroupReduceReturnTypes(GroupReduceFunction<IN,OUT> groupReduceInterface,
TypeInformation<IN> inType,
String functionName,
boolean allowMissing) |
Modifier and Type | Method and Description |
---|---|
<R> DataSet<R> |
GroupedDataSet.reduceGroup(GroupReduceFunction<T,R> reducer,
TypeInformation<R> evidence$8,
scala.reflect.ClassTag<R> evidence$9)
Creates a new
DataSet by passing for each group (elements with the same key) the list
of elements to the GroupReduceFunction . |
static <R> DataSet<R> |
CrossDataSet.reduceGroup(GroupReduceFunction<T,R> reducer,
TypeInformation<R> evidence$18,
scala.reflect.ClassTag<R> evidence$19) |
<R> DataSet<R> |
DataSet.reduceGroup(GroupReduceFunction<T,R> reducer,
TypeInformation<R> evidence$18,
scala.reflect.ClassTag<R> evidence$19)
Creates a new
DataSet by passing all elements in this DataSet to the group reduce function. |
Modifier and Type | Class and Description |
---|---|
static class |
ScalaAggregateOperator.AggregatingUdf<T extends scala.Product> |
Modifier and Type | Method and Description |
---|---|
protected GroupReduceOperatorBase<IN,IN,GroupReduceFunction<IN,IN>> |
ScalaAggregateOperator.translateToDataFlow(Operator<IN> input) |
Modifier and Type | Class and Description |
---|---|
static class |
PageRank.BuildOutgoingEdgeList
A reduce function that takes a sequence of edges and builds the adjacency list for the vertex where the edges
originate.
|
Modifier and Type | Class and Description |
---|---|
static class |
EnumTriangles.TriadBuilder |
Modifier and Type | Class and Description |
---|---|
static class |
MusicProfiles.CreateSimilarUserEdges |
Modifier and Type | Class and Description |
---|---|
static class |
VertexCentricIteration.MessageCombinerUdf<K,Message> |
Modifier and Type | Class and Description |
---|---|
class |
HadoopReduceCombineFunction<KEYIN,VALUEIN,KEYOUT,VALUEOUT>
This wrapper maps a Hadoop Reducer and Combiner (mapred API) to a combinable Flink GroupReduceFunction.
|
class |
HadoopReduceFunction<KEYIN,VALUEIN,KEYOUT,VALUEOUT>
This wrapper maps a Hadoop Reducer (mapred API) to a non-combinable Flink GroupReduceFunction.
|
Modifier and Type | Class and Description |
---|---|
class |
IdentityGroupReduce<IN> |
Modifier and Type | Method and Description |
---|---|
Class<GroupReduceFunction<IT,OT>> |
GroupReduceDriver.getStubType() |
Class<GroupReduceFunction<IT,OT>> |
AllGroupReduceDriver.getStubType() |
Modifier and Type | Method and Description |
---|---|
void |
GroupReduceDriver.setup(TaskContext<GroupReduceFunction<IT,OT>,OT> context) |
void |
AllGroupReduceDriver.setup(TaskContext<GroupReduceFunction<IT,OT>,OT> context) |
Modifier and Type | Class and Description |
---|---|
class |
DataSetAggFunction
RichGroupReduceFunction to compute aggregates that do not support pre-aggregation for batch
(DataSet) queries. |
class |
DataSetFinalAggFunction
RichGroupReduceFunction to compute the final result of a pre-aggregated aggregation
for batch (DataSet) queries. |
class |
DataSetSessionWindowAggReduceGroupFunction
It wraps the aggregate logic inside of
GroupReduceOperator . |
class |
DataSetSlideTimeWindowAggReduceGroupFunction
It is used for sliding windows on batch for time-windows.
|
class |
DataSetSlideWindowAggReduceCombineFunction
Wraps the aggregate logic inside of
GroupReduceOperator and
GroupCombineOperator . |
class |
DataSetSlideWindowAggReduceGroupFunction
It wraps the aggregate logic inside of
GroupReduceOperator . |
class |
DataSetTumbleCountWindowAggReduceGroupFunction
It wraps the aggregate logic inside of
GroupReduceOperator . |
class |
DataSetTumbleTimeWindowAggReduceCombineFunction
It wraps the aggregate logic inside of
GroupReduceOperator and
GroupCombineOperator . |
class |
DataSetTumbleTimeWindowAggReduceGroupFunction
It wraps the aggregate logic inside of
GroupReduceOperator . |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.