Package | Description |
---|---|
org.apache.flink.api.common.operators | |
org.apache.flink.api.java | |
org.apache.flink.api.java.io | |
org.apache.flink.api.java.operators |
Modifier and Type | Field and Description |
---|---|
protected ArrayList<Order> |
Ordering.orders |
Modifier and Type | Method and Description |
---|---|
Order[] |
Ordering.getFieldOrders() |
Order |
Ordering.getOrder(int index) |
static Order |
Order.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static Order[] |
Order.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
Ordering |
Ordering.appendOrdering(Integer index,
Class<? extends Comparable<?>> type,
Order order)
Extends this ordering by appending an additional order requirement.
|
Constructor and Description |
---|
Ordering(int index,
Class<? extends Comparable<?>> type,
Order order) |
Modifier and Type | Method and Description |
---|---|
SortPartitionOperator<T> |
DataSet.sortPartition(int field,
Order order)
Locally sorts the partitions of the DataSet on the specified field in the specified order.
|
<K> SortPartitionOperator<T> |
DataSet.sortPartition(KeySelector<T,K> keyExtractor,
Order order)
Locally sorts the partitions of the DataSet on the extracted key in the specified order.
|
SortPartitionOperator<T> |
DataSet.sortPartition(String field,
Order order)
Locally sorts the partitions of the DataSet on the specified field in the specified order.
|
Modifier and Type | Method and Description |
---|---|
SplitDataProperties<T> |
SplitDataProperties.splitsOrderedBy(int[] orderFields,
Order[] orders)
Defines that the data within an input split is sorted on the fields defined by the field
positions in the specified orders.
|
SplitDataProperties<T> |
SplitDataProperties.splitsOrderedBy(String orderFields,
Order[] orders)
Defines that the data within an input split is sorted on the fields defined by the field
expressions in the specified orders.
|
Modifier and Type | Method and Description |
---|---|
protected Order[] |
SortedGrouping.getGroupSortOrders() |
Modifier and Type | Method and Description |
---|---|
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction.sortFirstGroup(int field,
Order order)
|
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction.sortFirstGroup(String fieldExpression,
Order order)
|
SortedGrouping<T> |
SortedGrouping.sortGroup(int field,
Order order)
|
SortedGrouping<T> |
UnsortedGrouping.sortGroup(int field,
Order order)
|
<K> SortedGrouping<T> |
UnsortedGrouping.sortGroup(KeySelector<T,K> keySelector,
Order order)
Sorts elements within a group on a key extracted by the specified
KeySelector in the specified Order . |
SortedGrouping<T> |
SortedGrouping.sortGroup(String field,
Order order)
|
SortedGrouping<T> |
UnsortedGrouping.sortGroup(String field,
Order order)
Sorts Pojos within a group on the specified field in the specified
Order . |
DataSink<T> |
DataSink.sortLocalOutput(int field,
Order order)
Deprecated.
Use
DataSet.sortPartition(int, Order) instead |
DataSink<T> |
DataSink.sortLocalOutput(String fieldExpression,
Order order)
Deprecated.
Use
DataSet.sortPartition(String, Order) instead |
SortPartitionOperator<T> |
SortPartitionOperator.sortPartition(int field,
Order order)
Appends an additional sort order with the specified field in the specified order to the local
partition sorting of the DataSet.
|
<K> SortPartitionOperator<T> |
SortPartitionOperator.sortPartition(KeySelector<T,K> keyExtractor,
Order order) |
SortPartitionOperator<T> |
SortPartitionOperator.sortPartition(String field,
Order order)
Appends an additional sort order with the specified field in the specified order to the local
partition sorting of the DataSet.
|
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction.sortSecondGroup(int field,
Order order)
|
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction |
CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate.CoGroupOperatorWithoutFunction.sortSecondGroup(String fieldExpression,
Order order)
|
PartitionOperator<T> |
PartitionOperator.withOrders(Order... orders)
Sets the order of keys for range partitioning.
|
Constructor and Description |
---|
SortedGrouping(DataSet<T> set,
Keys<T> keys,
int field,
Order order) |
SortedGrouping(DataSet<T> set,
Keys<T> keys,
Keys.SelectorFunctionKeys<T,K> keySelector,
Order order) |
SortedGrouping(DataSet<T> set,
Keys<T> keys,
String field,
Order order) |
SortPartitionOperator(DataSet<T> dataSet,
int sortField,
Order sortOrder,
String sortLocationName) |
SortPartitionOperator(DataSet<T> dataSet,
Keys.SelectorFunctionKeys<T,K> sortKey,
Order sortOrder,
String sortLocationName) |
SortPartitionOperator(DataSet<T> dataSet,
String sortField,
Order sortOrder,
String sortLocationName) |
Constructor and Description |
---|
CoGroupOperator(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
CoGroupFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
List<org.apache.commons.lang3.tuple.Pair<Integer,Order>> groupSortKeyOrderFirst,
List<org.apache.commons.lang3.tuple.Pair<Integer,Order>> groupSortKeyOrderSecond,
Partitioner<?> customPartitioner,
String defaultName) |
CoGroupOperator(DataSet<I1> input1,
DataSet<I2> input2,
Keys<I1> keys1,
Keys<I2> keys2,
CoGroupFunction<I1,I2,OUT> function,
TypeInformation<OUT> returnType,
List<org.apache.commons.lang3.tuple.Pair<Integer,Order>> groupSortKeyOrderFirst,
List<org.apache.commons.lang3.tuple.Pair<Integer,Order>> groupSortKeyOrderSecond,
Partitioner<?> customPartitioner,
String defaultName) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.