org.apache.flink.api.scala.operators

Class ScalaAggregateOperator<IN>

java.lang.Object

org.apache.flink.api.java.DataSet<OUT>

org.apache.flink.api.java.operators.Operator<OUT,O>

org.apache.flink.api.java.operators.SingleInputOperator<IN,IN,ScalaAggregateOperator<IN>>

org.apache.flink.api.scala.operators.ScalaAggregateOperator<IN>

Type Parameters:

IN - The type of the data set aggregated by the operator.

@Public
public class ScalaAggregateOperator<IN>
extends SingleInputOperator<IN,IN,ScalaAggregateOperator<IN>>

This operator represents the application of a "aggregate" operation on a data set, and the result data set produced by the function.

Field Summary

Fields inherited from class org.apache.flink.api.java.operators.Operator

minResources, name, parallelism, preferredResources

Fields inherited from class org.apache.flink.api.java.DataSet

context

Constructor Summary

Constructors

Constructor and Description
ScalaAggregateOperator(DataSet<IN> input, Aggregations function, int field) Non grouped aggregation.
ScalaAggregateOperator(Grouping<IN> input, Aggregations function, int field) Grouped aggregation.

Method Summary

Modifier and Type	Method and Description
ScalaAggregateOperator<IN>	and(Aggregations function, int field)
protected GroupReduceOperatorBase<IN,IN,GroupReduceFunction<IN,IN>>	translateToDataFlow(Operator<IN> input) Translates this operation to a data flow operator of the common data flow API.

Methods inherited from class org.apache.flink.api.java.operators.SingleInputOperator

getInput, getInputType

Methods inherited from class org.apache.flink.api.java.operators.Operator

getMinResources, getName, getParallelism, getPreferredResources, getResultType, name, setParallelism

Methods inherited from class org.apache.flink.api.java.DataSet

aggregate, checkSameExecutionContext, clean, coGroup, collect, combineGroup, count, cross, crossWithHuge, crossWithTiny, distinct, distinct, distinct, distinct, fillInType, filter, first, flatMap, fullOuterJoin, fullOuterJoin, getExecutionEnvironment, getType, groupBy, groupBy, groupBy, iterate, iterateDelta, join, join, joinWithHuge, joinWithTiny, leftOuterJoin, leftOuterJoin, map, mapPartition, max, maxBy, min, minBy, output, partitionByHash, partitionByHash, partitionByHash, partitionByRange, partitionByRange, partitionByRange, partitionCustom, partitionCustom, partitionCustom, print, print, printOnTaskManager, printToErr, printToErr, project, rebalance, reduce, reduceGroup, rightOuterJoin, rightOuterJoin, runOperation, sortPartition, sortPartition, sortPartition, sum, union, write, write, writeAsCsv, writeAsCsv, writeAsCsv, writeAsCsv, writeAsFormattedText, writeAsFormattedText, writeAsText, writeAsText

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ScalaAggregateOperator

public ScalaAggregateOperator(DataSet<IN> input,
                              Aggregations function,
                              int field)

Non grouped aggregation.

ScalaAggregateOperator

public ScalaAggregateOperator(Grouping<IN> input,
                              Aggregations function,
                              int field)

Grouped aggregation.

Parameters:

input -

function -

field -

Method Detail

and

public ScalaAggregateOperator<IN> and(Aggregations function,
                                      int field)

translateToDataFlow

protected GroupReduceOperatorBase<IN,IN,GroupReduceFunction<IN,IN>> translateToDataFlow(Operator<IN> input)

Description copied from class: SingleInputOperator

Translates this operation to a data flow operator of the common data flow API.

Specified by:

translateToDataFlow in class SingleInputOperator<IN,IN,ScalaAggregateOperator<IN>>

Parameters:

input - The data flow operator that produces this operation's input data.

Returns:

The translated data flow operator.