Class

org.apache.flink.api.scala.operators

ScalaAggregateOperator

Related Doc: package operators

Permalink

class ScalaAggregateOperator[IN] extends SingleInputOperator[IN, IN, ScalaAggregateOperator[IN]]

Linear Supertypes
SingleInputOperator[IN, IN, ScalaAggregateOperator[IN]], Operator[IN, ScalaAggregateOperator[IN]], java.DataSet[IN], AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ScalaAggregateOperator
  2. SingleInputOperator
  3. Operator
  4. DataSet
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ScalaAggregateOperator(input: Grouping[IN], function: Aggregations, field: Int)

    Permalink
  2. new ScalaAggregateOperator(input: java.DataSet[IN], function: Aggregations, field: Int)

    Permalink

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  4. def aggregate(arg0: Aggregations, arg1: Int): AggregateOperator[IN]

    Permalink
    Definition Classes
    DataSet
  5. def and(function: Aggregations, field: Int): ScalaAggregateOperator[IN]

    Permalink
  6. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  7. def clean[F](arg0: F): F

    Permalink
    Definition Classes
    DataSet
  8. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  9. def coGroup[R](arg0: java.DataSet[R]): CoGroupOperatorSets[IN, R]

    Permalink
    Definition Classes
    DataSet
  10. def collect(): List[IN]

    Permalink
    Definition Classes
    DataSet
    Annotations
    @throws( classOf[java.lang.Exception] )
  11. def combineGroup[R](arg0: GroupCombineFunction[IN, R]): GroupCombineOperator[IN, R]

    Permalink
    Definition Classes
    DataSet
  12. def count(): Long

    Permalink
    Definition Classes
    DataSet
    Annotations
    @throws( classOf[java.lang.Exception] )
  13. def cross[R](arg0: java.DataSet[R]): DefaultCross[IN, R]

    Permalink
    Definition Classes
    DataSet
  14. def crossWithHuge[R](arg0: java.DataSet[R]): DefaultCross[IN, R]

    Permalink
    Definition Classes
    DataSet
  15. def crossWithTiny[R](arg0: java.DataSet[R]): DefaultCross[IN, R]

    Permalink
    Definition Classes
    DataSet
  16. def distinct(): DistinctOperator[IN]

    Permalink
    Definition Classes
    DataSet
  17. def distinct(arg0: <repeated...>[String]): DistinctOperator[IN]

    Permalink
    Definition Classes
    DataSet
  18. def distinct(arg0: <repeated...>[Int]): DistinctOperator[IN]

    Permalink
    Definition Classes
    DataSet
  19. def distinct[K](arg0: KeySelector[IN, K]): DistinctOperator[IN]

    Permalink
    Definition Classes
    DataSet
  20. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  21. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  22. def fillInType(arg0: TypeInformation[IN]): Unit

    Permalink
    Attributes
    protected[org.apache.flink.api.java]
    Definition Classes
    DataSet
  23. def filter(arg0: FilterFunction[IN]): FilterOperator[IN]

    Permalink
    Definition Classes
    DataSet
  24. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  25. def first(arg0: Int): GroupReduceOperator[IN, IN]

    Permalink
    Definition Classes
    DataSet
  26. def flatMap[R](arg0: FlatMapFunction[IN, R]): FlatMapOperator[IN, R]

    Permalink
    Definition Classes
    DataSet
  27. def fullOuterJoin[R](arg0: java.DataSet[R], arg1: JoinHint): JoinOperatorSetsBase[IN, R]

    Permalink
    Definition Classes
    DataSet
  28. def fullOuterJoin[R](arg0: java.DataSet[R]): JoinOperatorSetsBase[IN, R]

    Permalink
    Definition Classes
    DataSet
  29. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  30. def getExecutionEnvironment(): java.ExecutionEnvironment

    Permalink
    Definition Classes
    DataSet
  31. def getInput(): java.DataSet[IN]

    Permalink
    Definition Classes
    SingleInputOperator
  32. def getInputType(): TypeInformation[IN]

    Permalink
    Definition Classes
    SingleInputOperator
  33. def getMinResources(): ResourceSpec

    Permalink
    Definition Classes
    Operator
  34. def getName(): String

    Permalink
    Definition Classes
    Operator
  35. def getParallelism(): Int

    Permalink
    Definition Classes
    Operator
  36. def getPreferredResources(): ResourceSpec

    Permalink
    Definition Classes
    Operator
  37. def getResultType(): TypeInformation[IN]

    Permalink
    Definition Classes
    Operator
  38. def getType(): TypeInformation[IN]

    Permalink
    Definition Classes
    DataSet
  39. def groupBy(arg0: <repeated...>[String]): UnsortedGrouping[IN]

    Permalink
    Definition Classes
    DataSet
  40. def groupBy(arg0: <repeated...>[Int]): UnsortedGrouping[IN]

    Permalink
    Definition Classes
    DataSet
  41. def groupBy[K](arg0: KeySelector[IN, K]): UnsortedGrouping[IN]

    Permalink
    Definition Classes
    DataSet
  42. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  43. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  44. def iterate(arg0: Int): IterativeDataSet[IN]

    Permalink
    Definition Classes
    DataSet
  45. def iterateDelta[R](arg0: java.DataSet[R], arg1: Int, arg2: <repeated...>[Int]): DeltaIteration[IN, R]

    Permalink
    Definition Classes
    DataSet
  46. def join[R](arg0: java.DataSet[R], arg1: JoinHint): JoinOperatorSets[IN, R]

    Permalink
    Definition Classes
    DataSet
  47. def join[R](arg0: java.DataSet[R]): JoinOperatorSets[IN, R]

    Permalink
    Definition Classes
    DataSet
  48. def joinWithHuge[R](arg0: java.DataSet[R]): JoinOperatorSets[IN, R]

    Permalink
    Definition Classes
    DataSet
  49. def joinWithTiny[R](arg0: java.DataSet[R]): JoinOperatorSets[IN, R]

    Permalink
    Definition Classes
    DataSet
  50. def leftOuterJoin[R](arg0: java.DataSet[R], arg1: JoinHint): JoinOperatorSetsBase[IN, R]

    Permalink
    Definition Classes
    DataSet
  51. def leftOuterJoin[R](arg0: java.DataSet[R]): JoinOperatorSetsBase[IN, R]

    Permalink
    Definition Classes
    DataSet
  52. def map[R](arg0: MapFunction[IN, R]): MapOperator[IN, R]

    Permalink
    Definition Classes
    DataSet
  53. def mapPartition[R](arg0: MapPartitionFunction[IN, R]): MapPartitionOperator[IN, R]

    Permalink
    Definition Classes
    DataSet
  54. def max(arg0: Int): AggregateOperator[IN]

    Permalink
    Definition Classes
    DataSet
  55. def maxBy(arg0: <repeated...>[Int]): ReduceOperator[IN]

    Permalink
    Definition Classes
    DataSet
  56. def min(arg0: Int): AggregateOperator[IN]

    Permalink
    Definition Classes
    DataSet
  57. def minBy(arg0: <repeated...>[Int]): ReduceOperator[IN]

    Permalink
    Definition Classes
    DataSet
  58. def name(arg0: String): ScalaAggregateOperator[IN]

    Permalink
    Definition Classes
    Operator
  59. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  60. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  61. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  62. def output(arg0: OutputFormat[IN]): DataSink[IN]

    Permalink
    Definition Classes
    DataSet
  63. def partitionByHash[K <: Comparable[K]](arg0: KeySelector[IN, K]): PartitionOperator[IN]

    Permalink
    Definition Classes
    DataSet
  64. def partitionByHash(arg0: <repeated...>[String]): PartitionOperator[IN]

    Permalink
    Definition Classes
    DataSet
  65. def partitionByHash(arg0: <repeated...>[Int]): PartitionOperator[IN]

    Permalink
    Definition Classes
    DataSet
  66. def partitionByRange[K <: Comparable[K]](arg0: KeySelector[IN, K]): PartitionOperator[IN]

    Permalink
    Definition Classes
    DataSet
  67. def partitionByRange(arg0: <repeated...>[String]): PartitionOperator[IN]

    Permalink
    Definition Classes
    DataSet
  68. def partitionByRange(arg0: <repeated...>[Int]): PartitionOperator[IN]

    Permalink
    Definition Classes
    DataSet
  69. def partitionCustom[K <: Comparable[K]](arg0: Partitioner[K], arg1: KeySelector[IN, K]): PartitionOperator[IN]

    Permalink
    Definition Classes
    DataSet
  70. def partitionCustom[K](arg0: Partitioner[K], arg1: String): PartitionOperator[IN]

    Permalink
    Definition Classes
    DataSet
  71. def partitionCustom[K](arg0: Partitioner[K], arg1: Int): PartitionOperator[IN]

    Permalink
    Definition Classes
    DataSet
  72. def print(): Unit

    Permalink
    Definition Classes
    DataSet
    Annotations
    @throws( classOf[java.lang.Exception] )
  73. def printOnTaskManager(arg0: String): DataSink[IN]

    Permalink
    Definition Classes
    DataSet
  74. def printToErr(): Unit

    Permalink
    Definition Classes
    DataSet
    Annotations
    @throws( classOf[java.lang.Exception] )
  75. def project[OUT <: Tuple](arg0: <repeated...>[Int]): ProjectOperator[_, OUT]

    Permalink
    Definition Classes
    DataSet
  76. def rebalance(): PartitionOperator[IN]

    Permalink
    Definition Classes
    DataSet
  77. def reduce(arg0: ReduceFunction[IN]): ReduceOperator[IN]

    Permalink
    Definition Classes
    DataSet
  78. def reduceGroup[R](arg0: GroupReduceFunction[IN, R]): GroupReduceOperator[IN, R]

    Permalink
    Definition Classes
    DataSet
  79. def rightOuterJoin[R](arg0: java.DataSet[R], arg1: JoinHint): JoinOperatorSetsBase[IN, R]

    Permalink
    Definition Classes
    DataSet
  80. def rightOuterJoin[R](arg0: java.DataSet[R]): JoinOperatorSetsBase[IN, R]

    Permalink
    Definition Classes
    DataSet
  81. def runOperation[X](arg0: CustomUnaryOperation[IN, X]): java.DataSet[X]

    Permalink
    Definition Classes
    DataSet
  82. def setParallelism(arg0: Int): ScalaAggregateOperator[IN]

    Permalink
    Definition Classes
    Operator
  83. def sortPartition[K](arg0: KeySelector[IN, K], arg1: Order): SortPartitionOperator[IN]

    Permalink
    Definition Classes
    DataSet
  84. def sortPartition(arg0: String, arg1: Order): SortPartitionOperator[IN]

    Permalink
    Definition Classes
    DataSet
  85. def sortPartition(arg0: Int, arg1: Order): SortPartitionOperator[IN]

    Permalink
    Definition Classes
    DataSet
  86. def sum(arg0: Int): AggregateOperator[IN]

    Permalink
    Definition Classes
    DataSet
  87. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef
  88. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  89. def translateToDataFlow(input: Operator[IN]): GroupReduceOperatorBase[IN, IN, GroupReduceFunction[IN, IN]]

    Permalink
    Attributes
    protected[org.apache.flink.api.scala.operators]
    Definition Classes
    ScalaAggregateOperator → SingleInputOperator
  90. def union(arg0: java.DataSet[IN]): UnionOperator[IN]

    Permalink
    Definition Classes
    DataSet
  91. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  92. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  93. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  94. def write(arg0: FileOutputFormat[IN], arg1: String, arg2: WriteMode): DataSink[IN]

    Permalink
    Definition Classes
    DataSet
  95. def write(arg0: FileOutputFormat[IN], arg1: String): DataSink[IN]

    Permalink
    Definition Classes
    DataSet
  96. def writeAsCsv(arg0: String, arg1: String, arg2: String, arg3: WriteMode): DataSink[IN]

    Permalink
    Definition Classes
    DataSet
  97. def writeAsCsv(arg0: String, arg1: String, arg2: String): DataSink[IN]

    Permalink
    Definition Classes
    DataSet
  98. def writeAsCsv(arg0: String, arg1: WriteMode): DataSink[IN]

    Permalink
    Definition Classes
    DataSet
  99. def writeAsCsv(arg0: String): DataSink[IN]

    Permalink
    Definition Classes
    DataSet
  100. def writeAsFormattedText(arg0: String, arg1: WriteMode, arg2: TextFormatter[IN]): DataSink[String]

    Permalink
    Definition Classes
    DataSet
  101. def writeAsFormattedText(arg0: String, arg1: TextFormatter[IN]): DataSink[String]

    Permalink
    Definition Classes
    DataSet
  102. def writeAsText(arg0: String, arg1: WriteMode): DataSink[IN]

    Permalink
    Definition Classes
    DataSet
  103. def writeAsText(arg0: String): DataSink[IN]

    Permalink
    Definition Classes
    DataSet

Deprecated Value Members

  1. def print(arg0: String): DataSink[IN]

    Permalink
    Definition Classes
    DataSet
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  2. def printToErr(arg0: String): DataSink[IN]

    Permalink
    Definition Classes
    DataSet
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

Inherited from SingleInputOperator[IN, IN, ScalaAggregateOperator[IN]]

Inherited from Operator[IN, ScalaAggregateOperator[IN]]

Inherited from java.DataSet[IN]

Inherited from AnyRef

Inherited from Any

Ungrouped