Uses of Class
org.apache.flink.optimizer.dataproperties.LocalProperties

Packages that use LocalProperties

Package	Description
org.apache.flink.optimizer.dag
org.apache.flink.optimizer.dataproperties
org.apache.flink.optimizer.operators
org.apache.flink.optimizer.plan

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

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

Modifier and Type	Method	Description
LocalProperties	PartitionNode.PartitionDescriptor.computeLocalProperties(LocalProperties lProps)
LocalProperties	SortPartitionNode.SortPartitionDescriptor.computeLocalProperties(LocalProperties lProps)

Methods in org.apache.flink.optimizer.dag with parameters of type LocalProperties

Modifier and Type	Method	Description
LocalProperties	PartitionNode.PartitionDescriptor.computeLocalProperties(LocalProperties lProps)
LocalProperties	SortPartitionNode.SortPartitionDescriptor.computeLocalProperties(LocalProperties lProps)
void	BulkPartialSolutionNode.setCandidateProperties(GlobalProperties gProps, LocalProperties lProps, Channel initialInput)
void	SolutionSetNode.setCandidateProperties(GlobalProperties gProps, LocalProperties lProps, Channel initialInput)
void	WorksetNode.setCandidateProperties(GlobalProperties gProps, LocalProperties lProps, Channel initialInput)

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

Fields in org.apache.flink.optimizer.dataproperties declared as LocalProperties

Modifier and Type	Field	Description
static LocalProperties	LocalProperties.EMPTY

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

Modifier and Type	Method	Description
LocalProperties	LocalProperties.addUniqueFields(org.apache.flink.api.common.operators.util.FieldSet uniqueFields)	Adds a combination of fields that are unique in these data properties.
LocalProperties	LocalProperties.clearUniqueFieldSets()
LocalProperties	LocalProperties.clone()
static LocalProperties	LocalProperties.combine(LocalProperties lp1, LocalProperties lp2)
LocalProperties	LocalProperties.filterBySemanticProperties(org.apache.flink.api.common.operators.SemanticProperties props, int input)	Filters these LocalProperties by the fields that are forwarded to the output as described by the SemanticProperties.
static LocalProperties	LocalProperties.forGrouping(org.apache.flink.api.common.operators.util.FieldList groupedFields)
static LocalProperties	LocalProperties.forOrdering(org.apache.flink.api.common.operators.Ordering o)

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

Modifier and Type	Method	Description
static LocalProperties	LocalProperties.combine(LocalProperties lp1, LocalProperties lp2)
boolean	RequestedLocalProperties.isMetBy(LocalProperties other)	Checks, if this set of properties, as interesting properties, is met by the given properties.

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

Methods in org.apache.flink.optimizer.operators that return LocalProperties

Modifier and Type	Method	Description
LocalProperties	AbstractSortMergeJoinDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	AllGroupCombineProperties.computeLocalProperties(LocalProperties lProps)
LocalProperties	AllGroupReduceProperties.computeLocalProperties(LocalProperties lProps)
LocalProperties	AllGroupWithPartialPreGroupProperties.computeLocalProperties(LocalProperties lProps)
LocalProperties	AllReduceProperties.computeLocalProperties(LocalProperties lProps)
LocalProperties	BinaryUnionOpDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	CoGroupDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	CoGroupRawDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	CoGroupWithSolutionSetFirstDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	CoGroupWithSolutionSetSecondDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	CrossBlockOuterFirstDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	CrossBlockOuterSecondDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	CrossStreamOuterFirstDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	CrossStreamOuterSecondDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	FilterDescriptor.computeLocalProperties(LocalProperties lProps)
LocalProperties	FlatMapDescriptor.computeLocalProperties(LocalProperties lProps)
LocalProperties	GroupCombineProperties.computeLocalProperties(LocalProperties lProps)
LocalProperties	GroupReduceProperties.computeLocalProperties(LocalProperties lProps)
LocalProperties	GroupReduceWithCombineProperties.computeLocalProperties(LocalProperties lProps)
LocalProperties	HashFullOuterJoinBuildFirstDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	HashFullOuterJoinBuildSecondDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	HashJoinBuildFirstProperties.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	HashJoinBuildSecondProperties.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	HashLeftOuterJoinBuildFirstDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	HashLeftOuterJoinBuildSecondDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	HashRightOuterJoinBuildFirstDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	HashRightOuterJoinBuildSecondDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	MapDescriptor.computeLocalProperties(LocalProperties lProps)
LocalProperties	MapPartitionDescriptor.computeLocalProperties(LocalProperties lProps)
LocalProperties	NoOpDescriptor.computeLocalProperties(LocalProperties lProps)
abstract LocalProperties	OperatorDescriptorDual.computeLocalProperties(LocalProperties in1, LocalProperties in2)
abstract LocalProperties	OperatorDescriptorSingle.computeLocalProperties(LocalProperties in)	Returns the local properties which are present after the operator was applied on the provided local properties.
LocalProperties	PartialGroupProperties.computeLocalProperties(LocalProperties lProps)
LocalProperties	ReduceProperties.computeLocalProperties(LocalProperties lProps)
LocalProperties	SolutionSetDeltaOperator.computeLocalProperties(LocalProperties lProps)
LocalProperties	UtilSinkJoinOpDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)

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

Modifier and Type	Method	Description
boolean	AbstractSortMergeJoinDescriptor.areCoFulfilled(RequestedLocalProperties requested1, RequestedLocalProperties requested2, LocalProperties produced1, LocalProperties produced2)
boolean	BinaryUnionOpDescriptor.areCoFulfilled(RequestedLocalProperties requested1, RequestedLocalProperties requested2, LocalProperties produced1, LocalProperties produced2)
boolean	CartesianProductDescriptor.areCoFulfilled(RequestedLocalProperties requested1, RequestedLocalProperties requested2, LocalProperties produced1, LocalProperties produced2)
boolean	CoGroupDescriptor.areCoFulfilled(RequestedLocalProperties requested1, RequestedLocalProperties requested2, LocalProperties produced1, LocalProperties produced2)
boolean	CoGroupRawDescriptor.areCoFulfilled(RequestedLocalProperties requested1, RequestedLocalProperties requested2, LocalProperties produced1, LocalProperties produced2)
boolean	CoGroupWithSolutionSetFirstDescriptor.areCoFulfilled(RequestedLocalProperties requested1, RequestedLocalProperties requested2, LocalProperties produced1, LocalProperties produced2)
boolean	CoGroupWithSolutionSetSecondDescriptor.areCoFulfilled(RequestedLocalProperties requested1, RequestedLocalProperties requested2, LocalProperties produced1, LocalProperties produced2)
boolean	HashFullOuterJoinBuildFirstDescriptor.areCoFulfilled(RequestedLocalProperties requested1, RequestedLocalProperties requested2, LocalProperties produced1, LocalProperties produced2)
boolean	HashFullOuterJoinBuildSecondDescriptor.areCoFulfilled(RequestedLocalProperties requested1, RequestedLocalProperties requested2, LocalProperties produced1, LocalProperties produced2)
boolean	HashJoinBuildFirstProperties.areCoFulfilled(RequestedLocalProperties requested1, RequestedLocalProperties requested2, LocalProperties produced1, LocalProperties produced2)
boolean	HashJoinBuildSecondProperties.areCoFulfilled(RequestedLocalProperties requested1, RequestedLocalProperties requested2, LocalProperties produced1, LocalProperties produced2)
boolean	HashLeftOuterJoinBuildFirstDescriptor.areCoFulfilled(RequestedLocalProperties requested1, RequestedLocalProperties requested2, LocalProperties produced1, LocalProperties produced2)
boolean	HashLeftOuterJoinBuildSecondDescriptor.areCoFulfilled(RequestedLocalProperties requested1, RequestedLocalProperties requested2, LocalProperties produced1, LocalProperties produced2)
boolean	HashRightOuterJoinBuildFirstDescriptor.areCoFulfilled(RequestedLocalProperties requested1, RequestedLocalProperties requested2, LocalProperties produced1, LocalProperties produced2)
boolean	HashRightOuterJoinBuildSecondDescriptor.areCoFulfilled(RequestedLocalProperties requested1, RequestedLocalProperties requested2, LocalProperties produced1, LocalProperties produced2)
abstract boolean	OperatorDescriptorDual.areCoFulfilled(RequestedLocalProperties requested1, RequestedLocalProperties requested2, LocalProperties produced1, LocalProperties produced2)
boolean	UtilSinkJoinOpDescriptor.areCoFulfilled(RequestedLocalProperties requested1, RequestedLocalProperties requested2, LocalProperties produced1, LocalProperties produced2)
protected boolean	OperatorDescriptorDual.checkSameOrdering(LocalProperties produced1, LocalProperties produced2, int numRelevantFields)
LocalProperties	AbstractSortMergeJoinDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	AllGroupCombineProperties.computeLocalProperties(LocalProperties lProps)
LocalProperties	AllGroupReduceProperties.computeLocalProperties(LocalProperties lProps)
LocalProperties	AllGroupWithPartialPreGroupProperties.computeLocalProperties(LocalProperties lProps)
LocalProperties	AllReduceProperties.computeLocalProperties(LocalProperties lProps)
LocalProperties	BinaryUnionOpDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	CoGroupDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	CoGroupRawDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	CoGroupWithSolutionSetFirstDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	CoGroupWithSolutionSetSecondDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	CrossBlockOuterFirstDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	CrossBlockOuterSecondDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	CrossStreamOuterFirstDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	CrossStreamOuterSecondDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	FilterDescriptor.computeLocalProperties(LocalProperties lProps)
LocalProperties	FlatMapDescriptor.computeLocalProperties(LocalProperties lProps)
LocalProperties	GroupCombineProperties.computeLocalProperties(LocalProperties lProps)
LocalProperties	GroupReduceProperties.computeLocalProperties(LocalProperties lProps)
LocalProperties	GroupReduceWithCombineProperties.computeLocalProperties(LocalProperties lProps)
LocalProperties	HashFullOuterJoinBuildFirstDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	HashFullOuterJoinBuildSecondDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	HashJoinBuildFirstProperties.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	HashJoinBuildSecondProperties.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	HashLeftOuterJoinBuildFirstDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	HashLeftOuterJoinBuildSecondDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	HashRightOuterJoinBuildFirstDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	HashRightOuterJoinBuildSecondDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)
LocalProperties	MapDescriptor.computeLocalProperties(LocalProperties lProps)
LocalProperties	MapPartitionDescriptor.computeLocalProperties(LocalProperties lProps)
LocalProperties	NoOpDescriptor.computeLocalProperties(LocalProperties lProps)
abstract LocalProperties	OperatorDescriptorDual.computeLocalProperties(LocalProperties in1, LocalProperties in2)
abstract LocalProperties	OperatorDescriptorSingle.computeLocalProperties(LocalProperties in)	Returns the local properties which are present after the operator was applied on the provided local properties.
LocalProperties	PartialGroupProperties.computeLocalProperties(LocalProperties lProps)
LocalProperties	ReduceProperties.computeLocalProperties(LocalProperties lProps)
LocalProperties	SolutionSetDeltaOperator.computeLocalProperties(LocalProperties lProps)
LocalProperties	UtilSinkJoinOpDescriptor.computeLocalProperties(LocalProperties in1, LocalProperties in2)

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

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

Modifier and Type	Field	Description
protected LocalProperties	PlanNode.localProps

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

Modifier and Type	Method	Description
LocalProperties	Channel.getLocalProperties()
LocalProperties	PlanNode.getLocalProperties()	Gets the local properties from this PlanNode.

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

Modifier and Type	Method	Description
PlanNode.FeedbackPropertiesMeetRequirementsReport	PlanNode.checkPartialSolutionPropertiesMet(PlanNode partialSolution, GlobalProperties feedbackGlobal, LocalProperties feedbackLocal)
void	PlanNode.initProperties(GlobalProperties globals, LocalProperties locals)

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

Constructor	Description
BulkPartialSolutionPlanNode(BulkPartialSolutionNode template, String nodeName, GlobalProperties gProps, LocalProperties lProps, Channel initialInput)
SolutionSetPlanNode(SolutionSetNode template, String nodeName, GlobalProperties gProps, LocalProperties lProps, Channel initialInput)
SourcePlanNode(DataSourceNode template, String nodeName, GlobalProperties gprops, LocalProperties lprops)
WorksetPlanNode(WorksetNode template, String nodeName, GlobalProperties gProps, LocalProperties lProps, Channel initialInput)