Uses of Class
org.apache.flink.api.common.operators.Ordering
-
Packages that use Ordering Package Description org.apache.flink.api.common.operators org.apache.flink.api.common.operators.base -
-
Uses of Ordering in org.apache.flink.api.common.operators
Methods in org.apache.flink.api.common.operators that return Ordering Modifier and Type Method Description OrderingOrdering. appendOrdering(Integer index, Class<? extends Comparable<?>> type, Order order)Extends this ordering by appending an additional order requirement.OrderingOrdering. clone()OrderingOrdering. createNewOrderingUpToIndex(int exclusiveIndex)Creates a new ordering the represents an ordering on a prefix of the fields.OrderingGenericDataSinkBase. getLocalOrder()Gets the order, in which the data sink writes its data locally.OrderingGenericDataSourceBase.SplitDataProperties. getSplitOrder()Methods in org.apache.flink.api.common.operators with parameters of type Ordering Modifier and Type Method Description booleanOrdering. isMetBy(Ordering otherOrdering)booleanOrdering. isOrderEqualOnFirstNFields(Ordering other, int n)voidGenericDataSinkBase. setLocalOrder(Ordering localOrder)Sets the order in which the sink must write its data within each fragment in the distributed file system. -
Uses of Ordering in org.apache.flink.api.common.operators.base
Methods in org.apache.flink.api.common.operators.base that return Ordering Modifier and Type Method Description OrderingCoGroupOperatorBase. getGroupOrder(int inputNum)Gets the value order for an input, i.e.OrderingCoGroupRawOperatorBase. getGroupOrder(int inputNum)Gets the value order for an input, i.e.OrderingGroupCombineOperatorBase. getGroupOrder()Gets the order of elements within a reduce group.OrderingGroupReduceOperatorBase. getGroupOrder()Gets the order of elements within a reduce group.OrderingCoGroupOperatorBase. getGroupOrderForInputOne()Gets the order of elements within a group for the first input.OrderingCoGroupRawOperatorBase. getGroupOrderForInputOne()Gets the order of elements within a group for the first input.OrderingCoGroupOperatorBase. getGroupOrderForInputTwo()Gets the order of elements within a group for the second input.OrderingCoGroupRawOperatorBase. getGroupOrderForInputTwo()Gets the order of elements within a group for the second input.OrderingPartitionOperatorBase. getOrdering()OrderingSortPartitionOperatorBase. getPartitionOrdering()Methods in org.apache.flink.api.common.operators.base with parameters of type Ordering Modifier and Type Method Description voidCoGroupOperatorBase. setGroupOrder(int inputNum, Ordering order)Sets the order of the elements within a group for the given input.voidCoGroupRawOperatorBase. setGroupOrder(int inputNum, Ordering order)Sets the order of the elements within a group for the given input.voidGroupCombineOperatorBase. setGroupOrder(Ordering order)Sets the order of the elements within a reduce group.voidGroupReduceOperatorBase. setGroupOrder(Ordering order)Sets the order of the elements within a reduce group.voidCoGroupOperatorBase. setGroupOrderForInputOne(Ordering order)Sets the order of the elements within a group for the first input.voidCoGroupRawOperatorBase. setGroupOrderForInputOne(Ordering order)Sets the order of the elements within a group for the first input.voidCoGroupOperatorBase. setGroupOrderForInputTwo(Ordering order)Sets the order of the elements within a group for the second input.voidCoGroupRawOperatorBase. setGroupOrderForInputTwo(Ordering order)Sets the order of the elements within a group for the second input.voidPartitionOperatorBase. setOrdering(Ordering ordering)Constructors in org.apache.flink.api.common.operators.base with parameters of type Ordering Constructor Description SortPartitionOperatorBase(UnaryOperatorInformation<IN,IN> operatorInfo, Ordering partitionOrdering, String name)
-