Package | Description |
---|---|
org.apache.flink.api.java.operators | |
org.apache.flink.api.scala.operators |
Modifier and Type | Class and Description |
---|---|
class |
SortedGrouping<T>
SortedGrouping is an intermediate step for a transformation on a grouped and sorted DataSet.
|
class |
UnsortedGrouping<T>
A
Grouping that is unsorted. |
Constructor and Description |
---|
AggregateOperator(Grouping<IN> input,
Aggregations function,
int field,
String aggregateLocationName)
Grouped aggregation.
|
GroupCombineOperator(Grouping<IN> input,
TypeInformation<OUT> resultType,
GroupCombineFunction<IN,OUT> function,
String defaultName)
Constructor for a grouped reduce.
|
GroupReduceOperator(Grouping<IN> input,
TypeInformation<OUT> resultType,
GroupReduceFunction<IN,OUT> function,
String defaultName)
Constructor for a grouped reduce.
|
ReduceOperator(Grouping<IN> input,
ReduceFunction<IN> function,
String defaultName) |
Constructor and Description |
---|
ScalaAggregateOperator(Grouping<IN> input,
Aggregations function,
int field)
Grouped aggregation.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.