A B C D E F G H I J K L M N O P R S T U V W
All Classes All Packages

A

AbstractJoinDescriptor - Class in org.apache.flink.optimizer.operators

Defines the possible global properties for a join.

AbstractJoinDescriptor(FieldList, FieldList) - Constructor for class org.apache.flink.optimizer.operators.AbstractJoinDescriptor

AbstractJoinDescriptor(FieldList, FieldList, boolean, boolean, boolean) - Constructor for class org.apache.flink.optimizer.operators.AbstractJoinDescriptor

AbstractOperatorDescriptor - Interface in org.apache.flink.optimizer.operators

The root of all descriptions of an operator to the optimizer.

AbstractPartialSolutionNode - Class in org.apache.flink.optimizer.dag

The optimizer's internal representation of the partial solution that is input to a bulk iteration.

AbstractPartialSolutionNode(Operator<?>) - Constructor for class org.apache.flink.optimizer.dag.AbstractPartialSolutionNode

AbstractSortMergeJoinDescriptor - Class in org.apache.flink.optimizer.operators

AbstractSortMergeJoinDescriptor(FieldList, FieldList) - Constructor for class org.apache.flink.optimizer.operators.AbstractSortMergeJoinDescriptor

AbstractSortMergeJoinDescriptor(FieldList, FieldList, boolean, boolean, boolean) - Constructor for class org.apache.flink.optimizer.operators.AbstractSortMergeJoinDescriptor

accept(Visitor<OptimizerNode>) - Method in class org.apache.flink.optimizer.dag.AbstractPartialSolutionNode

accept(Visitor<OptimizerNode>) - Method in class org.apache.flink.optimizer.dag.DataSinkNode

accept(Visitor<OptimizerNode>) - Method in class org.apache.flink.optimizer.dag.DataSourceNode

accept(Visitor<OptimizerNode>) - Method in class org.apache.flink.optimizer.dag.OptimizerNode

This method implements the visit of a depth-first graph traversing visitor.

accept(Visitor<OptimizerNode>) - Method in class org.apache.flink.optimizer.dag.SingleInputNode

accept(Visitor<OptimizerNode>) - Method in class org.apache.flink.optimizer.dag.TwoInputNode

accept(Visitor<PlanNode>) - Method in class org.apache.flink.optimizer.plan.BulkPartialSolutionPlanNode

accept(Visitor<PlanNode>) - Method in class org.apache.flink.optimizer.plan.DualInputPlanNode

accept(Visitor<PlanNode>) - Method in class org.apache.flink.optimizer.plan.NAryUnionPlanNode

accept(Visitor<PlanNode>) - Method in class org.apache.flink.optimizer.plan.OptimizedPlan

Applies the given visitor top down to all nodes, starting at the sinks.

accept(Visitor<PlanNode>) - Method in class org.apache.flink.optimizer.plan.SingleInputPlanNode

accept(Visitor<PlanNode>) - Method in class org.apache.flink.optimizer.plan.SolutionSetPlanNode

accept(Visitor<PlanNode>) - Method in class org.apache.flink.optimizer.plan.SourcePlanNode

accept(Visitor<PlanNode>) - Method in class org.apache.flink.optimizer.plan.WorksetPlanNode

acceptForStepFunction(Visitor<OptimizerNode>) - Method in class org.apache.flink.optimizer.dag.BulkIterationNode

acceptForStepFunction(Visitor<OptimizerNode>) - Method in interface org.apache.flink.optimizer.dag.IterationNode

acceptForStepFunction(Visitor<OptimizerNode>) - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode

acceptForStepFunction(Visitor<PlanNode>) - Method in class org.apache.flink.optimizer.plan.BulkIterationPlanNode

acceptForStepFunction(Visitor<PlanNode>) - Method in interface org.apache.flink.optimizer.plan.IterationPlanNode

acceptForStepFunction(Visitor<PlanNode>) - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

addArtificialDamCost(EstimateProvider, long, Costs) - Method in class org.apache.flink.optimizer.costs.CostEstimator

addArtificialDamCost(EstimateProvider, long, Costs) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator

addBlockNestedLoopsCosts(EstimateProvider, EstimateProvider, long, Costs, int) - Method in class org.apache.flink.optimizer.costs.CostEstimator

addBlockNestedLoopsCosts(EstimateProvider, EstimateProvider, long, Costs, int) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator

addBroadcastConnection(String, DagConnection) - Method in class org.apache.flink.optimizer.dag.OptimizerNode

Adds the broadcast connection identified by the given name to this node.

addBroadcastCost(EstimateProvider, int, Costs) - Method in class org.apache.flink.optimizer.costs.CostEstimator

addBroadcastCost(EstimateProvider, int, Costs) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator

addCachedHybridHashCosts(EstimateProvider, EstimateProvider, Costs, int) - Method in class org.apache.flink.optimizer.costs.CostEstimator

addCachedHybridHashCosts(EstimateProvider, EstimateProvider, Costs, int) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator

Calculates the costs for the cached variant of the hybrid hash join.

addClosedBranch(OptimizerNode) - Method in class org.apache.flink.optimizer.dag.OptimizerNode

addClosedBranches(Set<OptimizerNode>) - Method in class org.apache.flink.optimizer.dag.OptimizerNode

addCosts(Costs) - Method in class org.apache.flink.optimizer.costs.Costs

Adds the given costs to these costs.

addCpuCost(double) - Method in class org.apache.flink.optimizer.costs.Costs

Adds the given CPU cost to the current CPU cost for this Costs object.

addDiskCost(double) - Method in class org.apache.flink.optimizer.costs.Costs

Adds the costs for disk to the current disk costs for this Costs object.

addFileInputCost(long, Costs) - Method in class org.apache.flink.optimizer.costs.CostEstimator

addFileInputCost(long, Costs) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator

addGlobalProperties(RequestedGlobalProperties) - Method in class org.apache.flink.optimizer.dataproperties.InterestingProperties

addHashPartitioningCost(EstimateProvider, Costs) - Method in class org.apache.flink.optimizer.costs.CostEstimator

addHashPartitioningCost(EstimateProvider, Costs) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator

addHeuristicCpuCost(double) - Method in class org.apache.flink.optimizer.costs.Costs

Adds the given heuristic CPU cost to the current heuristic CPU cost for this Costs object.

addHeuristicDiskCost(double) - Method in class org.apache.flink.optimizer.costs.Costs

Adds the heuristic costs for disk to the current heuristic disk costs for this Costs object.

addHeuristicNetworkCost(double) - Method in class org.apache.flink.optimizer.costs.Costs

Adds the heuristic costs for network to the current heuristic network costs for this Costs object.

addHybridHashCosts(EstimateProvider, EstimateProvider, Costs, int) - Method in class org.apache.flink.optimizer.costs.CostEstimator

addHybridHashCosts(EstimateProvider, EstimateProvider, Costs, int) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator

addInterestingProperties(InterestingProperties) - Method in class org.apache.flink.optimizer.dataproperties.InterestingProperties

addLocalCandidates(Channel, List<Set<? extends NamedChannel>>, RequestedGlobalProperties, List<PlanNode>, CostEstimator) - Method in class org.apache.flink.optimizer.dag.SingleInputNode

addLocalCandidates(Channel, Channel, List<Set<? extends NamedChannel>>, RequestedGlobalProperties, RequestedGlobalProperties, List<PlanNode>, OperatorDescriptorDual.LocalPropertiesPair[], CostEstimator) - Method in class org.apache.flink.optimizer.dag.TwoInputNode

addLocalMergeCost(EstimateProvider, EstimateProvider, Costs, int) - Method in class org.apache.flink.optimizer.costs.CostEstimator

addLocalMergeCost(EstimateProvider, EstimateProvider, Costs, int) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator

addLocalProperties(RequestedLocalProperties) - Method in class org.apache.flink.optimizer.dataproperties.InterestingProperties

addLocalSortCost(EstimateProvider, Costs) - Method in class org.apache.flink.optimizer.costs.CostEstimator

addLocalSortCost(EstimateProvider, Costs) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator

addNetworkCost(double) - Method in class org.apache.flink.optimizer.costs.Costs

Adds the costs for network to the current network costs for this Costs object.

addOutgoingChannel(Channel) - Method in class org.apache.flink.optimizer.plan.PlanNode

Adds a channel to a successor node to this node.

addOutgoingConnection(DagConnection) - Method in class org.apache.flink.optimizer.dag.BinaryUnionNode

addOutgoingConnection(DagConnection) - Method in class org.apache.flink.optimizer.dag.OptimizerNode

Adds a new outgoing connection to this node.

addRandomPartitioningCost(EstimateProvider, Costs) - Method in class org.apache.flink.optimizer.costs.CostEstimator

addRandomPartitioningCost(EstimateProvider, Costs) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator

addRangePartitionCost(EstimateProvider, Costs) - Method in class org.apache.flink.optimizer.costs.CostEstimator

addRangePartitionCost(EstimateProvider, Costs) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator

addStreamedNestedLoopsCosts(EstimateProvider, EstimateProvider, long, Costs, int) - Method in class org.apache.flink.optimizer.costs.CostEstimator

addStreamedNestedLoopsCosts(EstimateProvider, EstimateProvider, long, Costs, int) - Method in class org.apache.flink.optimizer.costs.DefaultCostEstimator

addUniqueFieldCombination(FieldSet) - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

addUniqueFields(FieldSet) - Method in class org.apache.flink.optimizer.dataproperties.LocalProperties

Adds a combination of fields that are unique in these data properties.

adjustGlobalPropertiesForFullParallelismChange() - Method in class org.apache.flink.optimizer.plan.Channel

AllGroupCombineProperties - Class in org.apache.flink.optimizer.operators

AllGroupCombineProperties() - Constructor for class org.apache.flink.optimizer.operators.AllGroupCombineProperties

AllGroupReduceProperties - Class in org.apache.flink.optimizer.operators

AllGroupReduceProperties() - Constructor for class org.apache.flink.optimizer.operators.AllGroupReduceProperties

AllGroupWithPartialPreGroupProperties - Class in org.apache.flink.optimizer.operators

AllGroupWithPartialPreGroupProperties() - Constructor for class org.apache.flink.optimizer.operators.AllGroupWithPartialPreGroupProperties

AllReduceProperties - Class in org.apache.flink.optimizer.operators

AllReduceProperties() - Constructor for class org.apache.flink.optimizer.operators.AllReduceProperties

ANY_DISTRIBUTION - org.apache.flink.optimizer.dataproperties.PartitioningProperty

Any possible way of data distribution, including random partitioning and full replication.

ANY_PARTITIONING - org.apache.flink.optimizer.dataproperties.PartitioningProperty

A not further specified partitioning on a key (hash-, or range partitioning, or some other scheme even).

areBranchCompatible(PlanNode, PlanNode) - Method in class org.apache.flink.optimizer.dag.OptimizerNode

Checks whether to candidate plans for the sub-plan of this node are comparable.

areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.AbstractSortMergeJoinDescriptor

areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.BinaryUnionOpDescriptor

areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.CartesianProductDescriptor

areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.CoGroupDescriptor

areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.CoGroupRawDescriptor

areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.CoGroupWithSolutionSetFirstDescriptor

areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.CoGroupWithSolutionSetSecondDescriptor

areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashFullOuterJoinBuildFirstDescriptor

areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashFullOuterJoinBuildSecondDescriptor

areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashJoinBuildFirstProperties

areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashJoinBuildSecondProperties

areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashLeftOuterJoinBuildFirstDescriptor

areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashLeftOuterJoinBuildSecondDescriptor

areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashRightOuterJoinBuildFirstDescriptor

areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashRightOuterJoinBuildSecondDescriptor

areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual

areCoFulfilled(RequestedLocalProperties, RequestedLocalProperties, LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.UtilSinkJoinOpDescriptor

areCompatible(RequestedGlobalProperties, RequestedGlobalProperties, GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.AbstractJoinDescriptor

areCompatible(RequestedGlobalProperties, RequestedGlobalProperties, GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.BinaryUnionOpDescriptor

areCompatible(RequestedGlobalProperties, RequestedGlobalProperties, GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.CartesianProductDescriptor

areCompatible(RequestedGlobalProperties, RequestedGlobalProperties, GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.CoGroupDescriptor

areCompatible(RequestedGlobalProperties, RequestedGlobalProperties, GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.CoGroupRawDescriptor

areCompatible(RequestedGlobalProperties, RequestedGlobalProperties, GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual

areCompatible(RequestedGlobalProperties, RequestedGlobalProperties, GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.UtilSinkJoinOpDescriptor

areFieldsUnique(FieldSet) - Method in class org.apache.flink.optimizer.dataproperties.LocalProperties

Checks whether the given set of fields is unique, as specified in these local properties.

B

BinaryUnionNode - Class in org.apache.flink.optimizer.dag

The Optimizer representation of a binary Union.

BinaryUnionNode(Union<?>) - Constructor for class org.apache.flink.optimizer.dag.BinaryUnionNode

BinaryUnionNode.UnionSemanticProperties - Class in org.apache.flink.optimizer.dag

BinaryUnionOpDescriptor - Class in org.apache.flink.optimizer.operators

BinaryUnionOpDescriptor() - Constructor for class org.apache.flink.optimizer.operators.BinaryUnionOpDescriptor

BinaryUnionPlanNode - Class in org.apache.flink.optimizer.plan

A special subclass for the union to make it identifiable.

BinaryUnionPlanNode(BinaryUnionNode, Channel, Channel) - Constructor for class org.apache.flink.optimizer.plan.BinaryUnionPlanNode

BinaryUnionPlanNode(BinaryUnionPlanNode) - Constructor for class org.apache.flink.optimizer.plan.BinaryUnionPlanNode

BinaryUnionReplacer - Class in org.apache.flink.optimizer.traversals

A traversal that collects cascading binary unions into a single n-ary union operator.

BinaryUnionReplacer() - Constructor for class org.apache.flink.optimizer.traversals.BinaryUnionReplacer

BranchesVisitor - Class in org.apache.flink.optimizer.traversals

This traversal of the optimizer DAG computes the information needed to track branches and joins in the data flow.

BranchesVisitor() - Constructor for class org.apache.flink.optimizer.traversals.BranchesVisitor

branchingNode - Variable in class org.apache.flink.optimizer.dag.OptimizerNode.UnclosedBranchDescriptor

branchPlan - Variable in class org.apache.flink.optimizer.plan.PlanNode

breaksPipeline() - Method in enum org.apache.flink.optimizer.dag.TempMode

BulkIterationNode - Class in org.apache.flink.optimizer.dag

A node in the optimizer's program representation for a bulk iteration.

BulkIterationNode(BulkIterationBase<?>) - Constructor for class org.apache.flink.optimizer.dag.BulkIterationNode

Creates a new node for the bulk iteration.

BulkIterationPlanNode - Class in org.apache.flink.optimizer.plan

BulkIterationPlanNode(BulkIterationNode, String, Channel, BulkPartialSolutionPlanNode, PlanNode) - Constructor for class org.apache.flink.optimizer.plan.BulkIterationPlanNode

BulkIterationPlanNode(BulkIterationNode, String, Channel, BulkPartialSolutionPlanNode, PlanNode, PlanNode) - Constructor for class org.apache.flink.optimizer.plan.BulkIterationPlanNode

BulkPartialSolutionNode - Class in org.apache.flink.optimizer.dag

The optimizer's internal representation of the partial solution that is input to a bulk iteration.

BulkPartialSolutionNode(BulkIterationBase.PartialSolutionPlaceHolder<?>, BulkIterationNode) - Constructor for class org.apache.flink.optimizer.dag.BulkPartialSolutionNode

BulkPartialSolutionPlanNode - Class in org.apache.flink.optimizer.plan

Plan candidate node for partial solution of a bulk iteration.

BulkPartialSolutionPlanNode(BulkPartialSolutionNode, String, GlobalProperties, LocalProperties, Channel) - Constructor for class org.apache.flink.optimizer.plan.BulkPartialSolutionPlanNode

C

cacheBaseStatistics(BaseStatistics, String) - Method in class org.apache.flink.optimizer.DataStatistics

Caches the given statistics.

CACHED - org.apache.flink.optimizer.dag.TempMode

cachedPlans - Variable in class org.apache.flink.optimizer.dag.OptimizerNode

CACHING_PIPELINE_BREAKER - org.apache.flink.optimizer.dag.TempMode

CartesianProductDescriptor - Class in org.apache.flink.optimizer.operators

CartesianProductDescriptor(boolean, boolean) - Constructor for class org.apache.flink.optimizer.operators.CartesianProductDescriptor

Channel - Class in org.apache.flink.optimizer.plan

A Channel represents the result produced by an operator and the data exchange before the consumption by the target operator.

Channel(PlanNode) - Constructor for class org.apache.flink.optimizer.plan.Channel

Channel(PlanNode, TempMode) - Constructor for class org.apache.flink.optimizer.plan.Channel

checkEquivalentFieldPositionsInKeyFields(FieldList, FieldList) - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual

checkEquivalentFieldPositionsInKeyFields(FieldList, FieldList, int) - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual

checkPartialSolutionPropertiesMet(PlanNode, GlobalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.plan.PlanNode

checkSameOrdering(GlobalProperties, GlobalProperties, int) - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual

checkSameOrdering(LocalProperties, LocalProperties, int) - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual

clearInterestingProperties() - Method in class org.apache.flink.optimizer.dag.BulkIterationNode

clearInterestingProperties() - Method in class org.apache.flink.optimizer.dag.DagConnection

clearInterestingProperties() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

clearInterestingProperties() - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode

clearUniqueFieldCombinations() - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

clearUniqueFieldSets() - Method in class org.apache.flink.optimizer.dataproperties.LocalProperties

clone() - Method in class org.apache.flink.optimizer.costs.Costs

clone() - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

clone() - Method in class org.apache.flink.optimizer.dataproperties.InterestingProperties

clone() - Method in class org.apache.flink.optimizer.dataproperties.LocalProperties

clone() - Method in class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties

clone() - Method in class org.apache.flink.optimizer.dataproperties.RequestedLocalProperties

clone() - Method in class org.apache.flink.optimizer.plan.Channel

closedBranchingNodes - Variable in class org.apache.flink.optimizer.dag.OptimizerNode

CoGroupDescriptor - Class in org.apache.flink.optimizer.operators

CoGroupDescriptor(FieldList, FieldList) - Constructor for class org.apache.flink.optimizer.operators.CoGroupDescriptor

CoGroupDescriptor(FieldList, FieldList, Ordering, Ordering) - Constructor for class org.apache.flink.optimizer.operators.CoGroupDescriptor

CoGroupNode - Class in org.apache.flink.optimizer.dag

The Optimizer representation of a CoGroup operator.

CoGroupNode(CoGroupOperatorBase<?, ?, ?, ?>) - Constructor for class org.apache.flink.optimizer.dag.CoGroupNode

CoGroupRawDescriptor - Class in org.apache.flink.optimizer.operators

CoGroupRawDescriptor(FieldList, FieldList) - Constructor for class org.apache.flink.optimizer.operators.CoGroupRawDescriptor

CoGroupRawDescriptor(FieldList, FieldList, Ordering, Ordering) - Constructor for class org.apache.flink.optimizer.operators.CoGroupRawDescriptor

CoGroupRawNode - Class in org.apache.flink.optimizer.dag

The Optimizer representation of a CoGroupRaw operator.

CoGroupRawNode(CoGroupRawOperatorBase<?, ?, ?, ?>) - Constructor for class org.apache.flink.optimizer.dag.CoGroupRawNode

CoGroupWithSolutionSetFirstDescriptor - Class in org.apache.flink.optimizer.operators

CoGroupWithSolutionSetFirstDescriptor(FieldList, FieldList) - Constructor for class org.apache.flink.optimizer.operators.CoGroupWithSolutionSetFirstDescriptor

CoGroupWithSolutionSetSecondDescriptor - Class in org.apache.flink.optimizer.operators

CoGroupWithSolutionSetSecondDescriptor(FieldList, FieldList) - Constructor for class org.apache.flink.optimizer.operators.CoGroupWithSolutionSetSecondDescriptor

collect(Channel, List<Channel>) - Method in class org.apache.flink.optimizer.traversals.BinaryUnionReplacer

combine(GlobalProperties, GlobalProperties) - Static method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

combine(LocalProperties, LocalProperties) - Static method in class org.apache.flink.optimizer.dataproperties.LocalProperties

compareTo(Costs) - Method in class org.apache.flink.optimizer.costs.Costs

The order of comparison is: network first, then disk, then CPU.

compile(Plan) - Method in class org.apache.flink.optimizer.Optimizer

Translates the given program to an OptimizedPlan, where all nodes have their local strategy assigned and all channels have a shipping strategy assigned.

compileJobGraph(OptimizedPlan) - Method in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator

Translates a OptimizedPlan into a JobGraph.

compileJobGraph(OptimizedPlan, JobID) - Method in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator

CompilerException - Exception in org.apache.flink.optimizer

An exception that is thrown by the Optimizer when encountering an illegal condition.

CompilerException() - Constructor for exception org.apache.flink.optimizer.CompilerException

Creates a compiler exception with no message and no cause.

CompilerException(String) - Constructor for exception org.apache.flink.optimizer.CompilerException

Creates a compiler exception with the given message and no cause.

CompilerException(String, Throwable) - Constructor for exception org.apache.flink.optimizer.CompilerException

Creates a compiler exception with the given message and cause.

CompilerException(Throwable) - Constructor for exception org.apache.flink.optimizer.CompilerException

Creates a compiler exception with the given cause and no message.

CompilerPostPassException - Exception in org.apache.flink.optimizer

An exception that is thrown by the Optimizer when encountering a problem during the optimizer post pass.

CompilerPostPassException() - Constructor for exception org.apache.flink.optimizer.CompilerPostPassException

Creates a post pass exception with no message and no cause.

CompilerPostPassException(String) - Constructor for exception org.apache.flink.optimizer.CompilerPostPassException

Creates a post pass exception with the given message and no cause.

CompilerPostPassException(String, Throwable) - Constructor for exception org.apache.flink.optimizer.CompilerPostPassException

Creates a post pass exception with the given message and cause.

CompilerPostPassException(Throwable) - Constructor for exception org.apache.flink.optimizer.CompilerPostPassException

Creates a post pass exception with the given cause and no message.

computeGlobalProperties(GlobalProperties) - Method in class org.apache.flink.optimizer.dag.PartitionNode.PartitionDescriptor

computeGlobalProperties(GlobalProperties) - Method in class org.apache.flink.optimizer.dag.SortPartitionNode.SortPartitionDescriptor

computeGlobalProperties(GlobalProperties) - Method in class org.apache.flink.optimizer.operators.AllGroupCombineProperties

computeGlobalProperties(GlobalProperties) - Method in class org.apache.flink.optimizer.operators.AllGroupReduceProperties

computeGlobalProperties(GlobalProperties) - Method in class org.apache.flink.optimizer.operators.AllGroupWithPartialPreGroupProperties

computeGlobalProperties(GlobalProperties) - Method in class org.apache.flink.optimizer.operators.AllReduceProperties

computeGlobalProperties(GlobalProperties) - Method in class org.apache.flink.optimizer.operators.FilterDescriptor

computeGlobalProperties(GlobalProperties) - Method in class org.apache.flink.optimizer.operators.FlatMapDescriptor

computeGlobalProperties(GlobalProperties) - Method in class org.apache.flink.optimizer.operators.GroupCombineProperties

computeGlobalProperties(GlobalProperties) - Method in class org.apache.flink.optimizer.operators.GroupReduceProperties

computeGlobalProperties(GlobalProperties) - Method in class org.apache.flink.optimizer.operators.GroupReduceWithCombineProperties

computeGlobalProperties(GlobalProperties) - Method in class org.apache.flink.optimizer.operators.MapDescriptor

computeGlobalProperties(GlobalProperties) - Method in class org.apache.flink.optimizer.operators.MapPartitionDescriptor

computeGlobalProperties(GlobalProperties) - Method in class org.apache.flink.optimizer.operators.NoOpDescriptor

computeGlobalProperties(GlobalProperties) - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorSingle

Returns the global properties which are present after the operator was applied on the provided global properties.

computeGlobalProperties(GlobalProperties) - Method in class org.apache.flink.optimizer.operators.PartialGroupProperties

computeGlobalProperties(GlobalProperties) - Method in class org.apache.flink.optimizer.operators.ReduceProperties

computeGlobalProperties(GlobalProperties) - Method in class org.apache.flink.optimizer.operators.SolutionSetDeltaOperator

computeGlobalProperties(GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.AbstractJoinDescriptor

computeGlobalProperties(GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.BinaryUnionOpDescriptor

computeGlobalProperties(GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.CartesianProductDescriptor

computeGlobalProperties(GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.CoGroupDescriptor

computeGlobalProperties(GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.CoGroupRawDescriptor

computeGlobalProperties(GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual

computeGlobalProperties(GlobalProperties, GlobalProperties) - Method in class org.apache.flink.optimizer.operators.UtilSinkJoinOpDescriptor

computeInterestingPropertiesForInputs(CostEstimator) - Method in class org.apache.flink.optimizer.dag.AbstractPartialSolutionNode

computeInterestingPropertiesForInputs(CostEstimator) - Method in class org.apache.flink.optimizer.dag.BinaryUnionNode

computeInterestingPropertiesForInputs(CostEstimator) - Method in class org.apache.flink.optimizer.dag.BulkIterationNode

computeInterestingPropertiesForInputs(CostEstimator) - Method in class org.apache.flink.optimizer.dag.DataSinkNode

computeInterestingPropertiesForInputs(CostEstimator) - Method in class org.apache.flink.optimizer.dag.DataSourceNode

computeInterestingPropertiesForInputs(CostEstimator) - Method in class org.apache.flink.optimizer.dag.OptimizerNode

Tells the node to compute the interesting properties for its inputs.

computeInterestingPropertiesForInputs(CostEstimator) - Method in class org.apache.flink.optimizer.dag.SingleInputNode

computeInterestingPropertiesForInputs(CostEstimator) - Method in class org.apache.flink.optimizer.dag.TwoInputNode

computeInterestingPropertiesForInputs(CostEstimator) - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode

computeLocalProperties(LocalProperties) - Method in class org.apache.flink.optimizer.dag.PartitionNode.PartitionDescriptor

computeLocalProperties(LocalProperties) - Method in class org.apache.flink.optimizer.dag.SortPartitionNode.SortPartitionDescriptor

computeLocalProperties(LocalProperties) - Method in class org.apache.flink.optimizer.operators.AllGroupCombineProperties

computeLocalProperties(LocalProperties) - Method in class org.apache.flink.optimizer.operators.AllGroupReduceProperties

computeLocalProperties(LocalProperties) - Method in class org.apache.flink.optimizer.operators.AllGroupWithPartialPreGroupProperties

computeLocalProperties(LocalProperties) - Method in class org.apache.flink.optimizer.operators.AllReduceProperties

computeLocalProperties(LocalProperties) - Method in class org.apache.flink.optimizer.operators.FilterDescriptor

computeLocalProperties(LocalProperties) - Method in class org.apache.flink.optimizer.operators.FlatMapDescriptor

computeLocalProperties(LocalProperties) - Method in class org.apache.flink.optimizer.operators.GroupCombineProperties

computeLocalProperties(LocalProperties) - Method in class org.apache.flink.optimizer.operators.GroupReduceProperties

computeLocalProperties(LocalProperties) - Method in class org.apache.flink.optimizer.operators.GroupReduceWithCombineProperties

computeLocalProperties(LocalProperties) - Method in class org.apache.flink.optimizer.operators.MapDescriptor

computeLocalProperties(LocalProperties) - Method in class org.apache.flink.optimizer.operators.MapPartitionDescriptor

computeLocalProperties(LocalProperties) - Method in class org.apache.flink.optimizer.operators.NoOpDescriptor

computeLocalProperties(LocalProperties) - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorSingle

Returns the local properties which are present after the operator was applied on the provided local properties.

computeLocalProperties(LocalProperties) - Method in class org.apache.flink.optimizer.operators.PartialGroupProperties

computeLocalProperties(LocalProperties) - Method in class org.apache.flink.optimizer.operators.ReduceProperties

computeLocalProperties(LocalProperties) - Method in class org.apache.flink.optimizer.operators.SolutionSetDeltaOperator

computeLocalProperties(LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.AbstractSortMergeJoinDescriptor

computeLocalProperties(LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.BinaryUnionOpDescriptor

computeLocalProperties(LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.CoGroupDescriptor

computeLocalProperties(LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.CoGroupRawDescriptor

computeLocalProperties(LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.CoGroupWithSolutionSetFirstDescriptor

computeLocalProperties(LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.CoGroupWithSolutionSetSecondDescriptor

computeLocalProperties(LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.CrossBlockOuterFirstDescriptor

computeLocalProperties(LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.CrossBlockOuterSecondDescriptor

computeLocalProperties(LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.CrossStreamOuterFirstDescriptor

computeLocalProperties(LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.CrossStreamOuterSecondDescriptor

computeLocalProperties(LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashFullOuterJoinBuildFirstDescriptor

computeLocalProperties(LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashFullOuterJoinBuildSecondDescriptor

computeLocalProperties(LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashJoinBuildFirstProperties

computeLocalProperties(LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashJoinBuildSecondProperties

computeLocalProperties(LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashLeftOuterJoinBuildFirstDescriptor

computeLocalProperties(LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashLeftOuterJoinBuildSecondDescriptor

computeLocalProperties(LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashRightOuterJoinBuildFirstDescriptor

computeLocalProperties(LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.HashRightOuterJoinBuildSecondDescriptor

computeLocalProperties(LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual

computeLocalProperties(LocalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.operators.UtilSinkJoinOpDescriptor

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.AbstractPartialSolutionNode

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.BinaryUnionNode

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.BulkIterationNode

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.CoGroupNode

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.CoGroupRawNode

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.CrossNode

We assume that the cardinality is the product of the input cardinalities and that the result width is the sum of the input widths.

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.DataSinkNode

Computes the estimated outputs for the data sink.

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.DataSourceNode

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.FilterNode

Computes the estimates for the Filter operator.

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.FlatMapNode

Computes the estimates for the FlatMap operator.

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.GroupCombineNode

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.GroupReduceNode

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.JoinNode

The default estimates build on the principle of inclusion: The smaller input key domain is included in the larger input key domain.

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.MapNode

Computes the estimates for the Map operator.

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.MapPartitionNode

Computes the estimates for the MapPartition operator.

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.NoOpNode

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.OptimizerNode

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.OuterJoinNode

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.PartitionNode

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.ReduceNode

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.SinkJoiner

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.SortPartitionNode

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.UnaryOperatorNode

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode

computeOperatorSpecificDefaultEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode.SingleRootJoiner

computeOutputEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.BinaryUnionNode

computeOutputEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.BulkPartialSolutionNode

computeOutputEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.OptimizerNode

Causes this node to compute its output estimates (such as number of rows, size in bytes) based on the inputs and the compiler hints.

computeOutputEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.SinkJoiner

computeOutputEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.SolutionSetNode

computeOutputEstimates(DataStatistics) - Method in class org.apache.flink.optimizer.dag.WorksetNode

computeUnclosedBranchStack() - Method in class org.apache.flink.optimizer.dag.BulkIterationNode

computeUnclosedBranchStack() - Method in class org.apache.flink.optimizer.dag.BulkPartialSolutionNode

computeUnclosedBranchStack() - Method in class org.apache.flink.optimizer.dag.DataSinkNode

computeUnclosedBranchStack() - Method in class org.apache.flink.optimizer.dag.DataSourceNode

computeUnclosedBranchStack() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

This method causes the node to compute the description of open branches in its sub-plan.

computeUnclosedBranchStack() - Method in class org.apache.flink.optimizer.dag.SingleInputNode

computeUnclosedBranchStack() - Method in class org.apache.flink.optimizer.dag.SinkJoiner

computeUnclosedBranchStack() - Method in class org.apache.flink.optimizer.dag.SolutionSetNode

computeUnclosedBranchStack() - Method in class org.apache.flink.optimizer.dag.TwoInputNode

computeUnclosedBranchStack() - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode

computeUnclosedBranchStack() - Method in class org.apache.flink.optimizer.dag.WorksetNode

computeUnclosedBranchStackForBroadcastInputs(List<OptimizerNode.UnclosedBranchDescriptor>) - Method in class org.apache.flink.optimizer.dag.OptimizerNode

computeUnionOfInterestingPropertiesFromSuccessors() - Method in class org.apache.flink.optimizer.dag.BinaryUnionNode

computeUnionOfInterestingPropertiesFromSuccessors() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

Computes all the interesting properties that are relevant to this node.

ConflictingFieldTypeInfoException - Exception in org.apache.flink.optimizer.postpass

ConflictingFieldTypeInfoException(int, Object, Object) - Constructor for exception org.apache.flink.optimizer.postpass.ConflictingFieldTypeInfoException

copyEstimates(OptimizerNode) - Method in class org.apache.flink.optimizer.dag.AbstractPartialSolutionNode

CostEstimator - Class in org.apache.flink.optimizer.costs

Abstract base class for a cost estimator.

CostEstimator() - Constructor for class org.apache.flink.optimizer.costs.CostEstimator

costOperator(PlanNode) - Method in class org.apache.flink.optimizer.costs.CostEstimator

This method computes the cost of an operator.

Costs - Class in org.apache.flink.optimizer.costs

Simple class to represent the costs of an operation.

Costs() - Constructor for class org.apache.flink.optimizer.costs.Costs

Default constructor.

Costs(double, double) - Constructor for class org.apache.flink.optimizer.costs.Costs

Creates a new costs object using the given values for the network and storage cost.

Costs(double, double, double) - Constructor for class org.apache.flink.optimizer.costs.Costs

Creates a new costs object using the given values for the network and storage cost.

costWeight - Variable in class org.apache.flink.optimizer.dag.OptimizerNode

createFinalPlan(List<SinkPlanNode>, String, Plan) - Method in class org.apache.flink.optimizer.traversals.PlanFinalizer

createOrderedFromSet(FieldSet) - Static method in class org.apache.flink.optimizer.util.Utils

createOrdering(FieldList) - Static method in class org.apache.flink.optimizer.util.Utils

createOrdering(FieldList, boolean[]) - Static method in class org.apache.flink.optimizer.util.Utils

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.dag.PartitionNode.PartitionDescriptor

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.dag.SortPartitionNode.SortPartitionDescriptor

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.AbstractJoinDescriptor

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.AllGroupCombineProperties

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.AllGroupReduceProperties

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.AllGroupWithPartialPreGroupProperties

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.AllReduceProperties

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.BinaryUnionOpDescriptor

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.CartesianProductDescriptor

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.CoGroupDescriptor

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.CoGroupRawDescriptor

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.FilterDescriptor

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.FlatMapDescriptor

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.GroupCombineProperties

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.GroupReduceProperties

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.GroupReduceWithCombineProperties

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.MapDescriptor

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.MapPartitionDescriptor

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.NoOpDescriptor

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorSingle

Returns a list of global properties that are required by this operator descriptor.

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.PartialGroupProperties

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.ReduceProperties

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.SolutionSetDeltaOperator

createPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.UtilSinkJoinOpDescriptor

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.dag.PartitionNode.PartitionDescriptor

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.dag.SortPartitionNode.SortPartitionDescriptor

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.AbstractSortMergeJoinDescriptor

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.AllGroupCombineProperties

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.AllGroupReduceProperties

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.AllGroupWithPartialPreGroupProperties

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.AllReduceProperties

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.BinaryUnionOpDescriptor

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.CartesianProductDescriptor

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.CoGroupDescriptor

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.CoGroupRawDescriptor

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.CoGroupWithSolutionSetFirstDescriptor

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.CoGroupWithSolutionSetSecondDescriptor

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.FilterDescriptor

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.FlatMapDescriptor

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.GroupCombineProperties

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.GroupReduceProperties

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.GroupReduceWithCombineProperties

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.HashFullOuterJoinBuildFirstDescriptor

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.HashFullOuterJoinBuildSecondDescriptor

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.HashJoinBuildFirstProperties

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.HashJoinBuildSecondProperties

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.HashLeftOuterJoinBuildFirstDescriptor

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.HashLeftOuterJoinBuildSecondDescriptor

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.HashRightOuterJoinBuildFirstDescriptor

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.HashRightOuterJoinBuildSecondDescriptor

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.MapDescriptor

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.MapPartitionDescriptor

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.NoOpDescriptor

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorSingle

Returns a list of local properties that are required by this operator descriptor.

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.PartialGroupProperties

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.ReduceProperties

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.SolutionSetDeltaOperator

createPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.UtilSinkJoinOpDescriptor

createPreOptimizedPlan(Plan) - Static method in class org.apache.flink.optimizer.Optimizer

This function performs only the first step to the compilation process - the creation of the optimizer representation of the plan.

CrossBlockOuterFirstDescriptor - Class in org.apache.flink.optimizer.operators

CrossBlockOuterFirstDescriptor() - Constructor for class org.apache.flink.optimizer.operators.CrossBlockOuterFirstDescriptor

CrossBlockOuterFirstDescriptor(boolean, boolean) - Constructor for class org.apache.flink.optimizer.operators.CrossBlockOuterFirstDescriptor

CrossBlockOuterSecondDescriptor - Class in org.apache.flink.optimizer.operators

CrossBlockOuterSecondDescriptor() - Constructor for class org.apache.flink.optimizer.operators.CrossBlockOuterSecondDescriptor

CrossBlockOuterSecondDescriptor(boolean, boolean) - Constructor for class org.apache.flink.optimizer.operators.CrossBlockOuterSecondDescriptor

CrossNode - Class in org.apache.flink.optimizer.dag

The Optimizer representation of a Cross (Cartesian product) operator.

CrossNode(CrossOperatorBase<?, ?, ?, ?>) - Constructor for class org.apache.flink.optimizer.dag.CrossNode

Creates a new CrossNode for the given operator.

CrossStreamOuterFirstDescriptor - Class in org.apache.flink.optimizer.operators

CrossStreamOuterFirstDescriptor() - Constructor for class org.apache.flink.optimizer.operators.CrossStreamOuterFirstDescriptor

CrossStreamOuterFirstDescriptor(boolean, boolean) - Constructor for class org.apache.flink.optimizer.operators.CrossStreamOuterFirstDescriptor

CrossStreamOuterSecondDescriptor - Class in org.apache.flink.optimizer.operators

CrossStreamOuterSecondDescriptor() - Constructor for class org.apache.flink.optimizer.operators.CrossStreamOuterSecondDescriptor

CrossStreamOuterSecondDescriptor(boolean, boolean) - Constructor for class org.apache.flink.optimizer.operators.CrossStreamOuterSecondDescriptor

cumulativeCosts - Variable in class org.apache.flink.optimizer.plan.PlanNode

CUSTOM_PARTITIONING - org.apache.flink.optimizer.dataproperties.PartitioningProperty

A custom partitioning, accompanied by a Partitioner.

D

DagConnection - Class in org.apache.flink.optimizer.dag

A connection between two operators.

DagConnection(OptimizerNode, ExecutionMode) - Constructor for class org.apache.flink.optimizer.dag.DagConnection

Constructor to create a result from an operator that is not consumed by another operator.

DagConnection(OptimizerNode, OptimizerNode, ExecutionMode) - Constructor for class org.apache.flink.optimizer.dag.DagConnection

Creates a new Connection between two nodes.

DagConnection(OptimizerNode, OptimizerNode, ShipStrategyType, ExecutionMode) - Constructor for class org.apache.flink.optimizer.dag.DagConnection

Creates a new Connection between two nodes.

DataSinkNode - Class in org.apache.flink.optimizer.dag

The Optimizer representation of a data sink.

DataSinkNode(GenericDataSinkBase<?>) - Constructor for class org.apache.flink.optimizer.dag.DataSinkNode

Creates a new DataSinkNode for the given sink operator.

DataSourceNode - Class in org.apache.flink.optimizer.dag

The optimizer's internal representation of a data source.

DataSourceNode(GenericDataSourceBase<?, ?>) - Constructor for class org.apache.flink.optimizer.dag.DataSourceNode

Creates a new DataSourceNode for the given contract.

DataStatistics - Class in org.apache.flink.optimizer

The collection of access methods that can be used to retrieve statistical information about the data processed in a job.

DataStatistics() - Constructor for class org.apache.flink.optimizer.DataStatistics

Creates a new statistics object, with an empty cache.

DefaultCostEstimator - Class in org.apache.flink.optimizer.costs

A default cost estimator that has access to basic size and cardinality estimates.

DefaultCostEstimator() - Constructor for class org.apache.flink.optimizer.costs.DefaultCostEstimator

divideBy(int) - Method in class org.apache.flink.optimizer.costs.Costs

driverKeys - Variable in class org.apache.flink.optimizer.plan.SingleInputPlanNode

driverSortOrders - Variable in class org.apache.flink.optimizer.plan.SingleInputPlanNode

dropTrivials() - Method in class org.apache.flink.optimizer.dataproperties.InterestingProperties

DualInputPlanNode - Class in org.apache.flink.optimizer.plan

DualInputPlanNode(OptimizerNode, String, Channel, Channel, DriverStrategy) - Constructor for class org.apache.flink.optimizer.plan.DualInputPlanNode

DualInputPlanNode(OptimizerNode, String, Channel, Channel, DriverStrategy, FieldList, FieldList) - Constructor for class org.apache.flink.optimizer.plan.DualInputPlanNode

DualInputPlanNode(OptimizerNode, String, Channel, Channel, DriverStrategy, FieldList, FieldList, boolean[]) - Constructor for class org.apache.flink.optimizer.plan.DualInputPlanNode

DumpableConnection<T extends DumpableNode<T>> - Interface in org.apache.flink.optimizer.plandump

DumpableNode<T extends DumpableNode<T>> - Interface in org.apache.flink.optimizer.plandump

dumpOptimizerPlanAsJSON(List<SinkPlanNode>, PrintWriter) - Method in class org.apache.flink.optimizer.plandump.PlanJSONDumpGenerator

dumpOptimizerPlanAsJSON(OptimizedPlan, File) - Method in class org.apache.flink.optimizer.plandump.PlanJSONDumpGenerator

dumpOptimizerPlanAsJSON(OptimizedPlan, PrintWriter) - Method in class org.apache.flink.optimizer.plandump.PlanJSONDumpGenerator

dumpPactPlanAsJSON(List<DataSinkNode>, PrintWriter) - Method in class org.apache.flink.optimizer.plandump.PlanJSONDumpGenerator

E

EMPTY - Static variable in class org.apache.flink.optimizer.dataproperties.LocalProperties

equals(Object) - Method in class org.apache.flink.optimizer.costs.Costs

equals(Object) - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

equals(Object) - Method in class org.apache.flink.optimizer.dataproperties.InterestingProperties

equals(Object) - Method in class org.apache.flink.optimizer.dataproperties.LocalProperties

equals(Object) - Method in class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties

equals(Object) - Method in class org.apache.flink.optimizer.dataproperties.RequestedLocalProperties

equals(Object) - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual.GlobalPropertiesPair

equals(Object) - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual.LocalPropertiesPair

estimatedNumRecords - Variable in class org.apache.flink.optimizer.dag.OptimizerNode

estimatedOutputSize - Variable in class org.apache.flink.optimizer.dag.OptimizerNode

EstimateProvider - Interface in org.apache.flink.optimizer.dag

Methods for operators / connections that provide estimated about data size and characteristics.

executeOnCollections(List<OUT>, List<OUT>, RuntimeContext, ExecutionConfig) - Method in class org.apache.flink.optimizer.util.NoOpBinaryUdfOp

executeOnCollections(List<OUT>, RuntimeContext, ExecutionConfig) - Method in class org.apache.flink.optimizer.util.NoOpUnaryUdfOp

ExecutionPlanJSONGenerator - Class in org.apache.flink.optimizer.plandump

Utility for extracting an execution plan (as JSON) from a given Plan.

ExecutionPlanJSONGenerator() - Constructor for class org.apache.flink.optimizer.plandump.ExecutionPlanJSONGenerator

F

filterByCodeAnnotations(OptimizerNode, int) - Method in class org.apache.flink.optimizer.dataproperties.InterestingProperties

filterBySemanticProperties(SemanticProperties, int) - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

Filters these GlobalProperties by the fields that are forwarded to the output as described by the SemanticProperties.

filterBySemanticProperties(SemanticProperties, int) - Method in class org.apache.flink.optimizer.dataproperties.LocalProperties

Filters these LocalProperties by the fields that are forwarded to the output as described by the SemanticProperties.

filterBySemanticProperties(SemanticProperties, int) - Method in class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties

Filters these properties by what can be preserved by the given SemanticProperties when propagated down to the given input.

filterBySemanticProperties(SemanticProperties, int) - Method in class org.apache.flink.optimizer.dataproperties.RequestedLocalProperties

Filters these properties by what can be preserved by the given SemanticProperties when propagated down to the given input.

FilterDescriptor - Class in org.apache.flink.optimizer.operators

FilterDescriptor() - Constructor for class org.apache.flink.optimizer.operators.FilterDescriptor

FilterNode - Class in org.apache.flink.optimizer.dag

The optimizer's internal representation of a Filter operator node.

FilterNode(FilterOperatorBase<?, ?>) - Constructor for class org.apache.flink.optimizer.dag.FilterNode

FlatMapDescriptor - Class in org.apache.flink.optimizer.operators

FlatMapDescriptor() - Constructor for class org.apache.flink.optimizer.operators.FlatMapDescriptor

FlatMapNode - Class in org.apache.flink.optimizer.dag

The optimizer's internal representation of a FlatMap operator node.

FlatMapNode(FlatMapOperatorBase<?, ?, ?>) - Constructor for class org.apache.flink.optimizer.dag.FlatMapNode

FORCED_REBALANCED - org.apache.flink.optimizer.dataproperties.PartitioningProperty

A forced even re-balancing.

forGrouping(FieldList) - Static method in class org.apache.flink.optimizer.dataproperties.LocalProperties

formatNumber(double) - Static method in class org.apache.flink.optimizer.plandump.PlanJSONDumpGenerator

formatNumber(double, String) - Static method in class org.apache.flink.optimizer.plandump.PlanJSONDumpGenerator

forOrdering(Ordering) - Static method in class org.apache.flink.optimizer.dataproperties.LocalProperties

FOUND_SOURCE - org.apache.flink.optimizer.plan.PlanNode.SourceAndDamReport

FOUND_SOURCE_AND_DAM - org.apache.flink.optimizer.plan.PlanNode.SourceAndDamReport

FULL_REPLICATION - org.apache.flink.optimizer.dataproperties.PartitioningProperty

Full replication of the data to each parallel instance.

G

getAllNodes() - Method in class org.apache.flink.optimizer.plan.OptimizedPlan

Gets all the nodes from this OptimizedPlan.

getAlternativePlans(CostEstimator) - Method in class org.apache.flink.optimizer.dag.AbstractPartialSolutionNode

getAlternativePlans(CostEstimator) - Method in class org.apache.flink.optimizer.dag.BinaryUnionNode

getAlternativePlans(CostEstimator) - Method in class org.apache.flink.optimizer.dag.DataSinkNode

getAlternativePlans(CostEstimator) - Method in class org.apache.flink.optimizer.dag.DataSourceNode

getAlternativePlans(CostEstimator) - Method in class org.apache.flink.optimizer.dag.OptimizerNode

Computes the plan alternatives for this node, an implicitly for all nodes that are children of this node.

getAlternativePlans(CostEstimator) - Method in class org.apache.flink.optimizer.dag.SingleInputNode

getAlternativePlans(CostEstimator) - Method in class org.apache.flink.optimizer.dag.TwoInputNode

getBaseStatistics(String) - Method in class org.apache.flink.optimizer.DataStatistics

Gets the base statistics for the input identified by the given identifier.

getBranchesForParent(DagConnection) - Method in class org.apache.flink.optimizer.dag.DataSinkNode

getBranchesForParent(DagConnection) - Method in class org.apache.flink.optimizer.dag.OptimizerNode

getBranchingNode() - Method in class org.apache.flink.optimizer.dag.OptimizerNode.UnclosedBranchDescriptor

getBranchPlan() - Method in class org.apache.flink.optimizer.plan.PlanNode

getBroadcastConnectionNames() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

Return the list of names associated with broadcast inputs for this node.

getBroadcastConnections() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

Return the list of inputs associated with broadcast variables for this node.

getBroadcastInputs() - Method in class org.apache.flink.optimizer.plan.PlanNode

Gets a list of all broadcast inputs attached to this node.

getCandidateAtBranchPoint(OptimizerNode) - Method in class org.apache.flink.optimizer.plan.PlanNode

getClosedBranchingNodes() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

getCombinerUtilityNode() - Method in class org.apache.flink.optimizer.dag.GroupReduceNode

getCombinerUtilityNode() - Method in class org.apache.flink.optimizer.dag.ReduceNode

getComparator(int) - Method in class org.apache.flink.optimizer.plan.SingleInputPlanNode

Gets the specified comparator from this PlanNode.

getComparator1() - Method in class org.apache.flink.optimizer.plan.DualInputPlanNode

getComparator2() - Method in class org.apache.flink.optimizer.plan.DualInputPlanNode

getContainingIterationNode() - Method in class org.apache.flink.optimizer.plan.BulkPartialSolutionPlanNode

getContainingIterationNode() - Method in class org.apache.flink.optimizer.plan.SolutionSetPlanNode

getContainingIterationNode() - Method in class org.apache.flink.optimizer.plan.WorksetPlanNode

getCostWeight() - Method in class org.apache.flink.optimizer.dag.BulkIterationNode

getCostWeight() - Method in class org.apache.flink.optimizer.dag.DagConnection

getCostWeight() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

getCostWeight() - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode

getCostWeight() - Method in class org.apache.flink.optimizer.plan.Channel

getCostWeight() - Method in class org.apache.flink.optimizer.plan.PlanNode

getCpuCost() - Method in class org.apache.flink.optimizer.costs.Costs

Gets the cost for the CPU.

getCumulativeCosts() - Method in class org.apache.flink.optimizer.plan.PlanNode

Gets the cumulative costs of this nose.

getCumulativeCostsShare() - Method in class org.apache.flink.optimizer.plan.PlanNode

getCurrentPartialSolutionPlanNode() - Method in class org.apache.flink.optimizer.dag.BulkPartialSolutionNode

getCurrentSolutionSetPlanNode() - Method in class org.apache.flink.optimizer.dag.SolutionSetNode

getCurrentWorksetPlanNode() - Method in class org.apache.flink.optimizer.dag.WorksetNode

getCustomPartitioner() - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

getCustomPartitioner() - Method in class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties

Gets the custom partitioner associated with these properties.

getDataDistribution() - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

getDataDistribution() - Method in class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties

Gets the data distribution.

getDataDistribution() - Method in class org.apache.flink.optimizer.plan.Channel

getDataExchangeMode() - Method in class org.apache.flink.optimizer.dag.DagConnection

Gets the data exchange mode to use for this connection.

getDataExchangeMode() - Method in class org.apache.flink.optimizer.plan.Channel

Gets the data exchange mode (batch / pipelined) to use for the data exchange of this channel.

getDataSinks() - Method in class org.apache.flink.optimizer.plan.OptimizedPlan

Gets the data sinks from this OptimizedPlan.

getDataSinks(List<SinkPlanNode>) - Method in class org.apache.flink.optimizer.plan.SinkJoinerPlanNode

getDataSourceNode() - Method in class org.apache.flink.optimizer.plan.SourcePlanNode

getDataSources() - Method in class org.apache.flink.optimizer.plan.OptimizedPlan

Gets the data sources from this OptimizedPlan.

getDefaultParallelism() - Method in class org.apache.flink.optimizer.Optimizer

getDirections(Ordering, int) - Static method in class org.apache.flink.optimizer.util.Utils

getDiskCost() - Method in class org.apache.flink.optimizer.costs.Costs

Gets the costs for disk.

getDriverStrategy() - Method in class org.apache.flink.optimizer.plan.PlanNode

Gets the driver strategy from this node.

getDumpableInputs() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

getDumpableInputs() - Method in class org.apache.flink.optimizer.plan.PlanNode

getDumpableInputs() - Method in interface org.apache.flink.optimizer.plandump.DumpableNode

getEstimatedAvgWidthPerOutputRecord() - Method in class org.apache.flink.optimizer.dag.DagConnection

getEstimatedAvgWidthPerOutputRecord() - Method in interface org.apache.flink.optimizer.dag.EstimateProvider

Gets the estimated number of bytes per record.

getEstimatedAvgWidthPerOutputRecord() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

getEstimatedAvgWidthPerOutputRecord() - Method in class org.apache.flink.optimizer.plan.Channel

getEstimatedNumRecords() - Method in class org.apache.flink.optimizer.dag.DagConnection

getEstimatedNumRecords() - Method in interface org.apache.flink.optimizer.dag.EstimateProvider

Gets the estimated number of records in the output of this node.

getEstimatedNumRecords() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

getEstimatedNumRecords() - Method in class org.apache.flink.optimizer.plan.Channel

getEstimatedOutputSize() - Method in class org.apache.flink.optimizer.dag.DagConnection

getEstimatedOutputSize() - Method in interface org.apache.flink.optimizer.dag.EstimateProvider

Gets the estimated output size from this node.

getEstimatedOutputSize() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

getEstimatedOutputSize() - Method in class org.apache.flink.optimizer.plan.Channel

getExecutionPlan(Plan) - Method in class org.apache.flink.optimizer.plandump.ExecutionPlanJSONGenerator

getFieldNumber() - Method in exception org.apache.flink.optimizer.postpass.ConflictingFieldTypeInfoException

getFieldNumber() - Method in exception org.apache.flink.optimizer.postpass.MissingFieldTypeInfoException

getFirstIncomingConnection() - Method in class org.apache.flink.optimizer.dag.TwoInputNode

Gets the DagConnection through which this node receives its first input.

getFirstPredecessorNode() - Method in class org.apache.flink.optimizer.dag.TwoInputNode

getForwardingSourceField(int, int) - Method in class org.apache.flink.optimizer.dag.BinaryUnionNode.UnionSemanticProperties

getForwardingTargetFields(int, int) - Method in class org.apache.flink.optimizer.dag.BinaryUnionNode.UnionSemanticProperties

getGlobalProperties() - Method in class org.apache.flink.optimizer.dataproperties.InterestingProperties

Gets the interesting global properties.

getGlobalProperties() - Method in class org.apache.flink.optimizer.plan.Channel

getGlobalProperties() - Method in class org.apache.flink.optimizer.plan.PlanNode

Gets the global properties from this PlanNode.

getGroupedFields() - Method in class org.apache.flink.optimizer.dataproperties.LocalProperties

Gets the grouped fields.

getGroupedFields() - Method in class org.apache.flink.optimizer.dataproperties.RequestedLocalProperties

Gets the grouped fields.

getGuaranteedAvailableMemory() - Method in class org.apache.flink.optimizer.plan.PlanNode

getHeuristicCpuCost() - Method in class org.apache.flink.optimizer.costs.Costs

Gets the heuristic cost for the CPU.

getHeuristicDiskCost() - Method in class org.apache.flink.optimizer.costs.Costs

Gets the heuristic costs for disk.

getHeuristicNetworkCost() - Method in class org.apache.flink.optimizer.costs.Costs

Gets the heuristic network cost.

getId() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

Gets the ID of this node.

getIncomingConnection() - Method in class org.apache.flink.optimizer.dag.SingleInputNode

Gets the input of this operator.

getIncomingConnections() - Method in class org.apache.flink.optimizer.dag.AbstractPartialSolutionNode

getIncomingConnections() - Method in class org.apache.flink.optimizer.dag.DataSinkNode

getIncomingConnections() - Method in class org.apache.flink.optimizer.dag.DataSourceNode

getIncomingConnections() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

Gets all incoming connections of this node.

getIncomingConnections() - Method in class org.apache.flink.optimizer.dag.SingleInputNode

getIncomingConnections() - Method in class org.apache.flink.optimizer.dag.TwoInputNode

getInitialSolutionSetInput() - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

getInitialSolutionSetPredecessorNode() - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode

getInitialWorksetInput() - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

getInitialWorksetPredecessorNode() - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode

getInput() - Method in class org.apache.flink.optimizer.plan.SingleInputPlanNode

Gets the input channel to this node.

getInput1() - Method in class org.apache.flink.optimizer.plan.DualInputPlanNode

Gets the first input channel to this node.

getInput2() - Method in class org.apache.flink.optimizer.plan.DualInputPlanNode

Gets the second input channel to this node.

getInputConnection() - Method in class org.apache.flink.optimizer.dag.DataSinkNode

Gets the input of the sink.

getInputs() - Method in class org.apache.flink.optimizer.plan.BulkPartialSolutionPlanNode

getInputs() - Method in class org.apache.flink.optimizer.plan.DualInputPlanNode

getInputs() - Method in class org.apache.flink.optimizer.plan.NAryUnionPlanNode

getInputs() - Method in class org.apache.flink.optimizer.plan.PlanNode

getInputs() - Method in class org.apache.flink.optimizer.plan.SingleInputPlanNode

getInputs() - Method in class org.apache.flink.optimizer.plan.SolutionSetPlanNode

getInputs() - Method in class org.apache.flink.optimizer.plan.SourcePlanNode

getInputs() - Method in class org.apache.flink.optimizer.plan.WorksetPlanNode

getInterestingProperties() - Method in class org.apache.flink.optimizer.dag.DagConnection

Gets the interesting properties object for this pact connection.

getInterestingProperties() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

Gets the properties that are interesting for this node to produce.

getIterationContract() - Method in class org.apache.flink.optimizer.dag.BulkIterationNode

getIterationContract() - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode

getIterationNode() - Method in class org.apache.flink.optimizer.dag.AbstractPartialSolutionNode

getIterationNode() - Method in class org.apache.flink.optimizer.dag.BulkPartialSolutionNode

getIterationNode() - Method in class org.apache.flink.optimizer.dag.SolutionSetNode

getIterationNode() - Method in class org.apache.flink.optimizer.dag.WorksetNode

getIterationNode() - Method in class org.apache.flink.optimizer.plan.BulkIterationPlanNode

getIterationNode() - Method in interface org.apache.flink.optimizer.plan.IterationPlanNode

getIterationNode() - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

getJobName() - Method in class org.apache.flink.optimizer.plan.OptimizedPlan

Returns the name of the program.

getJoinedPathsVector() - Method in class org.apache.flink.optimizer.dag.OptimizerNode.UnclosedBranchDescriptor

getKeys(int) - Method in class org.apache.flink.optimizer.plan.SingleInputPlanNode

Gets the key field indexes for the specified driver comparator.

getKeysForInput1() - Method in class org.apache.flink.optimizer.plan.DualInputPlanNode

getKeysForInput2() - Method in class org.apache.flink.optimizer.plan.DualInputPlanNode

getListOfInputs() - Method in class org.apache.flink.optimizer.plan.NAryUnionPlanNode

getLocalProperties() - Method in class org.apache.flink.optimizer.dataproperties.InterestingProperties

Gets the interesting local properties.

getLocalProperties() - Method in class org.apache.flink.optimizer.plan.Channel

getLocalProperties() - Method in class org.apache.flink.optimizer.plan.PlanNode

Gets the local properties from this PlanNode.

getLocalStrategy() - Method in class org.apache.flink.optimizer.plan.Channel

getLocalStrategyComparator() - Method in class org.apache.flink.optimizer.plan.Channel

Gets the local strategy comparator from this Channel.

getLocalStrategyKeys() - Method in class org.apache.flink.optimizer.plan.Channel

getLocalStrategySortOrder() - Method in class org.apache.flink.optimizer.plan.Channel

getLocalStrategyString(LocalStrategy) - Static method in class org.apache.flink.optimizer.plantranslate.JsonMapper

getMaterializationMode() - Method in class org.apache.flink.optimizer.dag.DagConnection

getMaxDepth() - Method in class org.apache.flink.optimizer.dag.DagConnection

getMaxDepth() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

getMaxDepth() - Method in class org.apache.flink.optimizer.plan.Channel

getMemoryConsumerWeight() - Method in class org.apache.flink.optimizer.plan.BinaryUnionPlanNode

getMemoryConsumerWeight() - Method in class org.apache.flink.optimizer.plan.BulkIterationPlanNode

getMemoryConsumerWeight() - Method in class org.apache.flink.optimizer.plan.PlanNode

getMemoryConsumerWeight() - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

getMinimalMemoryAcrossAllSubTasks() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

Gets the amount of memory that all subtasks of this task have jointly available.

getMinResources() - Method in class org.apache.flink.optimizer.plan.PlanNode

getName() - Method in class org.apache.flink.optimizer.plan.NamedChannel

getNetworkCost() - Method in class org.apache.flink.optimizer.costs.Costs

Gets the network cost.

getNewType() - Method in exception org.apache.flink.optimizer.postpass.ConflictingFieldTypeInfoException

getNextPartialSolution() - Method in class org.apache.flink.optimizer.dag.BulkIterationNode

Gets the nextPartialSolution from this BulkIterationNode.

getNextWorkset() - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode

getNextWorkSetPlanNode() - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

getNodeCosts() - Method in class org.apache.flink.optimizer.plan.PlanNode

Gets the costs incurred by this node.

getNodeName() - Method in class org.apache.flink.optimizer.operators.AbstractSortMergeJoinDescriptor

getNodeName() - Method in class org.apache.flink.optimizer.operators.SortMergeFullOuterJoinDescriptor

getNodeName() - Method in class org.apache.flink.optimizer.operators.SortMergeInnerJoinDescriptor

getNodeName() - Method in class org.apache.flink.optimizer.operators.SortMergeLeftOuterJoinDescriptor

getNodeName() - Method in class org.apache.flink.optimizer.operators.SortMergeRightOuterJoinDescriptor

getNodeName() - Method in class org.apache.flink.optimizer.plan.PlanNode

Gets the name of the plan node.

getOpenBranches() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

getOperator() - Method in class org.apache.flink.optimizer.dag.BulkPartialSolutionNode

Gets the operator (here the BulkIterationBase.PartialSolutionPlaceHolder) that is represented by this optimizer node.

getOperator() - Method in class org.apache.flink.optimizer.dag.CoGroupNode

Gets the operator for this CoGroup node.

getOperator() - Method in class org.apache.flink.optimizer.dag.CoGroupRawNode

Gets the operator for this CoGroup node.

getOperator() - Method in class org.apache.flink.optimizer.dag.CrossNode

getOperator() - Method in class org.apache.flink.optimizer.dag.DataSinkNode

Gets the operator for which this optimizer sink node was created.

getOperator() - Method in class org.apache.flink.optimizer.dag.DataSourceNode

Gets the contract object for this data source node.

getOperator() - Method in class org.apache.flink.optimizer.dag.FilterNode

getOperator() - Method in class org.apache.flink.optimizer.dag.FlatMapNode

getOperator() - Method in class org.apache.flink.optimizer.dag.GroupCombineNode

Gets the operator represented by this optimizer node.

getOperator() - Method in class org.apache.flink.optimizer.dag.GroupReduceNode

Gets the operator represented by this optimizer node.

getOperator() - Method in class org.apache.flink.optimizer.dag.JoinNode

Gets the contract object for this match node.

getOperator() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

Gets the operator represented by this optimizer node.

getOperator() - Method in class org.apache.flink.optimizer.dag.OuterJoinNode

getOperator() - Method in class org.apache.flink.optimizer.dag.PartitionNode

getOperator() - Method in class org.apache.flink.optimizer.dag.ReduceNode

getOperator() - Method in class org.apache.flink.optimizer.dag.SingleInputNode

getOperator() - Method in class org.apache.flink.optimizer.dag.SolutionSetNode

Gets the contract object for this data source node.

getOperator() - Method in class org.apache.flink.optimizer.dag.SortPartitionNode

getOperator() - Method in class org.apache.flink.optimizer.dag.TwoInputNode

getOperator() - Method in class org.apache.flink.optimizer.dag.WorksetNode

Gets the contract object for this data source node.

getOperatorInfo() - Method in class org.apache.flink.optimizer.util.NoOpUnaryUdfOp

getOperatorName() - Method in class org.apache.flink.optimizer.dag.BinaryUnionNode

getOperatorName() - Method in class org.apache.flink.optimizer.dag.BulkIterationNode

getOperatorName() - Method in class org.apache.flink.optimizer.dag.BulkPartialSolutionNode

getOperatorName() - Method in class org.apache.flink.optimizer.dag.CoGroupNode

getOperatorName() - Method in class org.apache.flink.optimizer.dag.CoGroupRawNode

getOperatorName() - Method in class org.apache.flink.optimizer.dag.CrossNode

getOperatorName() - Method in class org.apache.flink.optimizer.dag.DataSinkNode

getOperatorName() - Method in class org.apache.flink.optimizer.dag.DataSourceNode

getOperatorName() - Method in class org.apache.flink.optimizer.dag.FilterNode

getOperatorName() - Method in class org.apache.flink.optimizer.dag.FlatMapNode

getOperatorName() - Method in class org.apache.flink.optimizer.dag.GroupCombineNode

getOperatorName() - Method in class org.apache.flink.optimizer.dag.GroupReduceNode

getOperatorName() - Method in class org.apache.flink.optimizer.dag.JoinNode

getOperatorName() - Method in class org.apache.flink.optimizer.dag.MapNode

getOperatorName() - Method in class org.apache.flink.optimizer.dag.MapPartitionNode

getOperatorName() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

Gets the name of this node, which is the name of the function/operator, or data source / data sink.

getOperatorName() - Method in class org.apache.flink.optimizer.dag.OuterJoinNode

getOperatorName() - Method in class org.apache.flink.optimizer.dag.PartitionNode

getOperatorName() - Method in class org.apache.flink.optimizer.dag.ReduceNode

getOperatorName() - Method in class org.apache.flink.optimizer.dag.SinkJoiner

getOperatorName() - Method in class org.apache.flink.optimizer.dag.SolutionSetNode

getOperatorName() - Method in class org.apache.flink.optimizer.dag.SortPartitionNode

getOperatorName() - Method in class org.apache.flink.optimizer.dag.UnaryOperatorNode

getOperatorName() - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode

getOperatorName() - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode.SingleRootJoiner

getOperatorName() - Method in class org.apache.flink.optimizer.dag.WorksetNode

getOperatorStrategyString(DriverStrategy) - Static method in class org.apache.flink.optimizer.plantranslate.JsonMapper

getOperatorStrategyString(DriverStrategy, String, String) - Static method in class org.apache.flink.optimizer.plantranslate.JsonMapper

getOptimizerNode() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

getOptimizerNode() - Method in class org.apache.flink.optimizer.plan.BinaryUnionPlanNode

getOptimizerNode() - Method in class org.apache.flink.optimizer.plan.PlanNode

getOptimizerNode() - Method in interface org.apache.flink.optimizer.plandump.DumpableNode

getOptimizerPlanAsJSON(OptimizedPlan) - Method in class org.apache.flink.optimizer.plandump.PlanJSONDumpGenerator

getOptimizerPropertiesJson(JsonFactory, PlanNode) - Static method in class org.apache.flink.optimizer.plantranslate.JsonMapper

getOrdering() - Method in class org.apache.flink.optimizer.dataproperties.LocalProperties

Gets the key order.

getOrdering() - Method in class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties

Gets the key order.

getOrdering() - Method in class org.apache.flink.optimizer.dataproperties.RequestedLocalProperties

Gets the key order.

getOriginalOptimizerNode() - Method in class org.apache.flink.optimizer.plan.PlanNode

Gets the node from the optimizer DAG for which this plan candidate node was created.

getOriginalPlan() - Method in class org.apache.flink.optimizer.plan.OptimizedPlan

Gets the original program's dataflow plan from which this optimized plan was created.

getOutgoingChannels() - Method in class org.apache.flink.optimizer.plan.PlanNode

Gets a list of all outgoing channels leading to successors.

getOutgoingConnections() - Method in class org.apache.flink.optimizer.dag.DataSinkNode

Gets all outgoing connections, which is an empty set for the data sink.

getOutgoingConnections() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

The list of outgoing connections from this node to succeeding tasks.

getOutgoingConnections() - Method in class org.apache.flink.optimizer.dag.SinkJoiner

getPactPlanAsJSON(List<DataSinkNode>) - Method in class org.apache.flink.optimizer.plandump.PlanJSONDumpGenerator

getPairComparator() - Method in class org.apache.flink.optimizer.plan.DualInputPlanNode

getParallelism() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

Gets the parallelism for the operator represented by this optimizer node.

getParallelism() - Method in class org.apache.flink.optimizer.plan.PlanNode

getPartialSolution() - Method in class org.apache.flink.optimizer.dag.BulkIterationNode

Gets the partialSolution from this BulkIterationNode.

getPartialSolutionNode() - Method in class org.apache.flink.optimizer.plan.BulkPartialSolutionPlanNode

getPartialSolutionPlanNode() - Method in class org.apache.flink.optimizer.plan.BulkIterationPlanNode

getPartitionedFields() - Method in class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties

Gets the fields on which the data is partitioned.

getPartitioner() - Method in class org.apache.flink.optimizer.plan.Channel

getPartitioning() - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

getPartitioning() - Method in class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties

Gets the partitioning property.

getPartitioningFields() - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

getPartitioningOrdering() - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

getPlanNode() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

getPlanNode() - Method in class org.apache.flink.optimizer.plan.PlanNode

getPlanNode() - Method in interface org.apache.flink.optimizer.plandump.DumpableNode

getPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual

getPossibleGlobalProperties() - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorSingle

getPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual

getPossibleLocalProperties() - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorSingle

getPossibleProperties() - Method in class org.apache.flink.optimizer.dag.BinaryUnionNode

getPossibleProperties() - Method in class org.apache.flink.optimizer.dag.BulkIterationNode

getPossibleProperties() - Method in class org.apache.flink.optimizer.dag.CoGroupNode

getPossibleProperties() - Method in class org.apache.flink.optimizer.dag.CoGroupRawNode

getPossibleProperties() - Method in class org.apache.flink.optimizer.dag.CrossNode

getPossibleProperties() - Method in class org.apache.flink.optimizer.dag.FilterNode

getPossibleProperties() - Method in class org.apache.flink.optimizer.dag.FlatMapNode

getPossibleProperties() - Method in class org.apache.flink.optimizer.dag.GroupCombineNode

getPossibleProperties() - Method in class org.apache.flink.optimizer.dag.GroupReduceNode

getPossibleProperties() - Method in class org.apache.flink.optimizer.dag.JoinNode

getPossibleProperties() - Method in class org.apache.flink.optimizer.dag.MapNode

getPossibleProperties() - Method in class org.apache.flink.optimizer.dag.MapPartitionNode

getPossibleProperties() - Method in class org.apache.flink.optimizer.dag.OuterJoinNode

getPossibleProperties() - Method in class org.apache.flink.optimizer.dag.PartitionNode

getPossibleProperties() - Method in class org.apache.flink.optimizer.dag.ReduceNode

getPossibleProperties() - Method in class org.apache.flink.optimizer.dag.SingleInputNode

getPossibleProperties() - Method in class org.apache.flink.optimizer.dag.SinkJoiner

getPossibleProperties() - Method in class org.apache.flink.optimizer.dag.SortPartitionNode

getPossibleProperties() - Method in class org.apache.flink.optimizer.dag.TwoInputNode

getPossibleProperties() - Method in class org.apache.flink.optimizer.dag.UnaryOperatorNode

getPossibleProperties() - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode

getPossibleProperties() - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode.SingleRootJoiner

getPredecessor() - Method in class org.apache.flink.optimizer.plan.SingleInputPlanNode

Gets the predecessor of this node, i.e.

getPredecessorNode() - Method in class org.apache.flink.optimizer.dag.DataSinkNode

Gets the predecessor of this node.

getPredecessorNode() - Method in class org.apache.flink.optimizer.dag.SingleInputNode

Gets the predecessor of this node.

getPredecessors() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

getPredecessors() - Method in class org.apache.flink.optimizer.plan.BulkPartialSolutionPlanNode

getPredecessors() - Method in class org.apache.flink.optimizer.plan.DualInputPlanNode

getPredecessors() - Method in class org.apache.flink.optimizer.plan.NAryUnionPlanNode

getPredecessors() - Method in class org.apache.flink.optimizer.plan.PlanNode

getPredecessors() - Method in class org.apache.flink.optimizer.plan.SingleInputPlanNode

getPredecessors() - Method in class org.apache.flink.optimizer.plan.SolutionSetPlanNode

getPredecessors() - Method in class org.apache.flink.optimizer.plan.SourcePlanNode

getPredecessors() - Method in class org.apache.flink.optimizer.plan.WorksetPlanNode

getPredecessors() - Method in interface org.apache.flink.optimizer.plandump.DumpableNode

Gets an iterator over the predecessors.

getPreferredResources() - Method in class org.apache.flink.optimizer.plan.PlanNode

getPreviousType() - Method in exception org.apache.flink.optimizer.postpass.ConflictingFieldTypeInfoException

getProgramOperator() - Method in class org.apache.flink.optimizer.plan.PlanNode

Gets the program operator that this node represents in the plan.

getProperties1() - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual.GlobalPropertiesPair

getProperties1() - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual.LocalPropertiesPair

getProperties2() - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual.GlobalPropertiesPair

getProperties2() - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual.LocalPropertiesPair

getReadFields(int) - Method in class org.apache.flink.optimizer.dag.BinaryUnionNode.UnionSemanticProperties

getRelativeMemoryLocalStrategy() - Method in class org.apache.flink.optimizer.plan.Channel

getRelativeMemoryPerSubTask() - Method in class org.apache.flink.optimizer.plan.PlanNode

Gets the memory dedicated to each sub-task for this node.

getRelativeTempMemory() - Method in class org.apache.flink.optimizer.plan.Channel

Gets the memory for materializing the channel's result from this Channel.

getReplicationFactor() - Method in class org.apache.flink.optimizer.plan.Channel

Returns the replication factor of the connection.

getRequiredGlobalProps() - Method in class org.apache.flink.optimizer.plan.Channel

getRequiredLocalProps() - Method in class org.apache.flink.optimizer.plan.Channel

getRootOfStepFunction() - Method in class org.apache.flink.optimizer.plan.BulkIterationPlanNode

getRootOfTerminationCriterion() - Method in class org.apache.flink.optimizer.plan.BulkIterationPlanNode

getSecondIncomingConnection() - Method in class org.apache.flink.optimizer.dag.TwoInputNode

Gets the DagConnection through which this node receives its second input.

getSecondPredecessorNode() - Method in class org.apache.flink.optimizer.dag.TwoInputNode

getSemanticProperties() - Method in class org.apache.flink.optimizer.dag.AbstractPartialSolutionNode

getSemanticProperties() - Method in class org.apache.flink.optimizer.dag.BinaryUnionNode

getSemanticProperties() - Method in class org.apache.flink.optimizer.dag.BulkIterationNode

getSemanticProperties() - Method in class org.apache.flink.optimizer.dag.DataSinkNode

getSemanticProperties() - Method in class org.apache.flink.optimizer.dag.DataSourceNode

getSemanticProperties() - Method in class org.apache.flink.optimizer.dag.FilterNode

getSemanticProperties() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

getSemanticProperties() - Method in class org.apache.flink.optimizer.dag.PartitionNode

getSemanticProperties() - Method in class org.apache.flink.optimizer.dag.SingleInputNode

getSemanticProperties() - Method in class org.apache.flink.optimizer.dag.SortPartitionNode

getSemanticProperties() - Method in class org.apache.flink.optimizer.dag.TwoInputNode

getSemanticProperties() - Method in class org.apache.flink.optimizer.dag.UnaryOperatorNode

getSemanticProperties() - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode

getSemanticPropertiesForGlobalPropertyFiltering() - Method in class org.apache.flink.optimizer.dag.SingleInputNode

getSemanticPropertiesForGlobalPropertyFiltering() - Method in class org.apache.flink.optimizer.dag.TwoInputNode

getSemanticPropertiesForLocalPropertyFiltering() - Method in class org.apache.flink.optimizer.dag.CoGroupNode

getSemanticPropertiesForLocalPropertyFiltering() - Method in class org.apache.flink.optimizer.dag.GroupCombineNode

getSemanticPropertiesForLocalPropertyFiltering() - Method in class org.apache.flink.optimizer.dag.GroupReduceNode

getSemanticPropertiesForLocalPropertyFiltering() - Method in class org.apache.flink.optimizer.dag.MapPartitionNode

getSemanticPropertiesForLocalPropertyFiltering() - Method in class org.apache.flink.optimizer.dag.SingleInputNode

getSemanticPropertiesForLocalPropertyFiltering() - Method in class org.apache.flink.optimizer.dag.TwoInputNode

getSerializer() - Method in class org.apache.flink.optimizer.plan.Channel

Gets the serializer from this Channel.

getSerializer() - Method in class org.apache.flink.optimizer.plan.SourcePlanNode

Gets the serializer from this PlanNode.

getSerializerForIterationChannel() - Method in class org.apache.flink.optimizer.plan.BulkIterationPlanNode

getSerializerForIterationChannel() - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

getShipComparator(Channel, ExecutionConfig) - Static method in class org.apache.flink.optimizer.util.Utils

getShipStrategy() - Method in class org.apache.flink.optimizer.dag.DagConnection

Gets the shipping strategy for this connection.

getShipStrategy() - Method in class org.apache.flink.optimizer.plan.Channel

getShipStrategy() - Method in interface org.apache.flink.optimizer.plandump.DumpableConnection

getShipStrategyComparator() - Method in class org.apache.flink.optimizer.plan.Channel

Gets the ship strategy comparator from this Channel.

getShipStrategyKeys() - Method in class org.apache.flink.optimizer.plan.Channel

getShipStrategySortOrder() - Method in class org.apache.flink.optimizer.plan.Channel

getShipStrategyString(ShipStrategyType) - Static method in class org.apache.flink.optimizer.plantranslate.JsonMapper

getSingleInputNode() - Method in class org.apache.flink.optimizer.plan.SingleInputPlanNode

getSingleRootOfStepFunction() - Method in class org.apache.flink.optimizer.dag.BulkIterationNode

getSingleRootOfStepFunction() - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode

getSinkNode() - Method in class org.apache.flink.optimizer.plan.SinkPlanNode

getSinks() - Method in class org.apache.flink.optimizer.traversals.GraphCreatingVisitor

getSolutionSetComparator() - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

getSolutionSetDelta() - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode

getSolutionSetDeltaPlanNode() - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

getSolutionSetKeyFields() - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode

getSolutionSetKeyFields() - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

getSolutionSetNode() - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode

getSolutionSetNode() - Method in class org.apache.flink.optimizer.plan.SolutionSetPlanNode

getSolutionSetPlanNode() - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

getSolutionSetSerializer() - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

getSortOrders() - Method in class org.apache.flink.optimizer.plan.DualInputPlanNode

getSortOrders(int) - Method in class org.apache.flink.optimizer.plan.SingleInputPlanNode

Gets the sort order for the specified driver comparator.

getSource() - Method in class org.apache.flink.optimizer.dag.DagConnection

Gets the source of the connection.

getSource() - Method in class org.apache.flink.optimizer.plan.Channel

Gets the source of this Channel.

getSource() - Method in interface org.apache.flink.optimizer.plandump.DumpableConnection

getStrategy() - Method in class org.apache.flink.optimizer.dag.PartitionNode.PartitionDescriptor

getStrategy() - Method in class org.apache.flink.optimizer.dag.SortPartitionNode.SortPartitionDescriptor

getStrategy() - Method in interface org.apache.flink.optimizer.operators.AbstractOperatorDescriptor

Gets the runtime strategy to be executed by this operator.

getStrategy() - Method in class org.apache.flink.optimizer.operators.AllGroupCombineProperties

getStrategy() - Method in class org.apache.flink.optimizer.operators.AllGroupReduceProperties

getStrategy() - Method in class org.apache.flink.optimizer.operators.AllGroupWithPartialPreGroupProperties

getStrategy() - Method in class org.apache.flink.optimizer.operators.AllReduceProperties

getStrategy() - Method in class org.apache.flink.optimizer.operators.BinaryUnionOpDescriptor

getStrategy() - Method in class org.apache.flink.optimizer.operators.CoGroupDescriptor

getStrategy() - Method in class org.apache.flink.optimizer.operators.CoGroupRawDescriptor

getStrategy() - Method in class org.apache.flink.optimizer.operators.CrossBlockOuterFirstDescriptor

getStrategy() - Method in class org.apache.flink.optimizer.operators.CrossBlockOuterSecondDescriptor

getStrategy() - Method in class org.apache.flink.optimizer.operators.CrossStreamOuterFirstDescriptor

getStrategy() - Method in class org.apache.flink.optimizer.operators.CrossStreamOuterSecondDescriptor

getStrategy() - Method in class org.apache.flink.optimizer.operators.FilterDescriptor

getStrategy() - Method in class org.apache.flink.optimizer.operators.FlatMapDescriptor

getStrategy() - Method in class org.apache.flink.optimizer.operators.GroupCombineProperties

getStrategy() - Method in class org.apache.flink.optimizer.operators.GroupReduceProperties

getStrategy() - Method in class org.apache.flink.optimizer.operators.GroupReduceWithCombineProperties

getStrategy() - Method in class org.apache.flink.optimizer.operators.HashFullOuterJoinBuildFirstDescriptor

getStrategy() - Method in class org.apache.flink.optimizer.operators.HashFullOuterJoinBuildSecondDescriptor

getStrategy() - Method in class org.apache.flink.optimizer.operators.HashJoinBuildFirstProperties

getStrategy() - Method in class org.apache.flink.optimizer.operators.HashJoinBuildSecondProperties

getStrategy() - Method in class org.apache.flink.optimizer.operators.HashLeftOuterJoinBuildFirstDescriptor

getStrategy() - Method in class org.apache.flink.optimizer.operators.HashLeftOuterJoinBuildSecondDescriptor

getStrategy() - Method in class org.apache.flink.optimizer.operators.HashRightOuterJoinBuildFirstDescriptor

getStrategy() - Method in class org.apache.flink.optimizer.operators.HashRightOuterJoinBuildSecondDescriptor

getStrategy() - Method in class org.apache.flink.optimizer.operators.MapDescriptor

getStrategy() - Method in class org.apache.flink.optimizer.operators.MapPartitionDescriptor

getStrategy() - Method in class org.apache.flink.optimizer.operators.NoOpDescriptor

getStrategy() - Method in class org.apache.flink.optimizer.operators.PartialGroupProperties

getStrategy() - Method in class org.apache.flink.optimizer.operators.ReduceProperties

getStrategy() - Method in class org.apache.flink.optimizer.operators.SolutionSetDeltaOperator

getStrategy() - Method in class org.apache.flink.optimizer.operators.SortMergeFullOuterJoinDescriptor

getStrategy() - Method in class org.apache.flink.optimizer.operators.SortMergeInnerJoinDescriptor

getStrategy() - Method in class org.apache.flink.optimizer.operators.SortMergeLeftOuterJoinDescriptor

getStrategy() - Method in class org.apache.flink.optimizer.operators.SortMergeRightOuterJoinDescriptor

getStrategy() - Method in class org.apache.flink.optimizer.operators.UtilSinkJoinOpDescriptor

getTarget() - Method in class org.apache.flink.optimizer.dag.DagConnection

Gets the target of the connection.

getTarget() - Method in class org.apache.flink.optimizer.plan.Channel

Gets the target of this Channel.

getTempMode() - Method in class org.apache.flink.optimizer.plan.Channel

getTrueArray(int) - Static method in class org.apache.flink.optimizer.plan.SingleInputPlanNode

getTwoInputNode() - Method in class org.apache.flink.optimizer.plan.DualInputPlanNode

getUniqueFieldCombination() - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

getUniqueFields() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

Gets the FieldSets which are unique in the output of the node.

getUniqueFields() - Method in class org.apache.flink.optimizer.dataproperties.LocalProperties

Gets the fields whose combination is unique within the data set.

getWorksetNode() - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode

getWorksetNode() - Method in class org.apache.flink.optimizer.plan.WorksetPlanNode

getWorksetPlanNode() - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

getWorksetSerializer() - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

GlobalProperties - Class in org.apache.flink.optimizer.dataproperties

This class represents global properties of the data at a certain point in the plan.

GlobalProperties() - Constructor for class org.apache.flink.optimizer.dataproperties.GlobalProperties

Initializes the global properties with no partitioning.

GlobalPropertiesPair(RequestedGlobalProperties, RequestedGlobalProperties) - Constructor for class org.apache.flink.optimizer.operators.OperatorDescriptorDual.GlobalPropertiesPair

globalProps - Variable in class org.apache.flink.optimizer.plan.PlanNode

GraphCreatingVisitor - Class in org.apache.flink.optimizer.traversals

This traversal creates the optimizer DAG from a program.

GraphCreatingVisitor(int, ExecutionMode) - Constructor for class org.apache.flink.optimizer.traversals.GraphCreatingVisitor

GroupCombineNode - Class in org.apache.flink.optimizer.dag

The optimizer representation of a GroupCombineNode operation.

GroupCombineNode(GroupCombineOperatorBase<?, ?, ?>) - Constructor for class org.apache.flink.optimizer.dag.GroupCombineNode

Creates a new optimizer node for the given operator.

GroupCombineProperties - Class in org.apache.flink.optimizer.operators

The properties file belonging to the GroupCombineNode.

GroupCombineProperties(FieldSet, Ordering) - Constructor for class org.apache.flink.optimizer.operators.GroupCombineProperties

GroupReduceNode - Class in org.apache.flink.optimizer.dag

The optimizer representation of a GroupReduce operation.

GroupReduceNode(GroupReduceOperatorBase<?, ?, ?>) - Constructor for class org.apache.flink.optimizer.dag.GroupReduceNode

Creates a new optimizer node for the given operator.

GroupReduceProperties - Class in org.apache.flink.optimizer.operators

GroupReduceProperties(FieldSet) - Constructor for class org.apache.flink.optimizer.operators.GroupReduceProperties

GroupReduceProperties(FieldSet, Partitioner<?>) - Constructor for class org.apache.flink.optimizer.operators.GroupReduceProperties

GroupReduceProperties(FieldSet, Ordering) - Constructor for class org.apache.flink.optimizer.operators.GroupReduceProperties

GroupReduceProperties(FieldSet, Ordering, Partitioner<?>) - Constructor for class org.apache.flink.optimizer.operators.GroupReduceProperties

GroupReduceWithCombineProperties - Class in org.apache.flink.optimizer.operators

GroupReduceWithCombineProperties(FieldSet) - Constructor for class org.apache.flink.optimizer.operators.GroupReduceWithCombineProperties

GroupReduceWithCombineProperties(FieldSet, Partitioner<?>) - Constructor for class org.apache.flink.optimizer.operators.GroupReduceWithCombineProperties

GroupReduceWithCombineProperties(FieldSet, Ordering) - Constructor for class org.apache.flink.optimizer.operators.GroupReduceWithCombineProperties

GroupReduceWithCombineProperties(FieldSet, Ordering, Partitioner<?>) - Constructor for class org.apache.flink.optimizer.operators.GroupReduceWithCombineProperties

H

hasDamOnPathDownTo(PlanNode) - Method in class org.apache.flink.optimizer.plan.BulkIterationPlanNode

hasDamOnPathDownTo(PlanNode) - Method in class org.apache.flink.optimizer.plan.BulkPartialSolutionPlanNode

hasDamOnPathDownTo(PlanNode) - Method in class org.apache.flink.optimizer.plan.DualInputPlanNode

hasDamOnPathDownTo(PlanNode) - Method in class org.apache.flink.optimizer.plan.NAryUnionPlanNode

hasDamOnPathDownTo(PlanNode) - Method in class org.apache.flink.optimizer.plan.PlanNode

Checks whether this node has a dam on the way down to the given source node.

hasDamOnPathDownTo(PlanNode) - Method in class org.apache.flink.optimizer.plan.SingleInputPlanNode

hasDamOnPathDownTo(PlanNode) - Method in class org.apache.flink.optimizer.plan.SolutionSetPlanNode

hasDamOnPathDownTo(PlanNode) - Method in class org.apache.flink.optimizer.plan.SourcePlanNode

hasDamOnPathDownTo(PlanNode) - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

hasDamOnPathDownTo(PlanNode) - Method in class org.apache.flink.optimizer.plan.WorksetPlanNode

hasFoundWorkset() - Method in class org.apache.flink.optimizer.traversals.StepFunctionValidator

HASH_PARTITIONED - org.apache.flink.optimizer.dataproperties.PartitioningProperty

A hash partitioning on a certain key.

hashCode() - Method in class org.apache.flink.optimizer.costs.Costs

hashCode() - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

hashCode() - Method in class org.apache.flink.optimizer.dataproperties.InterestingProperties

hashCode() - Method in class org.apache.flink.optimizer.dataproperties.LocalProperties

hashCode() - Method in class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties

hashCode() - Method in class org.apache.flink.optimizer.dataproperties.RequestedLocalProperties

hashCode() - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual.GlobalPropertiesPair

hashCode() - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual.LocalPropertiesPair

HashFullOuterJoinBuildFirstDescriptor - Class in org.apache.flink.optimizer.operators

HashFullOuterJoinBuildFirstDescriptor(FieldList, FieldList) - Constructor for class org.apache.flink.optimizer.operators.HashFullOuterJoinBuildFirstDescriptor

HashFullOuterJoinBuildSecondDescriptor - Class in org.apache.flink.optimizer.operators

HashFullOuterJoinBuildSecondDescriptor(FieldList, FieldList) - Constructor for class org.apache.flink.optimizer.operators.HashFullOuterJoinBuildSecondDescriptor

HashJoinBuildFirstProperties - Class in org.apache.flink.optimizer.operators

HashJoinBuildFirstProperties(FieldList, FieldList) - Constructor for class org.apache.flink.optimizer.operators.HashJoinBuildFirstProperties

HashJoinBuildFirstProperties(FieldList, FieldList, boolean, boolean, boolean) - Constructor for class org.apache.flink.optimizer.operators.HashJoinBuildFirstProperties

HashJoinBuildSecondProperties - Class in org.apache.flink.optimizer.operators

HashJoinBuildSecondProperties(FieldList, FieldList) - Constructor for class org.apache.flink.optimizer.operators.HashJoinBuildSecondProperties

HashJoinBuildSecondProperties(FieldList, FieldList, boolean, boolean, boolean) - Constructor for class org.apache.flink.optimizer.operators.HashJoinBuildSecondProperties

HashLeftOuterJoinBuildFirstDescriptor - Class in org.apache.flink.optimizer.operators

HashLeftOuterJoinBuildFirstDescriptor(FieldList, FieldList, boolean, boolean) - Constructor for class org.apache.flink.optimizer.operators.HashLeftOuterJoinBuildFirstDescriptor

HashLeftOuterJoinBuildSecondDescriptor - Class in org.apache.flink.optimizer.operators

HashLeftOuterJoinBuildSecondDescriptor(FieldList, FieldList, boolean, boolean) - Constructor for class org.apache.flink.optimizer.operators.HashLeftOuterJoinBuildSecondDescriptor

HashRightOuterJoinBuildFirstDescriptor - Class in org.apache.flink.optimizer.operators

HashRightOuterJoinBuildFirstDescriptor(FieldList, FieldList, boolean, boolean) - Constructor for class org.apache.flink.optimizer.operators.HashRightOuterJoinBuildFirstDescriptor

HashRightOuterJoinBuildSecondDescriptor - Class in org.apache.flink.optimizer.operators

HashRightOuterJoinBuildSecondDescriptor(FieldList, FieldList, boolean, boolean) - Constructor for class org.apache.flink.optimizer.operators.HashRightOuterJoinBuildSecondDescriptor

hasUnclosedBranches() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

haveAllOutputConnectionInterestingProperties() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

Checks, if all outgoing connections have their interesting properties set from their target nodes.

hereJoinedBranches - Variable in class org.apache.flink.optimizer.dag.OptimizerNode

HINT_LOCAL_STRATEGY - Static variable in class org.apache.flink.optimizer.Optimizer

Compiler hint key for the operator's local strategy.

HINT_LOCAL_STRATEGY_COMBINING_SORT - Static variable in class org.apache.flink.optimizer.Optimizer

Value for the local strategy compiler hint that enforces a sort based local strategy.

HINT_LOCAL_STRATEGY_HASH_BUILD_FIRST - Static variable in class org.apache.flink.optimizer.Optimizer

Value for the local strategy compiler hint that enforces a hash based local strategy.

HINT_LOCAL_STRATEGY_HASH_BUILD_SECOND - Static variable in class org.apache.flink.optimizer.Optimizer

Value for the local strategy compiler hint that enforces a hash based local strategy.

HINT_LOCAL_STRATEGY_MERGE - Static variable in class org.apache.flink.optimizer.Optimizer

Value for the local strategy compiler hint that enforces a merge based local strategy.

HINT_LOCAL_STRATEGY_NESTEDLOOP_BLOCKED_OUTER_FIRST - Static variable in class org.apache.flink.optimizer.Optimizer

Value for the local strategy compiler hint that chooses the outer side of the nested-loop local strategy.

HINT_LOCAL_STRATEGY_NESTEDLOOP_BLOCKED_OUTER_SECOND - Static variable in class org.apache.flink.optimizer.Optimizer

Value for the local strategy compiler hint that chooses the outer side of the nested-loop local strategy.

HINT_LOCAL_STRATEGY_NESTEDLOOP_STREAMED_OUTER_FIRST - Static variable in class org.apache.flink.optimizer.Optimizer

Value for the local strategy compiler hint that chooses the outer side of the nested-loop local strategy.

HINT_LOCAL_STRATEGY_NESTEDLOOP_STREAMED_OUTER_SECOND - Static variable in class org.apache.flink.optimizer.Optimizer

Value for the local strategy compiler hint that chooses the outer side of the nested-loop local strategy.

HINT_LOCAL_STRATEGY_SORT - Static variable in class org.apache.flink.optimizer.Optimizer

Value for the local strategy compiler hint that enforces a sort based local strategy.

HINT_LOCAL_STRATEGY_SORT_BOTH_MERGE - Static variable in class org.apache.flink.optimizer.Optimizer

Value for the local strategy compiler hint that enforces a sort merge based local strategy on both inputs with subsequent merging of inputs.

HINT_LOCAL_STRATEGY_SORT_FIRST_MERGE - Static variable in class org.apache.flink.optimizer.Optimizer

Value for the local strategy compiler hint that enforces a sort merge based local strategy.

HINT_LOCAL_STRATEGY_SORT_SECOND_MERGE - Static variable in class org.apache.flink.optimizer.Optimizer

Value for the local strategy compiler hint that enforces a sort merge based local strategy.

HINT_SHIP_STRATEGY - Static variable in class org.apache.flink.optimizer.Optimizer

Compiler hint key for the input channel's shipping strategy.

HINT_SHIP_STRATEGY_BROADCAST - Static variable in class org.apache.flink.optimizer.Optimizer

Value for the shipping strategy compiler hint that enforces a broadcast strategy on the input channel.

HINT_SHIP_STRATEGY_FIRST_INPUT - Static variable in class org.apache.flink.optimizer.Optimizer

Compiler hint key for the first input channel's shipping strategy.

HINT_SHIP_STRATEGY_FORWARD - Static variable in class org.apache.flink.optimizer.Optimizer

Value for the shipping strategy compiler hint that enforces a Forward strategy on the input channel, i.e.

HINT_SHIP_STRATEGY_REPARTITION - Static variable in class org.apache.flink.optimizer.Optimizer

Value for the shipping strategy compiler hint that enforces a random repartition strategy.

HINT_SHIP_STRATEGY_REPARTITION_HASH - Static variable in class org.apache.flink.optimizer.Optimizer

Value for the shipping strategy compiler hint that enforces a hash-partition strategy.

HINT_SHIP_STRATEGY_REPARTITION_RANGE - Static variable in class org.apache.flink.optimizer.Optimizer

Value for the shipping strategy compiler hint that enforces a range-partition strategy.

HINT_SHIP_STRATEGY_SECOND_INPUT - Static variable in class org.apache.flink.optimizer.Optimizer

Compiler hint key for the second input channel's shipping strategy.

I

id - Variable in class org.apache.flink.optimizer.dag.OptimizerNode

IdAndEstimatesVisitor - Class in org.apache.flink.optimizer.traversals

This traversal of the optimizer DAG assigns IDs to each node (in a pre-order fashion), and calls each node to compute its estimates.

IdAndEstimatesVisitor(DataStatistics) - Constructor for class org.apache.flink.optimizer.traversals.IdAndEstimatesVisitor

identifyDynamicPath(int) - Method in class org.apache.flink.optimizer.dag.AbstractPartialSolutionNode

identifyDynamicPath(int) - Method in class org.apache.flink.optimizer.dag.OptimizerNode

inConn - Variable in class org.apache.flink.optimizer.dag.SingleInputNode

initId(int) - Method in class org.apache.flink.optimizer.dag.OptimizerNode

Sets the ID of this node.

initMaxDepth() - Method in class org.apache.flink.optimizer.dag.DagConnection

initProperties(GlobalProperties, LocalProperties) - Method in class org.apache.flink.optimizer.plan.PlanNode

input - Variable in class org.apache.flink.optimizer.dag.DataSinkNode

input - Variable in class org.apache.flink.optimizer.plan.SingleInputPlanNode

input1 - Variable in class org.apache.flink.optimizer.dag.TwoInputNode

input1 - Variable in class org.apache.flink.optimizer.plan.DualInputPlanNode

input2 - Variable in class org.apache.flink.optimizer.dag.TwoInputNode

input2 - Variable in class org.apache.flink.optimizer.plan.DualInputPlanNode

INSTANCE - Static variable in class org.apache.flink.optimizer.util.NoOpUnaryUdfOp

instantiate(OperatorDescriptorDual, Channel, Channel, List<Set<? extends NamedChannel>>, List<PlanNode>, CostEstimator, RequestedGlobalProperties, RequestedGlobalProperties, RequestedLocalProperties, RequestedLocalProperties) - Method in class org.apache.flink.optimizer.dag.TwoInputNode

instantiate(OperatorDescriptorDual, Channel, Channel, List<Set<? extends NamedChannel>>, List<PlanNode>, CostEstimator, RequestedGlobalProperties, RequestedGlobalProperties, RequestedLocalProperties, RequestedLocalProperties) - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode

instantiate(Channel, SingleInputNode) - Method in class org.apache.flink.optimizer.dag.PartitionNode.PartitionDescriptor

instantiate(Channel, SingleInputNode) - Method in class org.apache.flink.optimizer.dag.SortPartitionNode.SortPartitionDescriptor

instantiate(Channel, SingleInputNode) - Method in class org.apache.flink.optimizer.operators.AllGroupCombineProperties

instantiate(Channel, SingleInputNode) - Method in class org.apache.flink.optimizer.operators.AllGroupReduceProperties

instantiate(Channel, SingleInputNode) - Method in class org.apache.flink.optimizer.operators.AllGroupWithPartialPreGroupProperties

instantiate(Channel, SingleInputNode) - Method in class org.apache.flink.optimizer.operators.AllReduceProperties

instantiate(Channel, SingleInputNode) - Method in class org.apache.flink.optimizer.operators.FilterDescriptor

instantiate(Channel, SingleInputNode) - Method in class org.apache.flink.optimizer.operators.FlatMapDescriptor

instantiate(Channel, SingleInputNode) - Method in class org.apache.flink.optimizer.operators.GroupCombineProperties

instantiate(Channel, SingleInputNode) - Method in class org.apache.flink.optimizer.operators.GroupReduceProperties

instantiate(Channel, SingleInputNode) - Method in class org.apache.flink.optimizer.operators.GroupReduceWithCombineProperties

instantiate(Channel, SingleInputNode) - Method in class org.apache.flink.optimizer.operators.MapDescriptor

instantiate(Channel, SingleInputNode) - Method in class org.apache.flink.optimizer.operators.MapPartitionDescriptor

instantiate(Channel, SingleInputNode) - Method in class org.apache.flink.optimizer.operators.NoOpDescriptor

instantiate(Channel, SingleInputNode) - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorSingle

instantiate(Channel, SingleInputNode) - Method in class org.apache.flink.optimizer.operators.PartialGroupProperties

instantiate(Channel, SingleInputNode) - Method in class org.apache.flink.optimizer.operators.ReduceProperties

instantiate(Channel, SingleInputNode) - Method in class org.apache.flink.optimizer.operators.SolutionSetDeltaOperator

instantiate(Channel, Channel, TwoInputNode) - Method in class org.apache.flink.optimizer.operators.AbstractSortMergeJoinDescriptor

instantiate(Channel, Channel, TwoInputNode) - Method in class org.apache.flink.optimizer.operators.BinaryUnionOpDescriptor

instantiate(Channel, Channel, TwoInputNode) - Method in class org.apache.flink.optimizer.operators.CartesianProductDescriptor

instantiate(Channel, Channel, TwoInputNode) - Method in class org.apache.flink.optimizer.operators.CoGroupDescriptor

instantiate(Channel, Channel, TwoInputNode) - Method in class org.apache.flink.optimizer.operators.CoGroupRawDescriptor

instantiate(Channel, Channel, TwoInputNode) - Method in class org.apache.flink.optimizer.operators.CoGroupWithSolutionSetFirstDescriptor

instantiate(Channel, Channel, TwoInputNode) - Method in class org.apache.flink.optimizer.operators.HashFullOuterJoinBuildFirstDescriptor

instantiate(Channel, Channel, TwoInputNode) - Method in class org.apache.flink.optimizer.operators.HashFullOuterJoinBuildSecondDescriptor

instantiate(Channel, Channel, TwoInputNode) - Method in class org.apache.flink.optimizer.operators.HashJoinBuildFirstProperties

instantiate(Channel, Channel, TwoInputNode) - Method in class org.apache.flink.optimizer.operators.HashJoinBuildSecondProperties

instantiate(Channel, Channel, TwoInputNode) - Method in class org.apache.flink.optimizer.operators.HashLeftOuterJoinBuildFirstDescriptor

instantiate(Channel, Channel, TwoInputNode) - Method in class org.apache.flink.optimizer.operators.HashLeftOuterJoinBuildSecondDescriptor

instantiate(Channel, Channel, TwoInputNode) - Method in class org.apache.flink.optimizer.operators.HashRightOuterJoinBuildFirstDescriptor

instantiate(Channel, Channel, TwoInputNode) - Method in class org.apache.flink.optimizer.operators.HashRightOuterJoinBuildSecondDescriptor

instantiate(Channel, Channel, TwoInputNode) - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual

instantiate(Channel, Channel, TwoInputNode) - Method in class org.apache.flink.optimizer.operators.UtilSinkJoinOpDescriptor

instantiateCandidate(OperatorDescriptorSingle, Channel, List<Set<? extends NamedChannel>>, List<PlanNode>, CostEstimator, RequestedGlobalProperties, RequestedLocalProperties) - Method in class org.apache.flink.optimizer.dag.BulkIterationNode

instantiateCandidate(OperatorDescriptorSingle, Channel, List<Set<? extends NamedChannel>>, List<PlanNode>, CostEstimator, RequestedGlobalProperties, RequestedLocalProperties) - Method in class org.apache.flink.optimizer.dag.SingleInputNode

InterestingProperties - Class in org.apache.flink.optimizer.dataproperties

Interesting properties are propagated from parent operators to child operators.

InterestingProperties() - Constructor for class org.apache.flink.optimizer.dataproperties.InterestingProperties

InterestingPropertyVisitor - Class in org.apache.flink.optimizer.traversals

Visitor that computes the interesting properties for each node in the optimizer DAG.

InterestingPropertyVisitor(CostEstimator) - Constructor for class org.apache.flink.optimizer.traversals.InterestingPropertyVisitor

Creates a new visitor that computes the interesting properties for all nodes in the plan.

isBranching() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

Checks whether this node has branching output.

isBreakingPipeline() - Method in class org.apache.flink.optimizer.dag.DagConnection

Checks whether this connection is marked to break the pipeline.

isCached() - Method in enum org.apache.flink.optimizer.dag.TempMode

isCombineable() - Method in class org.apache.flink.optimizer.dag.GroupReduceNode

Checks, whether a combiner function has been given for the function encapsulated by this reduce contract.

isComputablyPartitioned() - Method in enum org.apache.flink.optimizer.dataproperties.PartitioningProperty

Checks, if this property represents a partitioning that is computable.

isEncodeForHTML() - Method in class org.apache.flink.optimizer.plandump.PlanJSONDumpGenerator

isExactlyPartitionedOnFields(FieldList) - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

isFullyReplicated() - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

isImmediateSolutionSetUpdate() - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

isMetBy(GlobalProperties) - Method in class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties

Checks, if this set of interesting properties, is met by the given produced properties.

isMetBy(LocalProperties) - Method in class org.apache.flink.optimizer.dataproperties.RequestedLocalProperties

Checks, if this set of properties, as interesting properties, is met by the given properties.

isOnDynamicPath() - Method in class org.apache.flink.optimizer.dag.AbstractPartialSolutionNode

isOnDynamicPath() - Method in class org.apache.flink.optimizer.dag.DagConnection

isOnDynamicPath() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

isOnDynamicPath() - Method in class org.apache.flink.optimizer.plan.Channel

isOnDynamicPath() - Method in class org.apache.flink.optimizer.plan.PlanNode

isPartitioned() - Method in enum org.apache.flink.optimizer.dataproperties.PartitioningProperty

Checks, if this property represents in fact a partitioning.

isPartitionedOnFields(FieldSet) - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

isPartitionedOnKey() - Method in enum org.apache.flink.optimizer.dataproperties.PartitioningProperty

Checks if this property presents a partitioning that is not random, but on a partitioning key.

isPruneMarkerSet() - Method in class org.apache.flink.optimizer.plan.PlanNode

Checks whether the pruning marker was set.

isReplication() - Method in enum org.apache.flink.optimizer.dataproperties.PartitioningProperty

Checks, if this property represents a full replication.

isTrivial() - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

Checks, if the properties in this object are trivial, i.e.

isTrivial() - Method in class org.apache.flink.optimizer.dataproperties.LocalProperties

Checks, if the properties in this object are trivial, i.e.

isTrivial() - Method in class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties

Checks, if the properties in this object are trivial, i.e.

isTrivial() - Method in class org.apache.flink.optimizer.dataproperties.RequestedLocalProperties

Checks, if the properties in this object are trivial, i.e.

IterationNode - Interface in org.apache.flink.optimizer.dag

IterationPlanNode - Interface in org.apache.flink.optimizer.plan

J

JavaApiPostPass - Class in org.apache.flink.optimizer.postpass

The post-optimizer plan traversal.

JavaApiPostPass() - Constructor for class org.apache.flink.optimizer.postpass.JavaApiPostPass

JobGraphGenerator - Class in org.apache.flink.optimizer.plantranslate

This component translates the optimizer's resulting OptimizedPlan to a JobGraph.

JobGraphGenerator() - Constructor for class org.apache.flink.optimizer.plantranslate.JobGraphGenerator

Creates a new job graph generator that uses the default values for its resource configuration.

JobGraphGenerator(Configuration) - Constructor for class org.apache.flink.optimizer.plantranslate.JobGraphGenerator

joinedPathsVector - Variable in class org.apache.flink.optimizer.dag.OptimizerNode.UnclosedBranchDescriptor

JoinNode - Class in org.apache.flink.optimizer.dag

The Optimizer representation of a join operator.

JoinNode(InnerJoinOperatorBase<?, ?, ?, ?>) - Constructor for class org.apache.flink.optimizer.dag.JoinNode

Creates a new JoinNode for the given join operator.

JsonMapper - Class in org.apache.flink.optimizer.plantranslate

JsonMapper() - Constructor for class org.apache.flink.optimizer.plantranslate.JsonMapper

K

keyList - Variable in class org.apache.flink.optimizer.operators.OperatorDescriptorSingle

keys - Variable in class org.apache.flink.optimizer.dag.SingleInputNode

keys - Variable in class org.apache.flink.optimizer.operators.OperatorDescriptorSingle

keys1 - Variable in class org.apache.flink.optimizer.dag.TwoInputNode

keys1 - Variable in class org.apache.flink.optimizer.operators.OperatorDescriptorDual

keys1 - Variable in class org.apache.flink.optimizer.plan.DualInputPlanNode

keys2 - Variable in class org.apache.flink.optimizer.dag.TwoInputNode

keys2 - Variable in class org.apache.flink.optimizer.operators.OperatorDescriptorDual

keys2 - Variable in class org.apache.flink.optimizer.plan.DualInputPlanNode

L

LocalProperties - Class in org.apache.flink.optimizer.dataproperties

This class represents local properties of the data.

LocalProperties() - Constructor for class org.apache.flink.optimizer.dataproperties.LocalProperties

Default constructor for trivial local properties.

LocalPropertiesPair(RequestedLocalProperties, RequestedLocalProperties) - Constructor for class org.apache.flink.optimizer.operators.OperatorDescriptorDual.LocalPropertiesPair

localProps - Variable in class org.apache.flink.optimizer.plan.PlanNode

LOG - Static variable in class org.apache.flink.optimizer.dataproperties.GlobalProperties

LOG - Static variable in class org.apache.flink.optimizer.dataproperties.LocalProperties

LOG - Static variable in class org.apache.flink.optimizer.Optimizer

The log handle that is used by the compiler to log messages.

M

makeCached() - Method in enum org.apache.flink.optimizer.dag.TempMode

makeCoGroupWithSolutionSet(int) - Method in class org.apache.flink.optimizer.dag.CoGroupNode

makeJoinWithSolutionSet(int) - Method in class org.apache.flink.optimizer.dag.JoinNode

makeNonCached() - Method in enum org.apache.flink.optimizer.dag.TempMode

makePipelineBreaker() - Method in enum org.apache.flink.optimizer.dag.TempMode

MapDescriptor - Class in org.apache.flink.optimizer.operators

MapDescriptor() - Constructor for class org.apache.flink.optimizer.operators.MapDescriptor

MapNode - Class in org.apache.flink.optimizer.dag

The optimizer's internal representation of a Map operator node.

MapNode(SingleInputOperator<?, ?, ?>) - Constructor for class org.apache.flink.optimizer.dag.MapNode

Creates a new MapNode for the given operator.

MapPartitionDescriptor - Class in org.apache.flink.optimizer.operators

MapPartitionDescriptor() - Constructor for class org.apache.flink.optimizer.operators.MapPartitionDescriptor

MapPartitionNode - Class in org.apache.flink.optimizer.dag

The optimizer's internal representation of a MapPartition operator node.

MapPartitionNode(SingleInputOperator<?, ?, ?>) - Constructor for class org.apache.flink.optimizer.dag.MapPartitionNode

Creates a new MapNode for the given contract.

markAllOutgoingConnectionsAsPipelineBreaking() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

markBreaksPipeline() - Method in class org.apache.flink.optimizer.dag.DagConnection

Marks that this connection should do a decoupled data exchange (such as batched) rather then pipeline data.

matchesOrderedPartitioning(Ordering) - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

MAX_DYNAMIC_PATH_COST_WEIGHT - Static variable in class org.apache.flink.optimizer.dag.OptimizerNode

MERGE_ITERATION_AUX_TASKS_KEY - Static variable in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator

mergeBranchPlanMaps() - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

mergeBranchPlanMaps(Map<OptimizerNode, PlanNode>, Map<OptimizerNode, PlanNode>) - Method in class org.apache.flink.optimizer.plan.PlanNode

mergeBranchPlanMaps(Map<OptimizerNode, PlanNode>, Map<OptimizerNode, PlanNode>) - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

Merging can only take place after the solutionSetDelta and nextWorkset PlanNode has been set, because they can contain also some of the branching nodes.

mergeBranchPlanMaps(PlanNode, PlanNode) - Method in class org.apache.flink.optimizer.plan.PlanNode

mergeLists(List<OptimizerNode.UnclosedBranchDescriptor>, List<OptimizerNode.UnclosedBranchDescriptor>, List<OptimizerNode.UnclosedBranchDescriptor>, boolean) - Method in class org.apache.flink.optimizer.dag.OptimizerNode

The node IDs are assigned in graph-traversal order (pre-order), hence, each list is sorted by ID in ascending order and all consecutive lists start with IDs in ascending order.

MET - org.apache.flink.optimizer.plan.PlanNode.FeedbackPropertiesMeetRequirementsReport

Indicates that the question whether the properties are met has been determined true

MissingFieldTypeInfoException - Exception in org.apache.flink.optimizer.postpass

MissingFieldTypeInfoException(int) - Constructor for exception org.apache.flink.optimizer.postpass.MissingFieldTypeInfoException

multiplyWith(int) - Method in class org.apache.flink.optimizer.costs.Costs

N

NamedChannel - Class in org.apache.flink.optimizer.plan

NamedChannel(String, PlanNode) - Constructor for class org.apache.flink.optimizer.plan.NamedChannel

Initializes NamedChannel.

NamedChannel(String, PlanNode, TempMode) - Constructor for class org.apache.flink.optimizer.plan.NamedChannel

NAryUnionPlanNode - Class in org.apache.flink.optimizer.plan

A union operation over multiple inputs (2 or more).

NAryUnionPlanNode(BinaryUnionNode, List<Channel>, GlobalProperties, Costs) - Constructor for class org.apache.flink.optimizer.plan.NAryUnionPlanNode

NO_PARTIAL_SOLUTION - org.apache.flink.optimizer.plan.PlanNode.FeedbackPropertiesMeetRequirementsReport

Indicates that the path is irrelevant

nodeCosts - Variable in class org.apache.flink.optimizer.plan.PlanNode

NONE - org.apache.flink.optimizer.dag.TempMode

NoOpBinaryUdfOp<OUT> - Class in org.apache.flink.optimizer.util

NoOpBinaryUdfOp(TypeInformation<OUT>) - Constructor for class org.apache.flink.optimizer.util.NoOpBinaryUdfOp

NoOpDescriptor - Class in org.apache.flink.optimizer.operators

NoOpDescriptor() - Constructor for class org.apache.flink.optimizer.operators.NoOpDescriptor

NoOpNode - Class in org.apache.flink.optimizer.dag

The optimizer's internal representation of a No Operation node.

NoOpNode() - Constructor for class org.apache.flink.optimizer.dag.NoOpNode

NoOpNode(String) - Constructor for class org.apache.flink.optimizer.dag.NoOpNode

NoOpUnaryUdfOp<OUT> - Class in org.apache.flink.optimizer.util

NoOpUnaryUdfOp() - Constructor for class org.apache.flink.optimizer.util.NoOpUnaryUdfOp

NOT_FOUND - org.apache.flink.optimizer.plan.PlanNode.SourceAndDamReport

NOT_MET - org.apache.flink.optimizer.plan.PlanNode.FeedbackPropertiesMeetRequirementsReport

Indicates that the question whether the properties are met has been determined false

O

onDynamicPath - Variable in class org.apache.flink.optimizer.dag.OptimizerNode

openBranches - Variable in class org.apache.flink.optimizer.dag.OptimizerNode

OperatorDescriptorDual - Class in org.apache.flink.optimizer.operators

OperatorDescriptorDual() - Constructor for class org.apache.flink.optimizer.operators.OperatorDescriptorDual

OperatorDescriptorDual(FieldList, FieldList) - Constructor for class org.apache.flink.optimizer.operators.OperatorDescriptorDual

OperatorDescriptorDual.GlobalPropertiesPair - Class in org.apache.flink.optimizer.operators

OperatorDescriptorDual.LocalPropertiesPair - Class in org.apache.flink.optimizer.operators

OperatorDescriptorSingle - Class in org.apache.flink.optimizer.operators

Abstract base class for Operator descriptions which instantiates the node and sets the driver strategy and the sorting and grouping keys.

OperatorDescriptorSingle() - Constructor for class org.apache.flink.optimizer.operators.OperatorDescriptorSingle

OperatorDescriptorSingle(FieldSet) - Constructor for class org.apache.flink.optimizer.operators.OperatorDescriptorSingle

OptimizedPlan - Class in org.apache.flink.optimizer.plan

The execution plan generated by the Optimizer.

OptimizedPlan(Collection<SourcePlanNode>, Collection<SinkPlanNode>, Collection<PlanNode>, String, Plan) - Constructor for class org.apache.flink.optimizer.plan.OptimizedPlan

Creates a new instance of this optimizer plan container.

Optimizer - Class in org.apache.flink.optimizer

The optimizer that takes the user specified program plan and creates an optimized plan that contains exact descriptions about how the physical execution will take place.

Optimizer(Configuration) - Constructor for class org.apache.flink.optimizer.Optimizer

Creates a new optimizer instance.

Optimizer(CostEstimator, Configuration) - Constructor for class org.apache.flink.optimizer.Optimizer

Creates a new optimizer instance.

Optimizer(DataStatistics, Configuration) - Constructor for class org.apache.flink.optimizer.Optimizer

Creates a new optimizer instance that uses the statistics object to determine properties about the input.

Optimizer(DataStatistics, CostEstimator, Configuration) - Constructor for class org.apache.flink.optimizer.Optimizer

Creates a new optimizer instance that uses the statistics object to determine properties about the input.

OptimizerNode - Class in org.apache.flink.optimizer.dag

The OptimizerNode is the base class of all nodes in the optimizer DAG.

OptimizerNode(Operator<?>) - Constructor for class org.apache.flink.optimizer.dag.OptimizerNode

Creates a new optimizer node that represents the given program operator.

OptimizerNode(OptimizerNode) - Constructor for class org.apache.flink.optimizer.dag.OptimizerNode

OptimizerNode.UnclosedBranchDescriptor - Class in org.apache.flink.optimizer.dag

Description of an unclosed branch.

OptimizerPostPass - Interface in org.apache.flink.optimizer.postpass

Interface for visitors that process the optimizer's plan.

org.apache.flink.optimizer - package org.apache.flink.optimizer

org.apache.flink.optimizer.costs - package org.apache.flink.optimizer.costs

org.apache.flink.optimizer.dag - package org.apache.flink.optimizer.dag

org.apache.flink.optimizer.dataproperties - package org.apache.flink.optimizer.dataproperties

org.apache.flink.optimizer.operators - package org.apache.flink.optimizer.operators

org.apache.flink.optimizer.plan - package org.apache.flink.optimizer.plan

org.apache.flink.optimizer.plandump - package org.apache.flink.optimizer.plandump

org.apache.flink.optimizer.plantranslate - package org.apache.flink.optimizer.plantranslate

org.apache.flink.optimizer.postpass - package org.apache.flink.optimizer.postpass

org.apache.flink.optimizer.traversals - package org.apache.flink.optimizer.traversals

This package contains the various traversals over the program plan and the optimizer DAG (directed acyclic graph) that are made in the course of the optimization.

org.apache.flink.optimizer.util - package org.apache.flink.optimizer.util

outChannels - Variable in class org.apache.flink.optimizer.plan.PlanNode

OuterJoinNode - Class in org.apache.flink.optimizer.dag

OuterJoinNode(OuterJoinOperatorBase<?, ?, ?, ?>) - Constructor for class org.apache.flink.optimizer.dag.OuterJoinNode

Creates a new two input node for the optimizer plan, representing the given operator.

P

parameterizeChannel(Channel) - Method in class org.apache.flink.optimizer.dataproperties.RequestedLocalProperties

Parametrizes the local strategy fields of a channel such that the channel produces the desired local properties.

parameterizeChannel(Channel, boolean, ExecutionMode, boolean) - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

parameterizeChannel(Channel, boolean, ExecutionMode, boolean) - Method in class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties

Parametrizes the ship strategy fields of a channel such that the channel produces the desired global properties.

PartialGroupProperties - Class in org.apache.flink.optimizer.operators

PartialGroupProperties(FieldSet) - Constructor for class org.apache.flink.optimizer.operators.PartialGroupProperties

PartitionDescriptor(PartitionOperatorBase.PartitionMethod, FieldSet, Ordering, Partitioner<?>, DataDistribution) - Constructor for class org.apache.flink.optimizer.dag.PartitionNode.PartitionDescriptor

PartitioningProperty - Enum in org.apache.flink.optimizer.dataproperties

An enumeration of the different types of distributing data across partitions or parallel workers.

PartitionNode - Class in org.apache.flink.optimizer.dag

The optimizer's internal representation of a Partition operator node.

PartitionNode(PartitionOperatorBase<?>) - Constructor for class org.apache.flink.optimizer.dag.PartitionNode

PartitionNode.PartitionDescriptor - Class in org.apache.flink.optimizer.dag

PENDING - org.apache.flink.optimizer.plan.PlanNode.FeedbackPropertiesMeetRequirementsReport

Indicates that the question whether the properties are met has been determined pending dependent on global and local properties

PENDING_LOCAL_MET - org.apache.flink.optimizer.plan.PlanNode.FeedbackPropertiesMeetRequirementsReport

Indicates that the question whether the properties are met has been determined pending dependent on global properties only

PIPELINE_BREAKER - org.apache.flink.optimizer.dag.TempMode

placePipelineBreakersIfNecessary(DriverStrategy, Channel, Channel) - Method in class org.apache.flink.optimizer.dag.TwoInputNode

PlanFinalizer - Class in org.apache.flink.optimizer.traversals

This visitor traverses the selected execution plan and finalizes it: The graph of nodes is double-linked (links from child to parent are inserted).

PlanFinalizer() - Constructor for class org.apache.flink.optimizer.traversals.PlanFinalizer

Creates a new plan finalizer.

PlanJSONDumpGenerator - Class in org.apache.flink.optimizer.plandump

PlanJSONDumpGenerator() - Constructor for class org.apache.flink.optimizer.plandump.PlanJSONDumpGenerator

PlanNode - Class in org.apache.flink.optimizer.plan

The representation of a data exchange between two operators.

PlanNode(OptimizerNode, String, DriverStrategy) - Constructor for class org.apache.flink.optimizer.plan.PlanNode

PlanNode.FeedbackPropertiesMeetRequirementsReport - Enum in org.apache.flink.optimizer.plan

PlanNode.SourceAndDamReport - Enum in org.apache.flink.optimizer.plan

postPass(OptimizedPlan) - Method in class org.apache.flink.optimizer.postpass.JavaApiPostPass

postPass(OptimizedPlan) - Method in interface org.apache.flink.optimizer.postpass.OptimizerPostPass

Central post processing function.

postPassHelper - Variable in class org.apache.flink.optimizer.plan.BulkPartialSolutionPlanNode

postPassHelper - Variable in class org.apache.flink.optimizer.plan.SingleInputPlanNode

postPassHelper - Variable in class org.apache.flink.optimizer.plan.SolutionSetPlanNode

postPassHelper - Variable in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

postPassHelper - Variable in class org.apache.flink.optimizer.plan.WorksetPlanNode

postPassHelper1 - Variable in class org.apache.flink.optimizer.plan.DualInputPlanNode

postPassHelper2 - Variable in class org.apache.flink.optimizer.plan.DualInputPlanNode

postVisit(Operator<?>) - Method in class org.apache.flink.optimizer.traversals.GraphCreatingVisitor

postVisit(Operator<?>) - Method in class org.apache.flink.optimizer.traversals.StepFunctionValidator

postVisit(OptimizerNode) - Method in class org.apache.flink.optimizer.traversals.BranchesVisitor

postVisit(OptimizerNode) - Method in class org.apache.flink.optimizer.traversals.IdAndEstimatesVisitor

postVisit(OptimizerNode) - Method in class org.apache.flink.optimizer.traversals.InterestingPropertyVisitor

postVisit(OptimizerNode) - Method in class org.apache.flink.optimizer.traversals.StaticDynamicPathIdentifier

postVisit(OptimizerNode) - Method in class org.apache.flink.optimizer.traversals.UnionParallelismAndForwardEnforcer

postVisit(PlanNode) - Method in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator

This method implements the post-visit during the depth-first traversal.

postVisit(PlanNode) - Method in class org.apache.flink.optimizer.traversals.BinaryUnionReplacer

postVisit(PlanNode) - Method in class org.apache.flink.optimizer.traversals.PlanFinalizer

postVisit(PlanNode) - Method in class org.apache.flink.optimizer.traversals.RangePartitionRewriter

preVisit(Operator<?>) - Method in class org.apache.flink.optimizer.traversals.GraphCreatingVisitor

preVisit(Operator<?>) - Method in class org.apache.flink.optimizer.traversals.StepFunctionValidator

preVisit(OptimizerNode) - Method in class org.apache.flink.optimizer.traversals.BranchesVisitor

preVisit(OptimizerNode) - Method in class org.apache.flink.optimizer.traversals.IdAndEstimatesVisitor

preVisit(OptimizerNode) - Method in class org.apache.flink.optimizer.traversals.InterestingPropertyVisitor

preVisit(OptimizerNode) - Method in class org.apache.flink.optimizer.traversals.StaticDynamicPathIdentifier

preVisit(OptimizerNode) - Method in class org.apache.flink.optimizer.traversals.UnionParallelismAndForwardEnforcer

preVisit(PlanNode) - Method in class org.apache.flink.optimizer.plantranslate.JobGraphGenerator

This methods implements the pre-visiting during a depth-first traversal.

preVisit(PlanNode) - Method in class org.apache.flink.optimizer.traversals.BinaryUnionReplacer

preVisit(PlanNode) - Method in class org.apache.flink.optimizer.traversals.PlanFinalizer

preVisit(PlanNode) - Method in class org.apache.flink.optimizer.traversals.RangePartitionRewriter

prunePlanAlternatives(List<PlanNode>) - Method in class org.apache.flink.optimizer.dag.OptimizerNode

prunePlanAlternativesWithCommonBranching(List<PlanNode>) - Method in class org.apache.flink.optimizer.dag.OptimizerNode

R

RANDOM_PARTITIONED - org.apache.flink.optimizer.dataproperties.PartitioningProperty

A random disjunct (non-replicated) data distribution, where each datum is contained in one partition only.

RANGE_PARTITIONED - org.apache.flink.optimizer.dataproperties.PartitioningProperty

A range partitioning on a certain key.

RangePartitionRewriter - Class in org.apache.flink.optimizer.traversals

RangePartitionRewriter(OptimizedPlan) - Constructor for class org.apache.flink.optimizer.traversals.RangePartitionRewriter

readStubAnnotations() - Method in class org.apache.flink.optimizer.dag.AbstractPartialSolutionNode

readStubAnnotations() - Method in class org.apache.flink.optimizer.dag.BinaryUnionNode

readStubAnnotations() - Method in class org.apache.flink.optimizer.dag.BulkIterationNode

readStubAnnotations() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

Reads all stub annotations, i.e.

readStubAnnotations() - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode

readUniqueFieldsAnnotation() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

ReduceNode - Class in org.apache.flink.optimizer.dag

The Optimizer representation of a Reduce operator.

ReduceNode(ReduceOperatorBase<?, ?>) - Constructor for class org.apache.flink.optimizer.dag.ReduceNode

ReduceNode(ReduceNode) - Constructor for class org.apache.flink.optimizer.dag.ReduceNode

ReduceProperties - Class in org.apache.flink.optimizer.operators

ReduceProperties(FieldSet, Partitioner<?>, DriverStrategy) - Constructor for class org.apache.flink.optimizer.operators.ReduceProperties

ReduceProperties(FieldSet, DriverStrategy) - Constructor for class org.apache.flink.optimizer.operators.ReduceProperties

removeClosedBranches(List<OptimizerNode.UnclosedBranchDescriptor>) - Method in class org.apache.flink.optimizer.dag.OptimizerNode

RequestedGlobalProperties - Class in org.apache.flink.optimizer.dataproperties

This class represents the global properties of the data that are requested by an operator.

RequestedGlobalProperties() - Constructor for class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties

Initializes the global properties with no partitioning.

RequestedLocalProperties - Class in org.apache.flink.optimizer.dataproperties

This class represents the local properties of the data that are requested by an operator.

RequestedLocalProperties() - Constructor for class org.apache.flink.optimizer.dataproperties.RequestedLocalProperties

Default constructor for trivial local properties.

RequestedLocalProperties(Ordering) - Constructor for class org.apache.flink.optimizer.dataproperties.RequestedLocalProperties

Creates interesting properties for the given ordering.

RequestedLocalProperties(FieldSet) - Constructor for class org.apache.flink.optimizer.dataproperties.RequestedLocalProperties

Creates interesting properties for the given grouping.

reset() - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

This method resets the properties to a state where no properties are given.

reset() - Method in class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties

This method resets the properties to a state where no properties are given.

reset() - Method in class org.apache.flink.optimizer.dataproperties.RequestedLocalProperties

This method resets the local properties to a state where no properties are given.

S

setAnyDistribution() - Method in class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties

setAnyPartitioning(FieldList) - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

setAnyPartitioning(FieldSet) - Method in class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties

Sets these properties to request some partitioning on the given fields.

setBroadcastInputs(List<NamedChannel>) - Method in class org.apache.flink.optimizer.plan.PlanNode

Sets a list of all broadcast inputs attached to this node.

setBroadcastInputs(Map<Operator<?>, OptimizerNode>, ExecutionMode) - Method in class org.apache.flink.optimizer.dag.OptimizerNode

This function connects the operators that produce the broadcast inputs to this operator.

setCandidateProperties(GlobalProperties, LocalProperties, Channel) - Method in class org.apache.flink.optimizer.dag.BulkPartialSolutionNode

setCandidateProperties(GlobalProperties, LocalProperties, Channel) - Method in class org.apache.flink.optimizer.dag.SolutionSetNode

setCandidateProperties(GlobalProperties, LocalProperties, Channel) - Method in class org.apache.flink.optimizer.dag.WorksetNode

setComparator(TypeComparatorFactory<?>, int) - Method in class org.apache.flink.optimizer.plan.SingleInputPlanNode

Sets the specified comparator for this PlanNode.

setComparator1(TypeComparatorFactory<?>) - Method in class org.apache.flink.optimizer.plan.DualInputPlanNode

setComparator2(TypeComparatorFactory<?>) - Method in class org.apache.flink.optimizer.plan.DualInputPlanNode

setContainingIterationNode(BulkIterationPlanNode) - Method in class org.apache.flink.optimizer.plan.BulkPartialSolutionPlanNode

setContainingIterationNode(WorksetIterationPlanNode) - Method in class org.apache.flink.optimizer.plan.SolutionSetPlanNode

setContainingIterationNode(WorksetIterationPlanNode) - Method in class org.apache.flink.optimizer.plan.WorksetPlanNode

setCosts(Costs) - Method in class org.apache.flink.optimizer.plan.BulkIterationPlanNode

setCosts(Costs) - Method in class org.apache.flink.optimizer.plan.PlanNode

Sets the basic cost for this node to the given value, and sets the cumulative costs to those costs plus the cost shares of all inputs (regular and broadcast).

setCosts(Costs) - Method in class org.apache.flink.optimizer.plan.SinkJoinerPlanNode

setCosts(Costs) - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

setCpuCost(double) - Method in class org.apache.flink.optimizer.costs.Costs

Sets the cost for the CPU.

setCustomPartitioned(FieldList, Partitioner<?>) - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

setCustomPartitioned(FieldSet, Partitioner<?>) - Method in class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties

Sets these properties to request a custom partitioning with the given Partitioner instance.

setCustomPartitioner(Partitioner<?>) - Method in class org.apache.flink.optimizer.operators.AbstractJoinDescriptor

setCustomPartitioner(Partitioner<?>) - Method in class org.apache.flink.optimizer.operators.CoGroupDescriptor

setDataDistribution(DataDistribution) - Method in class org.apache.flink.optimizer.plan.Channel

setDataExchangeMode(DataExchangeMode) - Method in class org.apache.flink.optimizer.plan.Channel

Sets the data exchange mode (batch / pipelined) to use for the data exchange of this channel.

setDefaultParallelism(int) - Method in class org.apache.flink.optimizer.Optimizer

setDiskCost(double) - Method in class org.apache.flink.optimizer.costs.Costs

Sets the costs for disk for this Costs object.

setDriverKeyInfo(FieldList, boolean[], int) - Method in class org.apache.flink.optimizer.plan.SingleInputPlanNode

Sets the key field information for the specified driver comparator.

setDriverKeyInfo(FieldList, int) - Method in class org.apache.flink.optimizer.plan.SingleInputPlanNode

Sets the key field indexes for the specified driver comparator.

setDriverStrategy(DriverStrategy) - Method in class org.apache.flink.optimizer.plan.PlanNode

Sets the driver strategy for this node.

setEncodeForHTML(boolean) - Method in class org.apache.flink.optimizer.plandump.PlanJSONDumpGenerator

setEstimatedNumRecords(long) - Method in class org.apache.flink.optimizer.dag.OptimizerNode

setEstimatedOutputSize(long) - Method in class org.apache.flink.optimizer.dag.OptimizerNode

setForcedRebalanced() - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

setForceRebalancing() - Method in class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties

setFullyReplicated() - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

setFullyReplicated() - Method in class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties

setGroupedFields(FieldSet) - Method in class org.apache.flink.optimizer.dataproperties.RequestedLocalProperties

Sets the fields that are grouped in these data properties.

setHashPartitioned(FieldList) - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

Sets this global properties to represent a hash partitioning.

setHashPartitioned(FieldSet) - Method in class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties

Sets these properties to request a hash partitioning on the given fields.

setHeuristicCpuCost(double) - Method in class org.apache.flink.optimizer.costs.Costs

Sets the heuristic cost for the CPU.

setHeuristicDiskCost(double) - Method in class org.apache.flink.optimizer.costs.Costs

Sets the heuristic costs for disk for this Costs object.

setHeuristicNetworkCost(double) - Method in class org.apache.flink.optimizer.costs.Costs

Sets the heuristic network cost for this Costs object.

setImmediateSolutionSetUpdate(boolean) - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

setIncomingConnection(DagConnection) - Method in class org.apache.flink.optimizer.dag.SingleInputNode

Sets the connection through which this node receives its input.

setInput(Map<Operator<?>, OptimizerNode>, ExecutionMode) - Method in class org.apache.flink.optimizer.dag.AbstractPartialSolutionNode

setInput(Map<Operator<?>, OptimizerNode>, ExecutionMode) - Method in class org.apache.flink.optimizer.dag.DataSinkNode

setInput(Map<Operator<?>, OptimizerNode>, ExecutionMode) - Method in class org.apache.flink.optimizer.dag.DataSourceNode

setInput(Map<Operator<?>, OptimizerNode>, ExecutionMode) - Method in class org.apache.flink.optimizer.dag.OptimizerNode

This function connects the predecessors to this operator.

setInput(Map<Operator<?>, OptimizerNode>, ExecutionMode) - Method in class org.apache.flink.optimizer.dag.SingleInputNode

setInput(Map<Operator<?>, OptimizerNode>, ExecutionMode) - Method in class org.apache.flink.optimizer.dag.TwoInputNode

setInputs(DagConnection, DagConnection) - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode.SingleRootJoiner

setInterestingProperties(InterestingProperties) - Method in class org.apache.flink.optimizer.dag.DagConnection

Sets the interesting properties for this pact connection.

setLocalStrategy(LocalStrategy) - Method in class org.apache.flink.optimizer.plan.Channel

setLocalStrategy(LocalStrategy, FieldList, boolean[]) - Method in class org.apache.flink.optimizer.plan.Channel

setLocalStrategyComparator(TypeComparatorFactory<?>) - Method in class org.apache.flink.optimizer.plan.Channel

Sets the local strategy comparator for this Channel.

setMaterializationMode(TempMode) - Method in class org.apache.flink.optimizer.dag.DagConnection

setNetworkCost(double) - Method in class org.apache.flink.optimizer.costs.Costs

Sets the network cost for this Costs object.

setNextPartialSolution(OptimizerNode, OptimizerNode) - Method in class org.apache.flink.optimizer.dag.BulkIterationNode

Sets the nextPartialSolution for this BulkIterationNode.

setNextPartialSolution(OptimizerNode, OptimizerNode, ExecutionMode) - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode

setOrdering(Ordering) - Method in class org.apache.flink.optimizer.dataproperties.RequestedLocalProperties

Sets the order for these interesting local properties.

setPairComparator(TypePairComparatorFactory<?, ?>) - Method in class org.apache.flink.optimizer.plan.DualInputPlanNode

setParallelism(int) - Method in class org.apache.flink.optimizer.dag.DataSourceNode

setParallelism(int) - Method in class org.apache.flink.optimizer.dag.OptimizerNode

Sets the parallelism for this optimizer node.

setParallelism(int) - Method in class org.apache.flink.optimizer.plan.PlanNode

setPartialSolution(BulkPartialSolutionNode) - Method in class org.apache.flink.optimizer.dag.BulkIterationNode

Sets the partialSolution for this BulkIterationNode.

setPartialSolution(SolutionSetNode, WorksetNode) - Method in class org.apache.flink.optimizer.dag.WorksetIterationNode

setPruningMarker() - Method in class org.apache.flink.optimizer.plan.PlanNode

Sets the pruning marker to true.

setRandomPartitioned() - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

setRandomPartitioning() - Method in class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties

setRangePartitioned(Ordering) - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

Set the parameters for range partition.

setRangePartitioned(Ordering) - Method in class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties

setRangePartitioned(Ordering, DataDistribution) - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

Set the parameters for range partition.

setRangePartitioned(Ordering, DataDistribution) - Method in class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties

setRelativeMemoryLocalStrategy(double) - Method in class org.apache.flink.optimizer.plan.Channel

setRelativeMemoryPerSubtask(double) - Method in class org.apache.flink.optimizer.plan.PlanNode

Sets the memory dedicated to each task for this node.

setRelativeTempMemory(double) - Method in class org.apache.flink.optimizer.plan.Channel

Sets the memory for materializing the channel's result from this Channel.

setReplicationFactor(int) - Method in class org.apache.flink.optimizer.plan.Channel

Sets the replication factor of the connection.

setRequiredGlobalProps(RequestedGlobalProperties) - Method in class org.apache.flink.optimizer.plan.Channel

setRequiredLocalProps(RequestedLocalProperties) - Method in class org.apache.flink.optimizer.plan.Channel

setSerializer(TypeSerializerFactory<?>) - Method in class org.apache.flink.optimizer.plan.Channel

Sets the serializer for this Channel.

setSerializer(TypeSerializerFactory<?>) - Method in class org.apache.flink.optimizer.plan.SourcePlanNode

Sets the serializer for this PlanNode.

setSerializerForIterationChannel(TypeSerializerFactory<?>) - Method in class org.apache.flink.optimizer.plan.BulkIterationPlanNode

setSerializerForIterationChannel(TypeSerializerFactory<?>) - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

setShipStrategy(ShipStrategyType) - Method in class org.apache.flink.optimizer.dag.DagConnection

Sets the shipping strategy for this connection.

setShipStrategy(ShipStrategyType, FieldList, boolean[], Partitioner<?>, DataExchangeMode) - Method in class org.apache.flink.optimizer.plan.Channel

setShipStrategy(ShipStrategyType, FieldList, boolean[], DataExchangeMode) - Method in class org.apache.flink.optimizer.plan.Channel

setShipStrategy(ShipStrategyType, FieldList, Partitioner<?>, DataExchangeMode) - Method in class org.apache.flink.optimizer.plan.Channel

setShipStrategy(ShipStrategyType, FieldList, DataExchangeMode) - Method in class org.apache.flink.optimizer.plan.Channel

setShipStrategy(ShipStrategyType, DataExchangeMode) - Method in class org.apache.flink.optimizer.plan.Channel

setShipStrategyComparator(TypeComparatorFactory<?>) - Method in class org.apache.flink.optimizer.plan.Channel

Sets the ship strategy comparator for this Channel.

setSolutionSetComparator(TypeComparatorFactory<?>) - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

setSolutionSetSerializer(TypeSerializerFactory<?>) - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

setSource(PlanNode) - Method in class org.apache.flink.optimizer.plan.Channel

setTarget(PlanNode) - Method in class org.apache.flink.optimizer.plan.Channel

Sets the target of this Channel.

setTempMode(TempMode) - Method in class org.apache.flink.optimizer.plan.Channel

Sets the temp mode of the connection.

setWorksetSerializer(TypeSerializerFactory<?>) - Method in class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

SingleInputNode - Class in org.apache.flink.optimizer.dag

A node in the optimizer's program representation for an operation with a single input.

SingleInputNode() - Constructor for class org.apache.flink.optimizer.dag.SingleInputNode

SingleInputNode(SingleInputOperator<?, ?, ?>) - Constructor for class org.apache.flink.optimizer.dag.SingleInputNode

Creates a new node with a single input for the optimizer plan.

SingleInputNode(FieldSet) - Constructor for class org.apache.flink.optimizer.dag.SingleInputNode

SingleInputNode(SingleInputNode) - Constructor for class org.apache.flink.optimizer.dag.SingleInputNode

SingleInputPlanNode - Class in org.apache.flink.optimizer.plan

SingleInputPlanNode(OptimizerNode, String, Channel, DriverStrategy) - Constructor for class org.apache.flink.optimizer.plan.SingleInputPlanNode

SingleInputPlanNode(OptimizerNode, String, Channel, DriverStrategy, FieldList) - Constructor for class org.apache.flink.optimizer.plan.SingleInputPlanNode

SingleInputPlanNode(OptimizerNode, String, Channel, DriverStrategy, FieldList, boolean[]) - Constructor for class org.apache.flink.optimizer.plan.SingleInputPlanNode

SinkJoiner - Class in org.apache.flink.optimizer.dag

This class represents a utility node that is not part of the actual plan.

SinkJoiner(OptimizerNode, OptimizerNode) - Constructor for class org.apache.flink.optimizer.dag.SinkJoiner

SinkJoinerPlanNode - Class in org.apache.flink.optimizer.plan

SinkJoinerPlanNode(SinkJoiner, Channel, Channel) - Constructor for class org.apache.flink.optimizer.plan.SinkJoinerPlanNode

SinkPlanNode - Class in org.apache.flink.optimizer.plan

Plan candidate node for data flow sinks.

SinkPlanNode(DataSinkNode, String, Channel) - Constructor for class org.apache.flink.optimizer.plan.SinkPlanNode

Constructs a new sink candidate node that uses NONE as its local strategy.

SolutionSetDeltaOperator - Class in org.apache.flink.optimizer.operators

SolutionSetDeltaOperator(FieldList) - Constructor for class org.apache.flink.optimizer.operators.SolutionSetDeltaOperator

SolutionSetNode - Class in org.apache.flink.optimizer.dag

The optimizer's internal representation of the solution set of a workset iteration.

SolutionSetNode(DeltaIterationBase.SolutionSetPlaceHolder<?>, WorksetIterationNode) - Constructor for class org.apache.flink.optimizer.dag.SolutionSetNode

SolutionSetPlanNode - Class in org.apache.flink.optimizer.plan

Plan candidate node for partial solution of a bulk iteration.

SolutionSetPlanNode(SolutionSetNode, String, GlobalProperties, LocalProperties, Channel) - Constructor for class org.apache.flink.optimizer.plan.SolutionSetPlanNode

SortMergeFullOuterJoinDescriptor - Class in org.apache.flink.optimizer.operators

SortMergeFullOuterJoinDescriptor(FieldList, FieldList) - Constructor for class org.apache.flink.optimizer.operators.SortMergeFullOuterJoinDescriptor

SortMergeInnerJoinDescriptor - Class in org.apache.flink.optimizer.operators

SortMergeInnerJoinDescriptor(FieldList, FieldList) - Constructor for class org.apache.flink.optimizer.operators.SortMergeInnerJoinDescriptor

SortMergeInnerJoinDescriptor(FieldList, FieldList, boolean, boolean, boolean) - Constructor for class org.apache.flink.optimizer.operators.SortMergeInnerJoinDescriptor

SortMergeLeftOuterJoinDescriptor - Class in org.apache.flink.optimizer.operators

SortMergeLeftOuterJoinDescriptor(FieldList, FieldList) - Constructor for class org.apache.flink.optimizer.operators.SortMergeLeftOuterJoinDescriptor

SortMergeLeftOuterJoinDescriptor(FieldList, FieldList, boolean) - Constructor for class org.apache.flink.optimizer.operators.SortMergeLeftOuterJoinDescriptor

SortMergeRightOuterJoinDescriptor - Class in org.apache.flink.optimizer.operators

SortMergeRightOuterJoinDescriptor(FieldList, FieldList) - Constructor for class org.apache.flink.optimizer.operators.SortMergeRightOuterJoinDescriptor

SortMergeRightOuterJoinDescriptor(FieldList, FieldList, boolean) - Constructor for class org.apache.flink.optimizer.operators.SortMergeRightOuterJoinDescriptor

sortOrders - Variable in class org.apache.flink.optimizer.plan.DualInputPlanNode

SortPartitionDescriptor(Ordering) - Constructor for class org.apache.flink.optimizer.dag.SortPartitionNode.SortPartitionDescriptor

SortPartitionNode - Class in org.apache.flink.optimizer.dag

The optimizer's internal representation of a SortPartition operator node.

SortPartitionNode(SortPartitionOperatorBase<?>) - Constructor for class org.apache.flink.optimizer.dag.SortPartitionNode

SortPartitionNode.SortPartitionDescriptor - Class in org.apache.flink.optimizer.dag

SourcePlanNode - Class in org.apache.flink.optimizer.plan

Plan candidate node for data flow sources that have no input and no special strategies.

SourcePlanNode(DataSourceNode, String) - Constructor for class org.apache.flink.optimizer.plan.SourcePlanNode

Constructs a new source candidate node that uses NONE as its local strategy.

SourcePlanNode(DataSourceNode, String, GlobalProperties, LocalProperties) - Constructor for class org.apache.flink.optimizer.plan.SourcePlanNode

StaticDynamicPathIdentifier - Class in org.apache.flink.optimizer.traversals

A traversal that goes over the program data flow of an iteration and makes the nodes that depend on the partial solution (the data set recomputed in each iteration) as "dynamic" and the other nodes as "static".

StaticDynamicPathIdentifier(int) - Constructor for class org.apache.flink.optimizer.traversals.StaticDynamicPathIdentifier

StepFunctionValidator - Class in org.apache.flink.optimizer.traversals

A traversal that checks if the Workset of a delta iteration is used in the data flow of its step function.

StepFunctionValidator() - Constructor for class org.apache.flink.optimizer.traversals.StepFunctionValidator

subtractCosts(Costs) - Method in class org.apache.flink.optimizer.costs.Costs

Subtracts the given costs from these costs.

swapUnionNodes(PlanNode) - Method in class org.apache.flink.optimizer.plan.Channel

Utility method used while swapping binary union nodes for n-ary union nodes.

T

template - Variable in class org.apache.flink.optimizer.plan.PlanNode

TempMode - Enum in org.apache.flink.optimizer.dag

Enumeration to indicate the mode of temporarily materializing the data that flows across a connection.

toString() - Method in class org.apache.flink.optimizer.costs.Costs

toString() - Method in class org.apache.flink.optimizer.dag.DagConnection

toString() - Method in class org.apache.flink.optimizer.dag.OptimizerNode

toString() - Method in class org.apache.flink.optimizer.dag.OptimizerNode.UnclosedBranchDescriptor

toString() - Method in class org.apache.flink.optimizer.dataproperties.GlobalProperties

toString() - Method in class org.apache.flink.optimizer.dataproperties.InterestingProperties

toString() - Method in class org.apache.flink.optimizer.dataproperties.LocalProperties

toString() - Method in class org.apache.flink.optimizer.dataproperties.RequestedGlobalProperties

toString() - Method in class org.apache.flink.optimizer.dataproperties.RequestedLocalProperties

toString() - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual.GlobalPropertiesPair

toString() - Method in class org.apache.flink.optimizer.operators.OperatorDescriptorDual.LocalPropertiesPair

toString() - Method in class org.apache.flink.optimizer.plan.Channel

toString() - Method in class org.apache.flink.optimizer.plan.PlanNode

traverse(PlanNode) - Method in class org.apache.flink.optimizer.postpass.JavaApiPostPass

TwoInputNode - Class in org.apache.flink.optimizer.dag

A node in the optimizer plan that represents an operator with a two different inputs, such as Join, Cross, CoGroup, or Union.

TwoInputNode(DualInputOperator<?, ?, ?, ?>) - Constructor for class org.apache.flink.optimizer.dag.TwoInputNode

Creates a new two input node for the optimizer plan, representing the given operator.

U

UnaryOperatorNode - Class in org.apache.flink.optimizer.dag

UnaryOperatorNode(String, SingleInputOperator<?, ?, ?>, boolean) - Constructor for class org.apache.flink.optimizer.dag.UnaryOperatorNode

UnaryOperatorNode(String, FieldSet, List<OperatorDescriptorSingle>) - Constructor for class org.apache.flink.optimizer.dag.UnaryOperatorNode

UnaryOperatorNode(String, FieldSet, OperatorDescriptorSingle...) - Constructor for class org.apache.flink.optimizer.dag.UnaryOperatorNode

UnclosedBranchDescriptor(OptimizerNode, long) - Constructor for class org.apache.flink.optimizer.dag.OptimizerNode.UnclosedBranchDescriptor

Creates a new branching descriptor.

UnionParallelismAndForwardEnforcer - Class in org.apache.flink.optimizer.traversals

Enforces that all union nodes have the same parallelism as their successor (there must be only one!) and that the union node and its successor are connected by a forward ship strategy.

UnionParallelismAndForwardEnforcer() - Constructor for class org.apache.flink.optimizer.traversals.UnionParallelismAndForwardEnforcer

UnionSemanticProperties() - Constructor for class org.apache.flink.optimizer.dag.BinaryUnionNode.UnionSemanticProperties

unionsStaticAndDynamicPath() - Method in class org.apache.flink.optimizer.plan.BinaryUnionPlanNode

uniqueFields - Variable in class org.apache.flink.optimizer.dag.OptimizerNode

UNKNOWN - Static variable in class org.apache.flink.optimizer.costs.Costs

updatePropertiesWithUniqueSets(Set<FieldSet>) - Method in class org.apache.flink.optimizer.plan.PlanNode

Utils - Class in org.apache.flink.optimizer.util

Utility class that contains helper methods for optimizer.

UtilSinkJoinOpDescriptor - Class in org.apache.flink.optimizer.operators

UtilSinkJoinOpDescriptor() - Constructor for class org.apache.flink.optimizer.operators.UtilSinkJoinOpDescriptor

V

valueOf(String) - Static method in enum org.apache.flink.optimizer.dag.TempMode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.optimizer.dataproperties.PartitioningProperty

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.optimizer.plan.PlanNode.FeedbackPropertiesMeetRequirementsReport

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.optimizer.plan.PlanNode.SourceAndDamReport

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.flink.optimizer.dag.TempMode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.optimizer.dataproperties.PartitioningProperty

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.optimizer.plan.PlanNode.FeedbackPropertiesMeetRequirementsReport

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.optimizer.plan.PlanNode.SourceAndDamReport

Returns an array containing the constants of this enum type, in the order they are declared.

W

WorksetIterationNode - Class in org.apache.flink.optimizer.dag

A node in the optimizer's program representation for a workset iteration.

WorksetIterationNode(DeltaIterationBase<?, ?>) - Constructor for class org.apache.flink.optimizer.dag.WorksetIterationNode

Creates a new node with a single input for the optimizer plan.

WorksetIterationNode.SingleRootJoiner - Class in org.apache.flink.optimizer.dag

WorksetIterationPlanNode - Class in org.apache.flink.optimizer.plan

A node in the execution, representing a workset iteration (delta iteration).

WorksetIterationPlanNode(WorksetIterationNode, String, Channel, Channel, SolutionSetPlanNode, WorksetPlanNode, PlanNode, PlanNode) - Constructor for class org.apache.flink.optimizer.plan.WorksetIterationPlanNode

WorksetNode - Class in org.apache.flink.optimizer.dag

The optimizer's internal representation of the partial solution that is input to a bulk iteration.

WorksetNode(DeltaIterationBase.WorksetPlaceHolder<?>, WorksetIterationNode) - Constructor for class org.apache.flink.optimizer.dag.WorksetNode

WorksetPlanNode - Class in org.apache.flink.optimizer.plan

Plan candidate node for partial solution of a bulk iteration.

WorksetPlanNode(WorksetNode, String, GlobalProperties, LocalProperties, Channel) - Constructor for class org.apache.flink.optimizer.plan.WorksetPlanNode

A B C D E F G H I J K L M N O P R S T U V W
All Classes All Packages