Uses of Class
org.apache.flink.api.common.operators.util.FieldList

Packages that use FieldList

Package	Description
org.apache.flink.api.common.operators
org.apache.flink.api.common.operators.util
org.apache.flink.optimizer.dag
org.apache.flink.optimizer.dataproperties
org.apache.flink.optimizer.operators
org.apache.flink.optimizer.plan
org.apache.flink.optimizer.util

Uses of FieldList in org.apache.flink.api.common.operators

Fields in org.apache.flink.api.common.operators declared as FieldList

Modifier and Type	Field and Description
protected FieldList	Ordering.indexes

Methods in org.apache.flink.api.common.operators that return FieldList

Modifier and Type	Method and Description
FieldList	Ordering.getInvolvedIndexes()

Uses of FieldList in org.apache.flink.api.common.operators.util

Fields in org.apache.flink.api.common.operators.util declared as FieldList

Modifier and Type	Field and Description
static FieldList	FieldList.EMPTY_LIST

Methods in org.apache.flink.api.common.operators.util that return FieldList

Modifier and Type	Method and Description
FieldList	FieldList.addField(Integer fieldID)
FieldList	FieldList.addFields(FieldSet set)
FieldList	FieldList.addFields(int... fieldIDs)
FieldList	FieldList.toFieldList()
FieldList	FieldSet.toFieldList() Turns the FieldSet into an ordered FieldList.

Methods in org.apache.flink.api.common.operators.util with parameters of type FieldList

Modifier and Type	Method and Description
boolean	FieldList.isExactMatch(FieldList list)
boolean	FieldList.isValidSubset(FieldList list)

Uses of FieldList in org.apache.flink.optimizer.dag

Fields in org.apache.flink.optimizer.dag declared as FieldList

Modifier and Type	Field and Description
protected FieldList	TwoInputNode.keys1
protected FieldList	TwoInputNode.keys2

Methods in org.apache.flink.optimizer.dag that return FieldList

Modifier and Type	Method and Description
FieldList	WorksetIterationNode.getSolutionSetKeyFields()

Uses of FieldList in org.apache.flink.optimizer.dataproperties

Methods in org.apache.flink.optimizer.dataproperties that return FieldList

Modifier and Type	Method and Description
FieldList	LocalProperties.getGroupedFields() Gets the grouped fields.
FieldList	GlobalProperties.getPartitioningFields()

Methods in org.apache.flink.optimizer.dataproperties with parameters of type FieldList

Modifier and Type	Method and Description
static LocalProperties	LocalProperties.forGrouping(FieldList groupedFields)
boolean	GlobalProperties.isExactlyPartitionedOnFields(FieldList fields)
void	GlobalProperties.setAnyPartitioning(FieldList partitionedFields)
void	GlobalProperties.setCustomPartitioned(FieldList partitionedFields, Partitioner<?> partitioner)
void	GlobalProperties.setHashPartitioned(FieldList partitionedFields) Sets this global properties to represent a hash partitioning.

Uses of FieldList in org.apache.flink.optimizer.operators

Fields in org.apache.flink.optimizer.operators declared as FieldList

Modifier and Type	Field and Description
protected FieldList	OperatorDescriptorSingle.keyList
protected FieldList	OperatorDescriptorDual.keys1
protected FieldList	OperatorDescriptorDual.keys2

Methods in org.apache.flink.optimizer.operators with parameters of type FieldList

Modifier and Type	Method and Description
protected boolean	OperatorDescriptorDual.checkEquivalentFieldPositionsInKeyFields(FieldList fields1, FieldList fields2)
protected boolean	OperatorDescriptorDual.checkEquivalentFieldPositionsInKeyFields(FieldList fields1, FieldList fields2, int numRelevantFields)

Constructors in org.apache.flink.optimizer.operators with parameters of type FieldList

Constructor and Description
AbstractJoinDescriptor(FieldList keys1, FieldList keys2)
AbstractJoinDescriptor(FieldList keys1, FieldList keys2, boolean broadcastFirstAllowed, boolean broadcastSecondAllowed, boolean repartitionAllowed)
AbstractSortMergeJoinDescriptor(FieldList keys1, FieldList keys2)
AbstractSortMergeJoinDescriptor(FieldList keys1, FieldList keys2, boolean broadcastFirstAllowed, boolean broadcastSecondAllowed, boolean repartitionAllowed)
CoGroupDescriptor(FieldList keys1, FieldList keys2)
CoGroupDescriptor(FieldList keys1, FieldList keys2, Ordering additionalOrdering1, Ordering additionalOrdering2)
CoGroupRawDescriptor(FieldList keys1, FieldList keys2)
CoGroupRawDescriptor(FieldList keys1, FieldList keys2, Ordering additionalOrdering1, Ordering additionalOrdering2)
CoGroupWithSolutionSetFirstDescriptor(FieldList keys1, FieldList keys2)
CoGroupWithSolutionSetSecondDescriptor(FieldList keys1, FieldList keys2)
HashFullOuterJoinBuildFirstDescriptor(FieldList keys1, FieldList keys2)
HashFullOuterJoinBuildSecondDescriptor(FieldList keys1, FieldList keys2)
HashJoinBuildFirstProperties(FieldList keys1, FieldList keys2)
HashJoinBuildFirstProperties(FieldList keys1, FieldList keys2, boolean broadcastFirstAllowed, boolean broadcastSecondAllowed, boolean repartitionAllowed)
HashJoinBuildSecondProperties(FieldList keys1, FieldList keys2)
HashJoinBuildSecondProperties(FieldList keys1, FieldList keys2, boolean broadcastFirstAllowed, boolean broadcastSecondAllowed, boolean repartitionAllowed)
HashLeftOuterJoinBuildFirstDescriptor(FieldList keys1, FieldList keys2, boolean broadcastSecondAllowed, boolean repartitionAllowed)
HashLeftOuterJoinBuildSecondDescriptor(FieldList keys1, FieldList keys2, boolean broadcastSecondAllowed, boolean repartitionAllowed)
HashRightOuterJoinBuildFirstDescriptor(FieldList keys1, FieldList keys2, boolean broadcastFirstAllowed, boolean repartitionAllowed)
HashRightOuterJoinBuildSecondDescriptor(FieldList keys1, FieldList keys2, boolean broadcastFirstAllowed, boolean repartitionAllowed)
OperatorDescriptorDual(FieldList keys1, FieldList keys2)
SolutionSetDeltaOperator(FieldList partitioningFields)
SortMergeFullOuterJoinDescriptor(FieldList keys1, FieldList keys2)
SortMergeInnerJoinDescriptor(FieldList keys1, FieldList keys2)
SortMergeInnerJoinDescriptor(FieldList keys1, FieldList keys2, boolean broadcastFirstAllowed, boolean broadcastSecondAllowed, boolean repartitionAllowed)
SortMergeLeftOuterJoinDescriptor(FieldList keys1, FieldList keys2)
SortMergeLeftOuterJoinDescriptor(FieldList keys1, FieldList keys2, boolean broadcastAllowed)
SortMergeRightOuterJoinDescriptor(FieldList keys1, FieldList keys2)
SortMergeRightOuterJoinDescriptor(FieldList keys1, FieldList keys2, boolean broadcastAllowed)

Uses of FieldList in org.apache.flink.optimizer.plan

Fields in org.apache.flink.optimizer.plan declared as FieldList

Modifier and Type	Field and Description
protected FieldList[]	SingleInputPlanNode.driverKeys
protected FieldList	DualInputPlanNode.keys1
protected FieldList	DualInputPlanNode.keys2

Methods in org.apache.flink.optimizer.plan that return FieldList

Modifier and Type	Method and Description
FieldList	SingleInputPlanNode.getKeys(int id) Gets the key field indexes for the specified driver comparator.
FieldList	DualInputPlanNode.getKeysForInput1()
FieldList	DualInputPlanNode.getKeysForInput2()
FieldList	Channel.getLocalStrategyKeys()
FieldList	Channel.getShipStrategyKeys()
FieldList	WorksetIterationPlanNode.getSolutionSetKeyFields()

Methods in org.apache.flink.optimizer.plan with parameters of type FieldList

Modifier and Type	Method and Description
void	SingleInputPlanNode.setDriverKeyInfo(FieldList keys, boolean[] sortOrder, int id) Sets the key field information for the specified driver comparator.
void	SingleInputPlanNode.setDriverKeyInfo(FieldList keys, int id) Sets the key field indexes for the specified driver comparator.
void	Channel.setLocalStrategy(LocalStrategy strategy, FieldList keys, boolean[] sortDirection)
void	Channel.setShipStrategy(ShipStrategyType strategy, FieldList keys, boolean[] sortDirection, DataExchangeMode dataExchangeMode)
void	Channel.setShipStrategy(ShipStrategyType strategy, FieldList keys, boolean[] sortDirection, Partitioner<?> partitioner, DataExchangeMode dataExchangeMode)
void	Channel.setShipStrategy(ShipStrategyType strategy, FieldList keys, DataExchangeMode dataExchangeMode)
void	Channel.setShipStrategy(ShipStrategyType strategy, FieldList keys, Partitioner<?> partitioner, DataExchangeMode dataExchangeMode)

Constructors in org.apache.flink.optimizer.plan with parameters of type FieldList

Constructor and Description
DualInputPlanNode(OptimizerNode template, String nodeName, Channel input1, Channel input2, DriverStrategy diverStrategy, FieldList driverKeyFields1, FieldList driverKeyFields2)
DualInputPlanNode(OptimizerNode template, String nodeName, Channel input1, Channel input2, DriverStrategy diverStrategy, FieldList driverKeyFields1, FieldList driverKeyFields2, boolean[] driverSortOrders)
SingleInputPlanNode(OptimizerNode template, String nodeName, Channel input, DriverStrategy driverStrategy, FieldList driverKeyFields)
SingleInputPlanNode(OptimizerNode template, String nodeName, Channel input, DriverStrategy driverStrategy, FieldList driverKeyFields, boolean[] driverSortOrders)

Uses of FieldList in org.apache.flink.optimizer.util

Methods in org.apache.flink.optimizer.util that return FieldList

Modifier and Type	Method and Description
static FieldList	Utils.createOrderedFromSet(FieldSet set)

Methods in org.apache.flink.optimizer.util with parameters of type FieldList

Modifier and Type	Method and Description
static Ordering	Utils.createOrdering(FieldList fields)
static Ordering	Utils.createOrdering(FieldList fields, boolean[] directions)