Instance Constructors
-
new
ScalaAggregateOperator(input: Grouping[IN], function: Aggregations, field: Int)
-
new
ScalaAggregateOperator(input: java.DataSet[IN], function: Aggregations, field: Int)
Value Members
-
final
def
!=(arg0: Any): Boolean
-
final
def
##(): Int
-
final
def
==(arg0: Any): Boolean
-
def
aggregate(arg0: Aggregations, arg1: Int): AggregateOperator[IN]
-
def
and(function: Aggregations, field: Int): ScalaAggregateOperator[IN]
-
final
def
asInstanceOf[T0]: T0
-
def
clean[F](arg0: F): F
-
def
clone(): AnyRef
-
def
coGroup[R](arg0: java.DataSet[R]): CoGroupOperatorSets[IN, R]
-
def
collect(): List[IN]
-
def
combineGroup[R](arg0: GroupCombineFunction[IN, R]): GroupCombineOperator[IN, R]
-
def
count(): Long
-
def
cross[R](arg0: java.DataSet[R]): DefaultCross[IN, R]
-
def
crossWithHuge[R](arg0: java.DataSet[R]): DefaultCross[IN, R]
-
def
crossWithTiny[R](arg0: java.DataSet[R]): DefaultCross[IN, R]
-
def
distinct(): DistinctOperator[IN]
-
def
distinct(arg0: <repeated...>[String]): DistinctOperator[IN]
-
def
distinct(arg0: <repeated...>[Int]): DistinctOperator[IN]
-
def
distinct[K](arg0: KeySelector[IN, K]): DistinctOperator[IN]
-
final
def
eq(arg0: AnyRef): Boolean
-
def
equals(arg0: Any): Boolean
-
def
fillInType(arg0: TypeInformation[IN]): Unit
-
def
filter(arg0: FilterFunction[IN]): FilterOperator[IN]
-
def
finalize(): Unit
-
def
first(arg0: Int): GroupReduceOperator[IN, IN]
-
def
flatMap[R](arg0: FlatMapFunction[IN, R]): FlatMapOperator[IN, R]
-
def
fullOuterJoin[R](arg0: java.DataSet[R], arg1: JoinHint): JoinOperatorSetsBase[IN, R]
-
def
fullOuterJoin[R](arg0: java.DataSet[R]): JoinOperatorSetsBase[IN, R]
-
final
def
getClass(): Class[_]
-
def
getExecutionEnvironment(): java.ExecutionEnvironment
-
def
getInput(): java.DataSet[IN]
-
def
getInputType(): TypeInformation[IN]
-
def
getMinResources(): ResourceSpec
-
def
getName(): String
-
def
getParallelism(): Int
-
def
getPreferredResources(): ResourceSpec
-
def
getResultType(): TypeInformation[IN]
-
def
getType(): TypeInformation[IN]
-
def
groupBy(arg0: <repeated...>[String]): UnsortedGrouping[IN]
-
def
groupBy(arg0: <repeated...>[Int]): UnsortedGrouping[IN]
-
def
groupBy[K](arg0: KeySelector[IN, K]): UnsortedGrouping[IN]
-
def
hashCode(): Int
-
final
def
isInstanceOf[T0]: Boolean
-
def
iterate(arg0: Int): IterativeDataSet[IN]
-
def
iterateDelta[R](arg0: java.DataSet[R], arg1: Int, arg2: <repeated...>[Int]): DeltaIteration[IN, R]
-
def
join[R](arg0: java.DataSet[R], arg1: JoinHint): JoinOperatorSets[IN, R]
-
def
join[R](arg0: java.DataSet[R]): JoinOperatorSets[IN, R]
-
def
joinWithHuge[R](arg0: java.DataSet[R]): JoinOperatorSets[IN, R]
-
def
joinWithTiny[R](arg0: java.DataSet[R]): JoinOperatorSets[IN, R]
-
def
leftOuterJoin[R](arg0: java.DataSet[R], arg1: JoinHint): JoinOperatorSetsBase[IN, R]
-
def
leftOuterJoin[R](arg0: java.DataSet[R]): JoinOperatorSetsBase[IN, R]
-
def
map[R](arg0: MapFunction[IN, R]): MapOperator[IN, R]
-
def
mapPartition[R](arg0: MapPartitionFunction[IN, R]): MapPartitionOperator[IN, R]
-
def
max(arg0: Int): AggregateOperator[IN]
-
def
maxBy(arg0: <repeated...>[Int]): ReduceOperator[IN]
-
def
min(arg0: Int): AggregateOperator[IN]
-
def
minBy(arg0: <repeated...>[Int]): ReduceOperator[IN]
-
-
final
def
ne(arg0: AnyRef): Boolean
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
def
output(arg0: OutputFormat[IN]): DataSink[IN]
-
def
partitionByHash[K <: Comparable[K]](arg0: KeySelector[IN, K]): PartitionOperator[IN]
-
def
partitionByHash(arg0: <repeated...>[String]): PartitionOperator[IN]
-
def
partitionByHash(arg0: <repeated...>[Int]): PartitionOperator[IN]
-
def
partitionByRange[K <: Comparable[K]](arg0: KeySelector[IN, K]): PartitionOperator[IN]
-
def
partitionByRange(arg0: <repeated...>[String]): PartitionOperator[IN]
-
def
partitionByRange(arg0: <repeated...>[Int]): PartitionOperator[IN]
-
def
partitionCustom[K <: Comparable[K]](arg0: Partitioner[K], arg1: KeySelector[IN, K]): PartitionOperator[IN]
-
def
partitionCustom[K](arg0: Partitioner[K], arg1: String): PartitionOperator[IN]
-
def
partitionCustom[K](arg0: Partitioner[K], arg1: Int): PartitionOperator[IN]
-
def
print(): Unit
-
def
printOnTaskManager(arg0: String): DataSink[IN]
-
def
printToErr(): Unit
-
def
project[OUT <: Tuple](arg0: <repeated...>[Int]): ProjectOperator[_, OUT]
-
def
rebalance(): PartitionOperator[IN]
-
def
reduce(arg0: ReduceFunction[IN]): ReduceOperator[IN]
-
def
reduceGroup[R](arg0: GroupReduceFunction[IN, R]): GroupReduceOperator[IN, R]
-
def
rightOuterJoin[R](arg0: java.DataSet[R], arg1: JoinHint): JoinOperatorSetsBase[IN, R]
-
def
rightOuterJoin[R](arg0: java.DataSet[R]): JoinOperatorSetsBase[IN, R]
-
def
runOperation[X](arg0: CustomUnaryOperation[IN, X]): java.DataSet[X]
-
-
def
sortPartition[K](arg0: KeySelector[IN, K], arg1: Order): SortPartitionOperator[IN]
-
def
sortPartition(arg0: String, arg1: Order): SortPartitionOperator[IN]
-
def
sortPartition(arg0: Int, arg1: Order): SortPartitionOperator[IN]
-
def
sum(arg0: Int): AggregateOperator[IN]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
def
toString(): String
-
def
translateToDataFlow(input: Operator[IN]): GroupReduceOperatorBase[IN, IN, GroupReduceFunction[IN, IN]]
-
def
union(arg0: java.DataSet[IN]): UnionOperator[IN]
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit
-
def
write(arg0: FileOutputFormat[IN], arg1: String, arg2: WriteMode): DataSink[IN]
-
def
write(arg0: FileOutputFormat[IN], arg1: String): DataSink[IN]
-
def
writeAsCsv(arg0: String, arg1: String, arg2: String, arg3: WriteMode): DataSink[IN]
-
def
writeAsCsv(arg0: String, arg1: String, arg2: String): DataSink[IN]
-
def
writeAsCsv(arg0: String, arg1: WriteMode): DataSink[IN]
-
def
writeAsCsv(arg0: String): DataSink[IN]
-
def
writeAsFormattedText(arg0: String, arg1: WriteMode, arg2: TextFormatter[IN]): DataSink[String]
-
def
writeAsFormattedText(arg0: String, arg1: TextFormatter[IN]): DataSink[String]
-
def
writeAsText(arg0: String, arg1: WriteMode): DataSink[IN]
-
def
writeAsText(arg0: String): DataSink[IN]
Deprecated Value Members
-
def
print(arg0: String): DataSink[IN]
-
def
printToErr(arg0: String): DataSink[IN]
Inherited from java.DataSet[IN]
Inherited from AnyRef
Inherited from Any