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

Packages that use FieldSet

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 FieldSet in org.apache.flink.api.common.operators

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

Modifier and Type	Method and Description
FieldSet	SingleInputSemanticProperties.getForwardingTargetFields(int input, int sourceField)
FieldSet	SingleInputSemanticProperties.AllFieldsForwardedProperties.getForwardingTargetFields(int input, int sourceField)
FieldSet	DualInputSemanticProperties.getForwardingTargetFields(int input, int sourceField)
FieldSet	SemanticProperties.getForwardingTargetFields(int input, int sourceField) Returns the indexes of all target fields to which a source field has been unmodified copied by a function.
FieldSet	SemanticProperties.EmptySemanticProperties.getForwardingTargetFields(int input, int sourceField)
FieldSet	SingleInputSemanticProperties.getReadFields(int input)
FieldSet	DualInputSemanticProperties.getReadFields(int input)
FieldSet	SemanticProperties.getReadFields(int input) Returns the position indexes of all fields of an input that are accessed by a function.
FieldSet	SemanticProperties.EmptySemanticProperties.getReadFields(int input)

Methods in org.apache.flink.api.common.operators that return types with arguments of type FieldSet

Modifier and Type	Method and Description
Set<FieldSet>	CompilerHints.getUniqueFields() Gets the FieldSets that are unique

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

Modifier and Type	Method and Description
void	SingleInputSemanticProperties.addReadFields(FieldSet readFields) Adds, to the existing information, field(s) that are read in the source record(s).
void	DualInputSemanticProperties.addReadFields(int input, FieldSet readFields) Adds, to the existing information, field(s) that are read in the source record(s) from the first input.
void	CompilerHints.addUniqueField(FieldSet uniqueFieldSet) Adds a FieldSet to be unique
boolean	Ordering.groupsFields(FieldSet fields)

Method parameters in org.apache.flink.api.common.operators with type arguments of type FieldSet

Modifier and Type	Method and Description
void	CompilerHints.addUniqueFields(Set<FieldSet> uniqueFieldSets) Adds multiple FieldSets to be unique

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

Subclasses of FieldSet in org.apache.flink.api.common.operators.util

Modifier and Type	Class and Description
class	FieldList Immutable ordered list of fields IDs.

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

Modifier and Type	Field and Description
static FieldSet	FieldSet.EMPTY_SET

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

Modifier and Type	Method and Description
FieldSet	FieldSet.addField(Integer fieldID)
FieldSet	FieldSet.addFields(FieldSet set)
FieldSet	FieldSet.addFields(int... fieldIDs)
FieldSet	FieldSet.clone() Since instances of FieldSet are strictly immutable, this method does not actually clone, but it only returns the original instance.

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

Modifier and Type	Method and Description
FieldList	FieldList.addFields(FieldSet set)
FieldSet	FieldSet.addFields(FieldSet set)
boolean	FieldList.isValidSubset(FieldSet set)
boolean	FieldSet.isValidSubset(FieldSet set) Checks if the given set of fields is a valid subset of this set of fields.
boolean	FieldList.isValidUnorderedPrefix(FieldSet set)

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

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

Modifier and Type	Field and Description
protected FieldSet	SingleInputNode.keys

Fields in org.apache.flink.optimizer.dag with type parameters of type FieldSet

Modifier and Type	Field and Description
protected Set<FieldSet>	OptimizerNode.uniqueFields

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

Modifier and Type	Method and Description
FieldSet	BinaryUnionNode.UnionSemanticProperties.getForwardingTargetFields(int input, int sourceField)
FieldSet	BinaryUnionNode.UnionSemanticProperties.getReadFields(int input)

Methods in org.apache.flink.optimizer.dag that return types with arguments of type FieldSet

Modifier and Type	Method and Description
Set<FieldSet>	OptimizerNode.getUniqueFields() Gets the FieldSets which are unique in the output of the node.

Constructors in org.apache.flink.optimizer.dag with parameters of type FieldSet

Constructor and Description
PartitionDescriptor(PartitionOperatorBase.PartitionMethod pMethod, FieldSet pKeys, Ordering ordering, Partitioner<?> customPartitioner, DataDistribution distribution)
SingleInputNode(FieldSet keys)
UnaryOperatorNode(String name, FieldSet keys, List<OperatorDescriptorSingle> operators)
UnaryOperatorNode(String name, FieldSet keys, OperatorDescriptorSingle... operators)

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

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

Modifier and Type	Method and Description
FieldSet	RequestedLocalProperties.getGroupedFields() Gets the grouped fields.
FieldSet	RequestedGlobalProperties.getPartitionedFields() Gets the fields on which the data is partitioned.

Methods in org.apache.flink.optimizer.dataproperties that return types with arguments of type FieldSet

Modifier and Type	Method and Description
Set<FieldSet>	GlobalProperties.getUniqueFieldCombination()
Set<FieldSet>	LocalProperties.getUniqueFields() Gets the fields whose combination is unique within the data set.

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

Modifier and Type	Method and Description
void	GlobalProperties.addUniqueFieldCombination(FieldSet fields)
LocalProperties	LocalProperties.addUniqueFields(FieldSet uniqueFields) Adds a combination of fields that are unique in these data properties.
boolean	LocalProperties.areFieldsUnique(FieldSet set) Checks whether the given set of fields is unique, as specified in these local properties.
boolean	GlobalProperties.isPartitionedOnFields(FieldSet fields)
void	RequestedGlobalProperties.setAnyPartitioning(FieldSet partitionedFields) Sets these properties to request some partitioning on the given fields.
void	RequestedGlobalProperties.setCustomPartitioned(FieldSet partitionedFields, Partitioner<?> partitioner) Sets these properties to request a custom partitioning with the given Partitioner instance.
void	RequestedLocalProperties.setGroupedFields(FieldSet groupedFields) Sets the fields that are grouped in these data properties.
void	RequestedGlobalProperties.setHashPartitioned(FieldSet partitionedFields) Sets these properties to request a hash partitioning on the given fields.

Constructors in org.apache.flink.optimizer.dataproperties with parameters of type FieldSet

Constructor and Description
RequestedLocalProperties(FieldSet groupedFields) Creates interesting properties for the given grouping.

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

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

Modifier and Type	Field and Description
protected FieldSet	OperatorDescriptorSingle.keys

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

Constructor and Description
GroupCombineProperties(FieldSet groupKeys, Ordering additionalOrderKeys)
GroupReduceProperties(FieldSet keys)
GroupReduceProperties(FieldSet keys, Ordering additionalOrderKeys)
GroupReduceProperties(FieldSet groupKeys, Ordering additionalOrderKeys, Partitioner<?> customPartitioner)
GroupReduceProperties(FieldSet keys, Partitioner<?> customPartitioner)
GroupReduceWithCombineProperties(FieldSet groupKeys)
GroupReduceWithCombineProperties(FieldSet groupKeys, Ordering additionalOrderKeys)
GroupReduceWithCombineProperties(FieldSet groupKeys, Ordering additionalOrderKeys, Partitioner<?> customPartitioner)
GroupReduceWithCombineProperties(FieldSet groupKeys, Partitioner<?> customPartitioner)
OperatorDescriptorSingle(FieldSet keys)
PartialGroupProperties(FieldSet keys)
ReduceProperties(FieldSet keys, DriverStrategy combinerStrategy)
ReduceProperties(FieldSet keys, Partitioner<?> customPartitioner, DriverStrategy combinerStrategy)

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

Method parameters in org.apache.flink.optimizer.plan with type arguments of type FieldSet

Modifier and Type	Method and Description
void	PlanNode.updatePropertiesWithUniqueSets(Set<FieldSet> uniqueFieldCombinations)

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

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

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