Package | Description |
---|---|
org.apache.flink.api.scala |
Modifier and Type | Method and Description |
---|---|
<K> GroupedDataSet<T> |
DataSet.groupBy(scala.Function1<T,K> fun,
TypeInformation<K> evidence$29)
Creates a
GroupedDataSet which provides operations on groups of elements. |
GroupedDataSet<T> |
DataSet.groupBy(scala.collection.Seq<Object> fields)
Creates a
GroupedDataSet which provides operations on groups of elements. |
GroupedDataSet<T> |
DataSet.groupBy(String firstField,
scala.collection.Seq<String> otherFields)
Creates a
GroupedDataSet which provides operations on groups of elements. |
<K> GroupedDataSet<T> |
GroupedDataSet.sortGroup(scala.Function1<T,K> fun,
Order order,
TypeInformation<K> evidence$2)
Adds a secondary sort key to this
GroupedDataSet . |
GroupedDataSet<T> |
GroupedDataSet.sortGroup(int field,
Order order)
Adds a secondary sort key to this
GroupedDataSet . |
GroupedDataSet<T> |
GroupedDataSet.sortGroup(String field,
Order order)
Adds a secondary sort key to this
GroupedDataSet . |
<K> GroupedDataSet<T> |
GroupedDataSet.withPartitioner(Partitioner<K> partitioner,
TypeInformation<K> evidence$3)
Sets a custom partitioner for the grouping.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.