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

Packages that use GlobalProperties

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

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

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

Modifier and Type	Method and Description
GlobalProperties	PartitionNode.PartitionDescriptor.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	SortPartitionNode.SortPartitionDescriptor.computeGlobalProperties(GlobalProperties gProps)

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

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

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

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

Modifier and Type	Method and Description
GlobalProperties	GlobalProperties.clone()
static GlobalProperties	GlobalProperties.combine(GlobalProperties gp1, GlobalProperties gp2)
GlobalProperties	GlobalProperties.filterBySemanticProperties(SemanticProperties props, int input) Filters these GlobalProperties by the fields that are forwarded to the output as described by the SemanticProperties.

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

Modifier and Type	Method and Description
static GlobalProperties	GlobalProperties.combine(GlobalProperties gp1, GlobalProperties gp2)
boolean	RequestedGlobalProperties.isMetBy(GlobalProperties props) Checks, if this set of interesting properties, is met by the given produced properties.

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

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

Modifier and Type	Method and Description
GlobalProperties	MapPartitionDescriptor.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	PartialGroupProperties.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	GroupCombineProperties.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	GroupReduceProperties.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	AllGroupWithPartialPreGroupProperties.computeGlobalProperties(GlobalProperties gProps)
abstract GlobalProperties	OperatorDescriptorSingle.computeGlobalProperties(GlobalProperties in) Returns the global properties which are present after the operator was applied on the provided global properties.
GlobalProperties	AllGroupCombineProperties.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	AllGroupReduceProperties.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	AllReduceProperties.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	FilterDescriptor.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	MapDescriptor.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	FlatMapDescriptor.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	NoOpDescriptor.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	ReduceProperties.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	GroupReduceWithCombineProperties.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	SolutionSetDeltaOperator.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	CartesianProductDescriptor.computeGlobalProperties(GlobalProperties in1, GlobalProperties in2)
GlobalProperties	CoGroupDescriptor.computeGlobalProperties(GlobalProperties in1, GlobalProperties in2)
GlobalProperties	UtilSinkJoinOpDescriptor.computeGlobalProperties(GlobalProperties in1, GlobalProperties in2)
GlobalProperties	AbstractJoinDescriptor.computeGlobalProperties(GlobalProperties in1, GlobalProperties in2)
GlobalProperties	BinaryUnionOpDescriptor.computeGlobalProperties(GlobalProperties in1, GlobalProperties in2)
GlobalProperties	CoGroupRawDescriptor.computeGlobalProperties(GlobalProperties in1, GlobalProperties in2)
abstract GlobalProperties	OperatorDescriptorDual.computeGlobalProperties(GlobalProperties in1, GlobalProperties in2)

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

Modifier and Type	Method and Description
boolean	CartesianProductDescriptor.areCompatible(RequestedGlobalProperties requested1, RequestedGlobalProperties requested2, GlobalProperties produced1, GlobalProperties produced2)
boolean	CoGroupDescriptor.areCompatible(RequestedGlobalProperties requested1, RequestedGlobalProperties requested2, GlobalProperties produced1, GlobalProperties produced2)
boolean	UtilSinkJoinOpDescriptor.areCompatible(RequestedGlobalProperties requested1, RequestedGlobalProperties requested2, GlobalProperties produced1, GlobalProperties produced2)
boolean	AbstractJoinDescriptor.areCompatible(RequestedGlobalProperties requested1, RequestedGlobalProperties requested2, GlobalProperties produced1, GlobalProperties produced2)
boolean	BinaryUnionOpDescriptor.areCompatible(RequestedGlobalProperties requested1, RequestedGlobalProperties requested2, GlobalProperties produced1, GlobalProperties produced2)
boolean	CoGroupRawDescriptor.areCompatible(RequestedGlobalProperties requested1, RequestedGlobalProperties requested2, GlobalProperties produced1, GlobalProperties produced2)
abstract boolean	OperatorDescriptorDual.areCompatible(RequestedGlobalProperties requested1, RequestedGlobalProperties requested2, GlobalProperties produced1, GlobalProperties produced2)
protected boolean	OperatorDescriptorDual.checkSameOrdering(GlobalProperties produced1, GlobalProperties produced2, int numRelevantFields)
GlobalProperties	MapPartitionDescriptor.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	PartialGroupProperties.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	GroupCombineProperties.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	GroupReduceProperties.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	AllGroupWithPartialPreGroupProperties.computeGlobalProperties(GlobalProperties gProps)
abstract GlobalProperties	OperatorDescriptorSingle.computeGlobalProperties(GlobalProperties in) Returns the global properties which are present after the operator was applied on the provided global properties.
GlobalProperties	AllGroupCombineProperties.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	AllGroupReduceProperties.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	AllReduceProperties.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	FilterDescriptor.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	MapDescriptor.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	FlatMapDescriptor.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	NoOpDescriptor.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	ReduceProperties.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	GroupReduceWithCombineProperties.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	SolutionSetDeltaOperator.computeGlobalProperties(GlobalProperties gProps)
GlobalProperties	CartesianProductDescriptor.computeGlobalProperties(GlobalProperties in1, GlobalProperties in2)
GlobalProperties	CoGroupDescriptor.computeGlobalProperties(GlobalProperties in1, GlobalProperties in2)
GlobalProperties	UtilSinkJoinOpDescriptor.computeGlobalProperties(GlobalProperties in1, GlobalProperties in2)
GlobalProperties	AbstractJoinDescriptor.computeGlobalProperties(GlobalProperties in1, GlobalProperties in2)
GlobalProperties	BinaryUnionOpDescriptor.computeGlobalProperties(GlobalProperties in1, GlobalProperties in2)
GlobalProperties	CoGroupRawDescriptor.computeGlobalProperties(GlobalProperties in1, GlobalProperties in2)
abstract GlobalProperties	OperatorDescriptorDual.computeGlobalProperties(GlobalProperties in1, GlobalProperties in2)

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

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

Modifier and Type	Field and Description
protected GlobalProperties	PlanNode.globalProps

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

Modifier and Type	Method and Description
GlobalProperties	PlanNode.getGlobalProperties() Gets the global properties from this PlanNode.
GlobalProperties	Channel.getGlobalProperties()

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

Modifier and Type	Method and 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 GlobalProperties

Constructor and Description
BulkPartialSolutionPlanNode(BulkPartialSolutionNode template, String nodeName, GlobalProperties gProps, LocalProperties lProps, Channel initialInput)
NAryUnionPlanNode(BinaryUnionNode template, List<Channel> inputs, GlobalProperties gProps, Costs cumulativeCosts)
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)