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.
- Deprecated
All Flink Scala APIs are deprecated and will be removed in a future Flink major version. You can still build your application in Scala, but you should move to the Java version of either the DataStream and/or Table API.
- See also
- Alphabetic
- By Inheritance
- ScalaAggregateOperator
- SingleInputOperator
- Operator
- DataSet
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
-
new
ScalaAggregateOperator(input: Grouping[IN], function: Aggregations, field: Int)
Grouped aggregation.
-
new
ScalaAggregateOperator(input: java.DataSet[IN], function: Aggregations, field: Int)
- Deprecated
All Flink Scala APIs are deprecated and will be removed in a future Flink major version. You can still build your application in Scala, but you should move to the Java version of either the DataStream and/or Table API.
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
aggregate(arg0: Aggregations, arg1: Int): AggregateOperator[IN]
- Definition Classes
- DataSet
- def and(function: Aggregations, field: Int): ScalaAggregateOperator[IN]
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clean[F](arg0: F): F
- Definition Classes
- DataSet
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
def
coGroup[R](arg0: java.DataSet[R]): CoGroupOperatorSets[IN, R]
- Definition Classes
- DataSet
-
def
collect(): List[IN]
- Definition Classes
- DataSet
- Annotations
- @throws( classOf[java.lang.Exception] )
-
def
combineGroup[R](arg0: GroupCombineFunction[IN, R]): GroupCombineOperator[IN, R]
- Definition Classes
- DataSet
-
def
count(): Long
- Definition Classes
- DataSet
- Annotations
- @throws( classOf[java.lang.Exception] )
-
def
cross[R](arg0: java.DataSet[R]): DefaultCross[IN, R]
- Definition Classes
- DataSet
-
def
crossWithHuge[R](arg0: java.DataSet[R]): DefaultCross[IN, R]
- Definition Classes
- DataSet
-
def
crossWithTiny[R](arg0: java.DataSet[R]): DefaultCross[IN, R]
- Definition Classes
- DataSet
-
def
distinct(): DistinctOperator[IN]
- Definition Classes
- DataSet
-
def
distinct(arg0: <repeated...>[String]): DistinctOperator[IN]
- Definition Classes
- DataSet
- Annotations
- @transient()
-
def
distinct(arg0: <repeated...>[Int]): DistinctOperator[IN]
- Definition Classes
- DataSet
- Annotations
- @transient()
-
def
distinct[K](arg0: KeySelector[IN, K]): DistinctOperator[IN]
- Definition Classes
- DataSet
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
fillInType(arg0: TypeInformation[IN]): Unit
- Attributes
- protected[org.apache.flink.api.java]
- Definition Classes
- DataSet
-
def
filter(arg0: FilterFunction[IN]): FilterOperator[IN]
- Definition Classes
- DataSet
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
first(arg0: Int): GroupReduceOperator[IN, IN]
- Definition Classes
- DataSet
-
def
flatMap[R](arg0: FlatMapFunction[IN, R]): FlatMapOperator[IN, R]
- Definition Classes
- DataSet
-
def
fullOuterJoin[R](arg0: java.DataSet[R], arg1: JoinHint): JoinOperatorSetsBase[IN, R]
- Definition Classes
- DataSet
-
def
fullOuterJoin[R](arg0: java.DataSet[R]): JoinOperatorSetsBase[IN, R]
- Definition Classes
- DataSet
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
getExecutionEnvironment(): java.ExecutionEnvironment
- Definition Classes
- DataSet
-
def
getInput(): java.DataSet[IN]
- Definition Classes
- SingleInputOperator
-
def
getInputType(): TypeInformation[IN]
- Definition Classes
- SingleInputOperator
-
def
getMinResources(): ResourceSpec
- Definition Classes
- Operator
-
def
getName(): String
- Definition Classes
- Operator
-
def
getParallelism(): Int
- Definition Classes
- Operator
-
def
getPreferredResources(): ResourceSpec
- Definition Classes
- Operator
-
def
getResultType(): TypeInformation[IN]
- Definition Classes
- Operator
-
def
getType(): TypeInformation[IN]
- Definition Classes
- DataSet
-
def
groupBy(arg0: <repeated...>[String]): UnsortedGrouping[IN]
- Definition Classes
- DataSet
- Annotations
- @transient()
-
def
groupBy(arg0: <repeated...>[Int]): UnsortedGrouping[IN]
- Definition Classes
- DataSet
- Annotations
- @transient()
-
def
groupBy[K](arg0: KeySelector[IN, K]): UnsortedGrouping[IN]
- Definition Classes
- DataSet
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
iterate(arg0: Int): IterativeDataSet[IN]
- Definition Classes
- DataSet
-
def
iterateDelta[R](arg0: java.DataSet[R], arg1: Int, arg2: <repeated...>[Int]): DeltaIteration[IN, R]
- Definition Classes
- DataSet
- Annotations
- @transient()
-
def
join[R](arg0: java.DataSet[R], arg1: JoinHint): JoinOperatorSets[IN, R]
- Definition Classes
- DataSet
-
def
join[R](arg0: java.DataSet[R]): JoinOperatorSets[IN, R]
- Definition Classes
- DataSet
-
def
joinWithHuge[R](arg0: java.DataSet[R]): JoinOperatorSets[IN, R]
- Definition Classes
- DataSet
-
def
joinWithTiny[R](arg0: java.DataSet[R]): JoinOperatorSets[IN, R]
- Definition Classes
- DataSet
-
def
leftOuterJoin[R](arg0: java.DataSet[R], arg1: JoinHint): JoinOperatorSetsBase[IN, R]
- Definition Classes
- DataSet
-
def
leftOuterJoin[R](arg0: java.DataSet[R]): JoinOperatorSetsBase[IN, R]
- Definition Classes
- DataSet
-
def
map[R](arg0: MapFunction[IN, R]): MapOperator[IN, R]
- Definition Classes
- DataSet
-
def
mapPartition[R](arg0: MapPartitionFunction[IN, R]): MapPartitionOperator[IN, R]
- Definition Classes
- DataSet
-
def
max(arg0: Int): AggregateOperator[IN]
- Definition Classes
- DataSet
-
def
maxBy(arg0: <repeated...>[Int]): ReduceOperator[IN]
- Definition Classes
- DataSet
- Annotations
- @transient()
-
def
min(arg0: Int): AggregateOperator[IN]
- Definition Classes
- DataSet
-
def
minBy(arg0: <repeated...>[Int]): ReduceOperator[IN]
- Definition Classes
- DataSet
- Annotations
- @transient()
-
def
name(arg0: String): ScalaAggregateOperator[IN]
- Definition Classes
- Operator
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
def
output(arg0: OutputFormat[IN]): DataSink[IN]
- Definition Classes
- DataSet
-
def
partitionByHash[K <: Comparable[K]](arg0: KeySelector[IN, K]): PartitionOperator[IN]
- Definition Classes
- DataSet
-
def
partitionByHash(arg0: <repeated...>[String]): PartitionOperator[IN]
- Definition Classes
- DataSet
- Annotations
- @transient()
-
def
partitionByHash(arg0: <repeated...>[Int]): PartitionOperator[IN]
- Definition Classes
- DataSet
- Annotations
- @transient()
-
def
partitionByRange[K <: Comparable[K]](arg0: KeySelector[IN, K]): PartitionOperator[IN]
- Definition Classes
- DataSet
-
def
partitionByRange(arg0: <repeated...>[String]): PartitionOperator[IN]
- Definition Classes
- DataSet
- Annotations
- @transient()
-
def
partitionByRange(arg0: <repeated...>[Int]): PartitionOperator[IN]
- Definition Classes
- DataSet
- Annotations
- @transient()
-
def
partitionCustom[K <: Comparable[K]](arg0: Partitioner[K], arg1: KeySelector[IN, K]): PartitionOperator[IN]
- Definition Classes
- DataSet
-
def
partitionCustom[K](arg0: Partitioner[K], arg1: String): PartitionOperator[IN]
- Definition Classes
- DataSet
-
def
partitionCustom[K](arg0: Partitioner[K], arg1: Int): PartitionOperator[IN]
- Definition Classes
- DataSet
-
def
print(): Unit
- Definition Classes
- DataSet
- Annotations
- @throws( classOf[java.lang.Exception] )
-
def
printOnTaskManager(arg0: String): DataSink[IN]
- Definition Classes
- DataSet
-
def
printToErr(): Unit
- Definition Classes
- DataSet
- Annotations
- @throws( classOf[java.lang.Exception] )
-
def
project[OUT <: Tuple](arg0: <repeated...>[Int]): ProjectOperator[_, OUT]
- Definition Classes
- DataSet
- Annotations
- @transient()
-
def
rebalance(): PartitionOperator[IN]
- Definition Classes
- DataSet
-
def
reduce(arg0: ReduceFunction[IN]): ReduceOperator[IN]
- Definition Classes
- DataSet
-
def
reduceGroup[R](arg0: GroupReduceFunction[IN, R]): GroupReduceOperator[IN, R]
- Definition Classes
- DataSet
-
def
rightOuterJoin[R](arg0: java.DataSet[R], arg1: JoinHint): JoinOperatorSetsBase[IN, R]
- Definition Classes
- DataSet
-
def
rightOuterJoin[R](arg0: java.DataSet[R]): JoinOperatorSetsBase[IN, R]
- Definition Classes
- DataSet
-
def
runOperation[X](arg0: CustomUnaryOperation[IN, X]): java.DataSet[X]
- Definition Classes
- DataSet
-
def
setParallelism(arg0: Int): ScalaAggregateOperator[IN]
- Definition Classes
- Operator
-
def
sortPartition[K](arg0: KeySelector[IN, K], arg1: Order): SortPartitionOperator[IN]
- Definition Classes
- DataSet
-
def
sortPartition(arg0: String, arg1: Order): SortPartitionOperator[IN]
- Definition Classes
- DataSet
-
def
sortPartition(arg0: Int, arg1: Order): SortPartitionOperator[IN]
- Definition Classes
- DataSet
-
def
sum(arg0: Int): AggregateOperator[IN]
- Definition Classes
- DataSet
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
def
translateToDataFlow(input: Operator[IN]): GroupReduceOperatorBase[IN, IN, GroupReduceFunction[IN, IN]]
- Attributes
- protected[org.apache.flink.api.scala.operators]
- Definition Classes
- ScalaAggregateOperator → SingleInputOperator
-
def
union(arg0: java.DataSet[IN]): UnionOperator[IN]
- Definition Classes
- DataSet
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
def
write(arg0: FileOutputFormat[IN], arg1: String, arg2: WriteMode): DataSink[IN]
- Definition Classes
- DataSet
-
def
write(arg0: FileOutputFormat[IN], arg1: String): DataSink[IN]
- Definition Classes
- DataSet
-
def
writeAsCsv(arg0: String, arg1: String, arg2: String, arg3: WriteMode): DataSink[IN]
- Definition Classes
- DataSet
-
def
writeAsCsv(arg0: String, arg1: String, arg2: String): DataSink[IN]
- Definition Classes
- DataSet
-
def
writeAsCsv(arg0: String, arg1: WriteMode): DataSink[IN]
- Definition Classes
- DataSet
-
def
writeAsCsv(arg0: String): DataSink[IN]
- Definition Classes
- DataSet
-
def
writeAsFormattedText(arg0: String, arg1: WriteMode, arg2: TextFormatter[IN]): DataSink[String]
- Definition Classes
- DataSet
-
def
writeAsFormattedText(arg0: String, arg1: TextFormatter[IN]): DataSink[String]
- Definition Classes
- DataSet
-
def
writeAsText(arg0: String, arg1: WriteMode): DataSink[IN]
- Definition Classes
- DataSet
-
def
writeAsText(arg0: String): DataSink[IN]
- Definition Classes
- DataSet
Deprecated Value Members
-
def
print(arg0: String): DataSink[IN]
- Definition Classes
- DataSet
- Annotations
- @Deprecated @deprecated
- Deprecated
(Since version ) see corresponding Javadoc for more information.
-
def
printToErr(arg0: String): DataSink[IN]
- Definition Classes
- DataSet
- Annotations
- @Deprecated @deprecated
- Deprecated
(Since version ) see corresponding Javadoc for more information.