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.
|
Ordering |
Ordering.clone() |
Ordering |
Ordering.createNewOrderingUpToIndex(int exclusiveIndex)
Creates a new ordering the represents an ordering on a prefix of the fields.
|
Ordering |
GenericDataSinkBase.getLocalOrder()
Gets the order, in which the data sink writes its data locally.
|
Ordering |
GenericDataSourceBase.SplitDataProperties.getSplitOrder() |
Modifier and Type | Method and Description |
---|---|
boolean |
Ordering.isMetBy(Ordering otherOrdering) |
boolean |
Ordering.isOrderEqualOnFirstNFields(Ordering other,
int n) |
void |
GenericDataSinkBase.setLocalOrder(Ordering localOrder)
Sets the order in which the sink must write its data within each fragment in the distributed
file system.
|
Modifier and Type | Method and Description |
---|---|
Ordering |
GroupReduceOperatorBase.getGroupOrder()
Gets the order of elements within a reduce group.
|
Ordering |
GroupCombineOperatorBase.getGroupOrder()
Gets the order of elements within a reduce group.
|
Ordering |
CoGroupRawOperatorBase.getGroupOrder(int inputNum)
Gets the value order for an input, i.e.
|
Ordering |
CoGroupOperatorBase.getGroupOrder(int inputNum)
Gets the value order for an input, i.e.
|
Ordering |
CoGroupRawOperatorBase.getGroupOrderForInputOne()
Gets the order of elements within a group for the first input.
|
Ordering |
CoGroupOperatorBase.getGroupOrderForInputOne()
Gets the order of elements within a group for the first input.
|
Ordering |
CoGroupRawOperatorBase.getGroupOrderForInputTwo()
Gets the order of elements within a group for the second input.
|
Ordering |
CoGroupOperatorBase.getGroupOrderForInputTwo()
Gets the order of elements within a group for the second input.
|
Ordering |
PartitionOperatorBase.getOrdering() |
Ordering |
SortPartitionOperatorBase.getPartitionOrdering() |
Modifier and Type | Method and Description |
---|---|
void |
CoGroupRawOperatorBase.setGroupOrder(int inputNum,
Ordering order)
Sets the order of the elements within a group for the given input.
|
void |
CoGroupOperatorBase.setGroupOrder(int inputNum,
Ordering order)
Sets the order of the elements within a group for the given input.
|
void |
GroupReduceOperatorBase.setGroupOrder(Ordering order)
Sets the order of the elements within a reduce group.
|
void |
GroupCombineOperatorBase.setGroupOrder(Ordering order)
Sets the order of the elements within a reduce group.
|
void |
CoGroupRawOperatorBase.setGroupOrderForInputOne(Ordering order)
Sets the order of the elements within a group for the first input.
|
void |
CoGroupOperatorBase.setGroupOrderForInputOne(Ordering order)
Sets the order of the elements within a group for the first input.
|
void |
CoGroupRawOperatorBase.setGroupOrderForInputTwo(Ordering order)
Sets the order of the elements within a group for the second input.
|
void |
CoGroupOperatorBase.setGroupOrderForInputTwo(Ordering order)
Sets the order of the elements within a group for the second input.
|
void |
PartitionOperatorBase.setOrdering(Ordering ordering) |
Constructor and Description |
---|
SortPartitionOperatorBase(UnaryOperatorInformation<IN,IN> operatorInfo,
Ordering partitionOrdering,
String name) |
Modifier and Type | Method and Description |
---|---|
Ordering |
SplitDataProperties.getSplitOrder() |
Modifier and Type | Method and Description |
---|---|
protected Ordering |
SortedGrouping.getGroupOrdering() |
Constructor and Description |
---|
PartitionDescriptor(PartitionOperatorBase.PartitionMethod pMethod,
FieldSet pKeys,
Ordering ordering,
Partitioner<?> customPartitioner,
DataDistribution distribution) |
SortPartitionDescriptor(Ordering partitionOrder) |
Modifier and Type | Method and Description |
---|---|
Ordering |
RequestedGlobalProperties.getOrdering()
Gets the key order.
|
Ordering |
LocalProperties.getOrdering()
Gets the key order.
|
Ordering |
RequestedLocalProperties.getOrdering()
Gets the key order.
|
Ordering |
GlobalProperties.getPartitioningOrdering() |
Modifier and Type | Method and Description |
---|---|
static LocalProperties |
LocalProperties.forOrdering(Ordering o) |
boolean |
GlobalProperties.matchesOrderedPartitioning(Ordering o) |
void |
RequestedLocalProperties.setOrdering(Ordering ordering)
Sets the order for these interesting local properties.
|
void |
RequestedGlobalProperties.setRangePartitioned(Ordering ordering) |
void |
GlobalProperties.setRangePartitioned(Ordering ordering)
Set the parameters for range partition.
|
void |
RequestedGlobalProperties.setRangePartitioned(Ordering ordering,
DataDistribution dataDistribution) |
void |
GlobalProperties.setRangePartitioned(Ordering ordering,
DataDistribution distribution)
Set the parameters for range partition.
|
Constructor and Description |
---|
RequestedLocalProperties(Ordering ordering)
Creates interesting properties for the given ordering.
|
Constructor and Description |
---|
CoGroupDescriptor(FieldList keys1,
FieldList keys2,
Ordering additionalOrdering1,
Ordering additionalOrdering2) |
CoGroupRawDescriptor(FieldList keys1,
FieldList keys2,
Ordering additionalOrdering1,
Ordering additionalOrdering2) |
GroupCombineProperties(FieldSet groupKeys,
Ordering additionalOrderKeys) |
GroupReduceProperties(FieldSet keys,
Ordering additionalOrderKeys) |
GroupReduceProperties(FieldSet groupKeys,
Ordering additionalOrderKeys,
Partitioner<?> customPartitioner) |
GroupReduceWithCombineProperties(FieldSet groupKeys,
Ordering additionalOrderKeys) |
GroupReduceWithCombineProperties(FieldSet groupKeys,
Ordering additionalOrderKeys,
Partitioner<?> customPartitioner) |
Modifier and Type | Method and Description |
---|---|
static Ordering |
Utils.createOrdering(FieldList fields) |
static Ordering |
Utils.createOrdering(FieldList fields,
boolean[] directions) |
Modifier and Type | Method and Description |
---|---|
static boolean[] |
Utils.getDirections(Ordering o,
int numFields) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.