Package | Description |
---|---|
org.apache.flink.api.scala | |
org.apache.flink.api.scala.extensions.impl.acceptPartialFunctions |
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.
|
Modifier and Type | Method and Description |
---|---|
<K> GroupedDataSet<T> |
OnDataSet.groupingBy(scala.Function1<T,K> fun,
TypeInformation<K> evidence$9)
Groups the items according to a grouping function
fun |
<K> GroupedDataSet<T> |
OnGroupedDataSet.sortGroupWith(Order order,
scala.Function1<T,K> fun,
TypeInformation<K> evidence$1)
Sorts a group using a sorting function
fun and an Order |
Constructor and Description |
---|
OnGroupedDataSet(GroupedDataSet<T> ds) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.