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 getName(): String

    Definition Classes
    Operator
  36. def getParallelism(): Int

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

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

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

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

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

    Definition Classes
    DataSet
  42. def hashCode(): Int

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

    Definition Classes
    DataSet
  72. def print(): Unit

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

    Definition Classes
    DataSet
  74. def printToErr(): Unit

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

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

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

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

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

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

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

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

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

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

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

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

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

    Definition Classes
    AnyRef
  88. def toString(): String

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

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

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

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

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

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

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

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

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

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

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

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

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

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

    Definition Classes
    DataSet
  103. 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