org.apache.flink.api.scala.operators

ScalaAggregateOperator

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
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

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

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

Value Members

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

    Definition Classes
    AnyRef

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

    Definition Classes
    Any

  3. final def ##(): Int

    Definition Classes
    AnyRef → Any

  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any

  6. def aggregate(arg0: Aggregations, arg1: Int): AggregateOperator[IN]

    Definition Classes
    DataSet

  7. def and(function: Aggregations, field: Int): ScalaAggregateOperator[IN]

  8. final def asInstanceOf[T0]: T0

    Definition Classes
    Any

  9. def clean[F](arg0: F): F

    Definition Classes
    DataSet

  10. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  11. def coGroup[R](arg0: java.DataSet[R]): CoGroupOperatorSets[IN, R]

    Definition Classes
    DataSet

  12. def collect(): List[IN]

    Definition Classes
    DataSet
    Annotations
    @throws( classOf[java.lang.Exception] )

  13. def combineGroup[R](arg0: GroupCombineFunction[IN, R]): GroupCombineOperator[IN, R]

    Definition Classes
    DataSet

  14. def count(): Long

    Definition Classes
    DataSet
    Annotations
    @throws( classOf[java.lang.Exception] )

  15. def cross[R](arg0: java.DataSet[R]): DefaultCross[IN, R]

    Definition Classes
    DataSet

  16. def crossWithHuge[R](arg0: java.DataSet[R]): DefaultCross[IN, R]

    Definition Classes
    DataSet

  17. def crossWithTiny[R](arg0: java.DataSet[R]): DefaultCross[IN, R]

    Definition Classes
    DataSet

  18. def distinct(): DistinctOperator[IN]

    Definition Classes
    DataSet

  19. def distinct(arg0: <repeated...>[String]): DistinctOperator[IN]

    Definition Classes
    DataSet

  20. def distinct(arg0: <repeated...>[Int]): DistinctOperator[IN]

    Definition Classes
    DataSet

  21. def distinct[K](arg0: KeySelector[IN, K]): DistinctOperator[IN]

    Definition Classes
    DataSet

  22. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  23. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  24. def fillInType(arg0: TypeInformation[IN]): Unit

    Attributes
    protected[org.apache.flink.api.java]
    Definition Classes
    DataSet

  25. def filter(arg0: FilterFunction[IN]): FilterOperator[IN]

    Definition Classes
    DataSet

  26. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  27. def first(arg0: Int): GroupReduceOperator[IN, IN]

    Definition Classes
    DataSet

  28. def flatMap[R](arg0: FlatMapFunction[IN, R]): FlatMapOperator[IN, R]

    Definition Classes
    DataSet

  29. def fullOuterJoin[R](arg0: java.DataSet[R], arg1: JoinHint): JoinOperatorSetsBase[IN, R]

    Definition Classes
    DataSet

  30. def fullOuterJoin[R](arg0: java.DataSet[R]): JoinOperatorSetsBase[IN, R]

    Definition Classes
    DataSet

  31. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any

  32. def getExecutionEnvironment(): java.ExecutionEnvironment

    Definition Classes
    DataSet

  33. def getInput(): java.DataSet[IN]

    Definition Classes
    SingleInputOperator

  34. def getInputType(): TypeInformation[IN]

    Definition Classes
    SingleInputOperator

  35. def getMinResources(): ResourceSpec

    Definition Classes
    Operator

  36. def getName(): String

    Definition Classes
    Operator

  37. def getParallelism(): Int

    Definition Classes
    Operator

  38. def getPreferredResources(): ResourceSpec

    Definition Classes
    Operator

  39. def getResultType(): TypeInformation[IN]

    Definition Classes
    Operator

  40. def getType(): TypeInformation[IN]

    Definition Classes
    DataSet

  41. def groupBy(arg0: <repeated...>[String]): UnsortedGrouping[IN]

    Definition Classes
    DataSet

  42. def groupBy(arg0: <repeated...>[Int]): UnsortedGrouping[IN]

    Definition Classes
    DataSet

  43. def groupBy[K](arg0: KeySelector[IN, K]): UnsortedGrouping[IN]

    Definition Classes
    DataSet

  44. def hashCode(): Int

    Definition Classes
    AnyRef → Any

  45. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any

  46. def iterate(arg0: Int): IterativeDataSet[IN]

    Definition Classes
    DataSet

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

    Definition Classes
    DataSet

  48. def join[R](arg0: java.DataSet[R], arg1: JoinHint): JoinOperatorSets[IN, R]

    Definition Classes
    DataSet

  49. def join[R](arg0: java.DataSet[R]): JoinOperatorSets[IN, R]

    Definition Classes
    DataSet

  50. def joinWithHuge[R](arg0: java.DataSet[R]): JoinOperatorSets[IN, R]

    Definition Classes
    DataSet

  51. def joinWithTiny[R](arg0: java.DataSet[R]): JoinOperatorSets[IN, R]

    Definition Classes
    DataSet

  52. def leftOuterJoin[R](arg0: java.DataSet[R], arg1: JoinHint): JoinOperatorSetsBase[IN, R]

    Definition Classes
    DataSet

  53. def leftOuterJoin[R](arg0: java.DataSet[R]): JoinOperatorSetsBase[IN, R]

    Definition Classes
    DataSet

  54. def map[R](arg0: MapFunction[IN, R]): MapOperator[IN, R]

    Definition Classes
    DataSet

  55. def mapPartition[R](arg0: MapPartitionFunction[IN, R]): MapPartitionOperator[IN, R]

    Definition Classes
    DataSet

  56. def max(arg0: Int): AggregateOperator[IN]

    Definition Classes
    DataSet

  57. def maxBy(arg0: <repeated...>[Int]): ReduceOperator[IN]

    Definition Classes
    DataSet

  58. def min(arg0: Int): AggregateOperator[IN]

    Definition Classes
    DataSet

  59. def minBy(arg0: <repeated...>[Int]): ReduceOperator[IN]

    Definition Classes
    DataSet

  60. def name(arg0: String): ScalaAggregateOperator[IN]

    Definition Classes
    Operator

  61. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  62. final def notify(): Unit

    Definition Classes
    AnyRef

  63. final def notifyAll(): Unit

    Definition Classes
    AnyRef

  64. def output(arg0: OutputFormat[IN]): DataSink[IN]

    Definition Classes
    DataSet

  65. def partitionByHash[K <: Comparable[K]](arg0: KeySelector[IN, K]): PartitionOperator[IN]

    Definition Classes
    DataSet

  66. def partitionByHash(arg0: <repeated...>[String]): PartitionOperator[IN]

    Definition Classes
    DataSet

  67. def partitionByHash(arg0: <repeated...>[Int]): PartitionOperator[IN]

    Definition Classes
    DataSet

  68. def partitionByRange[K <: Comparable[K]](arg0: KeySelector[IN, K]): PartitionOperator[IN]

    Definition Classes
    DataSet

  69. def partitionByRange(arg0: <repeated...>[String]): PartitionOperator[IN]

    Definition Classes
    DataSet

  70. def partitionByRange(arg0: <repeated...>[Int]): PartitionOperator[IN]

    Definition Classes
    DataSet

  71. def partitionCustom[K <: Comparable[K]](arg0: Partitioner[K], arg1: KeySelector[IN, K]): PartitionOperator[IN]

    Definition Classes
    DataSet

  72. def partitionCustom[K](arg0: Partitioner[K], arg1: String): PartitionOperator[IN]

    Definition Classes
    DataSet

  73. def partitionCustom[K](arg0: Partitioner[K], arg1: Int): PartitionOperator[IN]

    Definition Classes
    DataSet

  74. def print(): Unit

    Definition Classes
    DataSet
    Annotations
    @throws( classOf[java.lang.Exception] )

  75. def printOnTaskManager(arg0: String): DataSink[IN]

    Definition Classes
    DataSet

  76. def printToErr(): Unit

    Definition Classes
    DataSet
    Annotations
    @throws( classOf[java.lang.Exception] )

  77. def project[OUT <: Tuple](arg0: <repeated...>[Int]): ProjectOperator[_, OUT]

    Definition Classes
    DataSet

  78. def rebalance(): PartitionOperator[IN]

    Definition Classes
    DataSet

  79. def reduce(arg0: ReduceFunction[IN]): ReduceOperator[IN]

    Definition Classes
    DataSet

  80. def reduceGroup[R](arg0: GroupReduceFunction[IN, R]): GroupReduceOperator[IN, R]

    Definition Classes
    DataSet

  81. def rightOuterJoin[R](arg0: java.DataSet[R], arg1: JoinHint): JoinOperatorSetsBase[IN, R]

    Definition Classes
    DataSet

  82. def rightOuterJoin[R](arg0: java.DataSet[R]): JoinOperatorSetsBase[IN, R]

    Definition Classes
    DataSet

  83. def runOperation[X](arg0: CustomUnaryOperation[IN, X]): java.DataSet[X]

    Definition Classes
    DataSet

  84. def setParallelism(arg0: Int): ScalaAggregateOperator[IN]

    Definition Classes
    Operator

  85. def sortPartition[K](arg0: KeySelector[IN, K], arg1: Order): SortPartitionOperator[IN]

    Definition Classes
    DataSet

  86. def sortPartition(arg0: String, arg1: Order): SortPartitionOperator[IN]

    Definition Classes
    DataSet

  87. def sortPartition(arg0: Int, arg1: Order): SortPartitionOperator[IN]

    Definition Classes
    DataSet

  88. def sum(arg0: Int): AggregateOperator[IN]

    Definition Classes
    DataSet

  89. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef

  90. def toString(): String

    Definition Classes
    AnyRef → Any

  91. def translateToDataFlow(input: Operator[IN]): GroupReduceOperatorBase[IN, IN, GroupReduceFunction[IN, IN]]

    Attributes
    protected[org.apache.flink.api.scala.operators]
    Definition Classes
    ScalaAggregateOperator → SingleInputOperator

  92. def union(arg0: java.DataSet[IN]): UnionOperator[IN]

    Definition Classes
    DataSet

  93. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  94. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  95. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  96. def write(arg0: FileOutputFormat[IN], arg1: String, arg2: WriteMode): DataSink[IN]

    Definition Classes
    DataSet

  97. def write(arg0: FileOutputFormat[IN], arg1: String): DataSink[IN]

    Definition Classes
    DataSet

  98. def writeAsCsv(arg0: String, arg1: String, arg2: String, arg3: WriteMode): DataSink[IN]

    Definition Classes
    DataSet

  99. def writeAsCsv(arg0: String, arg1: String, arg2: String): DataSink[IN]

    Definition Classes
    DataSet

  100. def writeAsCsv(arg0: String, arg1: WriteMode): DataSink[IN]

    Definition Classes
    DataSet

  101. def writeAsCsv(arg0: String): DataSink[IN]

    Definition Classes
    DataSet

  102. def writeAsFormattedText(arg0: String, arg1: WriteMode, arg2: TextFormatter[IN]): DataSink[String]

    Definition Classes
    DataSet

  103. def writeAsFormattedText(arg0: String, arg1: TextFormatter[IN]): DataSink[String]

    Definition Classes
    DataSet

  104. def writeAsText(arg0: String, arg1: WriteMode): DataSink[IN]

    Definition Classes
    DataSet

  105. def writeAsText(arg0: String): DataSink[IN]

    Definition Classes
    DataSet

Deprecated Value Members

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

    Definition Classes
    DataSet
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

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

    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