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

Packages that use RequestedGlobalProperties

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

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

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

Modifier and Type	Method and Description
protected List<RequestedGlobalProperties>	PartitionNode.PartitionDescriptor.createPossibleGlobalProperties()
protected List<RequestedGlobalProperties>	SortPartitionNode.SortPartitionDescriptor.createPossibleGlobalProperties()

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

Modifier and Type	Method and Description
protected void	TwoInputNode.addLocalCandidates(Channel template1, Channel template2, List<Set<? extends NamedChannel>> broadcastPlanChannels, RequestedGlobalProperties rgps1, RequestedGlobalProperties rgps2, List<PlanNode> target, OperatorDescriptorDual.LocalPropertiesPair[] validLocalCombinations, CostEstimator estimator)
protected void	SingleInputNode.addLocalCandidates(Channel template, List<Set<? extends NamedChannel>> broadcastPlanChannels, RequestedGlobalProperties rgps, List<PlanNode> target, CostEstimator estimator)
protected void	WorksetIterationNode.instantiate(OperatorDescriptorDual operator, Channel solutionSetIn, Channel worksetIn, List<Set<? extends NamedChannel>> broadcastPlanChannels, List<PlanNode> target, CostEstimator estimator, RequestedGlobalProperties globPropsReqSolutionSet, RequestedGlobalProperties globPropsReqWorkset, RequestedLocalProperties locPropsReqSolutionSet, RequestedLocalProperties locPropsReqWorkset)
protected void	TwoInputNode.instantiate(OperatorDescriptorDual operator, Channel in1, Channel in2, List<Set<? extends NamedChannel>> broadcastPlanChannels, List<PlanNode> target, CostEstimator estimator, RequestedGlobalProperties globPropsReq1, RequestedGlobalProperties globPropsReq2, RequestedLocalProperties locPropsReq1, RequestedLocalProperties locPropsReq2)
protected void	BulkIterationNode.instantiateCandidate(OperatorDescriptorSingle dps, Channel in, List<Set<? extends NamedChannel>> broadcastPlanChannels, List<PlanNode> target, CostEstimator estimator, RequestedGlobalProperties globPropsReq, RequestedLocalProperties locPropsReq)
protected void	SingleInputNode.instantiateCandidate(OperatorDescriptorSingle dps, Channel in, List<Set<? extends NamedChannel>> broadcastPlanChannels, List<PlanNode> target, CostEstimator estimator, RequestedGlobalProperties globPropsReq, RequestedLocalProperties locPropsReq)

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

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

Modifier and Type	Method and Description
RequestedGlobalProperties	RequestedGlobalProperties.clone()
RequestedGlobalProperties	RequestedGlobalProperties.filterBySemanticProperties(SemanticProperties props, int input) Filters these properties by what can be preserved by the given SemanticProperties when propagated down to the given input.

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

Modifier and Type	Method and Description
Set<RequestedGlobalProperties>	InterestingProperties.getGlobalProperties() Gets the interesting global properties.

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

Modifier and Type	Method and Description
void	InterestingProperties.addGlobalProperties(RequestedGlobalProperties props)

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

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

Modifier and Type	Method and Description
RequestedGlobalProperties	OperatorDescriptorDual.GlobalPropertiesPair.getProperties1()
RequestedGlobalProperties	OperatorDescriptorDual.GlobalPropertiesPair.getProperties2()

Methods in org.apache.flink.optimizer.operators that return types with arguments of type RequestedGlobalProperties

Modifier and Type	Method and Description
protected List<RequestedGlobalProperties>	MapPartitionDescriptor.createPossibleGlobalProperties()
protected List<RequestedGlobalProperties>	PartialGroupProperties.createPossibleGlobalProperties()
protected List<RequestedGlobalProperties>	GroupCombineProperties.createPossibleGlobalProperties()
protected List<RequestedGlobalProperties>	GroupReduceProperties.createPossibleGlobalProperties()
protected List<RequestedGlobalProperties>	AllGroupWithPartialPreGroupProperties.createPossibleGlobalProperties()
protected abstract List<RequestedGlobalProperties>	OperatorDescriptorSingle.createPossibleGlobalProperties() Returns a list of global properties that are required by this operator descriptor.
protected List<RequestedGlobalProperties>	AllGroupCombineProperties.createPossibleGlobalProperties()
protected List<RequestedGlobalProperties>	AllGroupReduceProperties.createPossibleGlobalProperties()
protected List<RequestedGlobalProperties>	AllReduceProperties.createPossibleGlobalProperties()
protected List<RequestedGlobalProperties>	FilterDescriptor.createPossibleGlobalProperties()
protected List<RequestedGlobalProperties>	MapDescriptor.createPossibleGlobalProperties()
protected List<RequestedGlobalProperties>	FlatMapDescriptor.createPossibleGlobalProperties()
protected List<RequestedGlobalProperties>	NoOpDescriptor.createPossibleGlobalProperties()
protected List<RequestedGlobalProperties>	ReduceProperties.createPossibleGlobalProperties()
protected List<RequestedGlobalProperties>	GroupReduceWithCombineProperties.createPossibleGlobalProperties()
protected List<RequestedGlobalProperties>	SolutionSetDeltaOperator.createPossibleGlobalProperties()
List<RequestedGlobalProperties>	OperatorDescriptorSingle.getPossibleGlobalProperties()

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

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)

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

Constructor and Description
GlobalPropertiesPair(RequestedGlobalProperties props1, RequestedGlobalProperties props2)

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

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

Modifier and Type	Method and Description
RequestedGlobalProperties	Channel.getRequiredGlobalProps()

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

Modifier and Type	Method and Description
void	Channel.setRequiredGlobalProps(RequestedGlobalProperties requiredGlobalProps)