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 . |
Modifier and Type | Class and Description |
---|---|
class |
FirstReducer<T>
Reducer that only emits the first N elements in a group.
|
class |
GroupReduceIterator<IN,OUT>
Base class that simplifies reducing all values provided as
Iterable . |
class |
SampleInCoordinator<T>
SampleInCoordinator wraps the sample logic of the coordinator side (the second phase of
distributed sample algorithm).
|
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> |
SortedGrouping.reduceGroup(GroupReduceFunction<T,R> reducer)
Applies a GroupReduce transformation on a grouped and sorted
DataSet . |
<R> GroupReduceOperator<T,R> |
UnsortedGrouping.reduceGroup(GroupReduceFunction<T,R> reducer)
Applies a GroupReduce transformation on a grouped
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. |
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. |
class |
RichCombineToGroupCombineWrapper<IN,OUT,F extends RichGroupReduceFunction<IN,OUT> & CombineFunction<IN,IN>>
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 |
---|---|
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 |
---|---|
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>
Utility function to group and sort data.
|
Modifier and Type | Method and Description |
---|---|
Class<GroupReduceFunction<IT,OT>> |
AllGroupReduceDriver.getStubType() |
Class<GroupReduceFunction<IT,OT>> |
GroupReduceDriver.getStubType() |
Modifier and Type | Method and Description |
---|---|
void |
AllGroupReduceDriver.setup(TaskContext<GroupReduceFunction<IT,OT>,OT> context) |
void |
GroupReduceDriver.setup(TaskContext<GroupReduceFunction<IT,OT>,OT> context) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.