All Classes
-
All Classes Interface Summary Class Summary Enum Summary Exception Summary Class Description AbstractJoinDescriptor Defines the possible global properties for a join.AbstractOperatorDescriptor The root of all descriptions of an operator to the optimizer.AbstractPartialSolutionNode The optimizer's internal representation of the partial solution that is input to a bulk iteration.AbstractSortMergeJoinDescriptor AllGroupCombineProperties AllGroupReduceProperties AllGroupWithPartialPreGroupProperties AllReduceProperties BinaryUnionNode The Optimizer representation of a binary Union.BinaryUnionNode.UnionSemanticProperties BinaryUnionOpDescriptor BinaryUnionPlanNode A special subclass for the union to make it identifiable.BinaryUnionReplacer A traversal that collects cascading binary unions into a single n-ary union operator.BranchesVisitor This traversal of the optimizer DAG computes the information needed to track branches and joins in the data flow.BulkIterationNode A node in the optimizer's program representation for a bulk iteration.BulkIterationPlanNode BulkPartialSolutionNode The optimizer's internal representation of the partial solution that is input to a bulk iteration.BulkPartialSolutionPlanNode Plan candidate node for partial solution of a bulk iteration.CartesianProductDescriptor Channel A Channel represents the result produced by an operator and the data exchange before the consumption by the target operator.CoGroupDescriptor CoGroupNode The Optimizer representation of a CoGroup operator.CoGroupRawDescriptor CoGroupRawNode The Optimizer representation of a CoGroupRaw operator.CoGroupWithSolutionSetFirstDescriptor CoGroupWithSolutionSetSecondDescriptor CompilerException An exception that is thrown by the Optimizer when encountering an illegal condition.CompilerPostPassException An exception that is thrown by the Optimizer when encountering a problem during the optimizer post pass.ConflictingFieldTypeInfoException CostEstimator Abstract base class for a cost estimator.Costs Simple class to represent the costs of an operation.CrossBlockOuterFirstDescriptor CrossBlockOuterSecondDescriptor CrossNode The Optimizer representation of a Cross (Cartesian product) operator.CrossStreamOuterFirstDescriptor CrossStreamOuterSecondDescriptor DagConnection A connection between two operators.DataSinkNode The Optimizer representation of a data sink.DataSourceNode The optimizer's internal representation of a data source.DataStatistics The collection of access methods that can be used to retrieve statistical information about the data processed in a job.DefaultCostEstimator A default cost estimator that has access to basic size and cardinality estimates.DualInputPlanNode DumpableConnection<T extends DumpableNode<T>> DumpableNode<T extends DumpableNode<T>> EstimateProvider Methods for operators / connections that provide estimated about data size and characteristics.ExecutionPlanJSONGenerator Utility for extracting an execution plan (as JSON) from a givenPlan.FilterDescriptor FilterNode The optimizer's internal representation of a Filter operator node.FlatMapDescriptor FlatMapNode The optimizer's internal representation of a FlatMap operator node.GlobalProperties This class represents global properties of the data at a certain point in the plan.GraphCreatingVisitor This traversal creates the optimizer DAG from a program.GroupCombineNode The optimizer representation of a GroupCombineNode operation.GroupCombineProperties The properties file belonging to the GroupCombineNode.GroupReduceNode The optimizer representation of a GroupReduce operation.GroupReduceProperties GroupReduceWithCombineProperties HashFullOuterJoinBuildFirstDescriptor HashFullOuterJoinBuildSecondDescriptor HashJoinBuildFirstProperties HashJoinBuildSecondProperties HashLeftOuterJoinBuildFirstDescriptor HashLeftOuterJoinBuildSecondDescriptor HashRightOuterJoinBuildFirstDescriptor HashRightOuterJoinBuildSecondDescriptor IdAndEstimatesVisitor This traversal of the optimizer DAG assigns IDs to each node (in a pre-order fashion), and calls each node to compute its estimates.InterestingProperties Interesting properties are propagated from parent operators to child operators.InterestingPropertyVisitor Visitor that computes the interesting properties for each node in the optimizer DAG.IterationNode IterationPlanNode JavaApiPostPass The post-optimizer plan traversal.JobGraphGenerator This component translates the optimizer's resultingOptimizedPlanto aJobGraph.JoinNode The Optimizer representation of a join operator.JsonMapper LocalProperties This class represents local properties of the data.MapDescriptor MapNode The optimizer's internal representation of a Map operator node.MapPartitionDescriptor MapPartitionNode The optimizer's internal representation of a MapPartition operator node.MissingFieldTypeInfoException NamedChannel NAryUnionPlanNode A union operation over multiple inputs (2 or more).NoOpBinaryUdfOp<OUT> NoOpDescriptor NoOpNode The optimizer's internal representation of a No Operation node.NoOpUnaryUdfOp<OUT> OperatorDescriptorDual OperatorDescriptorDual.GlobalPropertiesPair OperatorDescriptorDual.LocalPropertiesPair OperatorDescriptorSingle Abstract base class for Operator descriptions which instantiates the node and sets the driver strategy and the sorting and grouping keys.OptimizedPlan The execution plan generated by the Optimizer.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.OptimizerNode The OptimizerNode is the base class of all nodes in the optimizer DAG.OptimizerNode.UnclosedBranchDescriptor Description of an unclosed branch.OptimizerPostPass Interface for visitors that process the optimizer's plan.OuterJoinNode PartialGroupProperties PartitioningProperty An enumeration of the different types of distributing data across partitions or parallel workers.PartitionNode The optimizer's internal representation of a Partition operator node.PartitionNode.PartitionDescriptor PlanFinalizer This visitor traverses the selected execution plan and finalizes it: The graph of nodes is double-linked (links from child to parent are inserted).PlanJSONDumpGenerator PlanNode The representation of a data exchange between two operators.PlanNode.FeedbackPropertiesMeetRequirementsReport PlanNode.SourceAndDamReport RangePartitionRewriter ReduceNode The Optimizer representation of a Reduce operator.ReduceProperties RequestedGlobalProperties This class represents the global properties of the data that are requested by an operator.RequestedLocalProperties This class represents the local properties of the data that are requested by an operator.SingleInputNode A node in the optimizer's program representation for an operation with a single input.SingleInputPlanNode SinkJoiner This class represents a utility node that is not part of the actual plan.SinkJoinerPlanNode SinkPlanNode Plan candidate node for data flow sinks.SolutionSetDeltaOperator SolutionSetNode The optimizer's internal representation of the solution set of a workset iteration.SolutionSetPlanNode Plan candidate node for partial solution of a bulk iteration.SortMergeFullOuterJoinDescriptor SortMergeInnerJoinDescriptor SortMergeLeftOuterJoinDescriptor SortMergeRightOuterJoinDescriptor SortPartitionNode The optimizer's internal representation of a SortPartition operator node.SortPartitionNode.SortPartitionDescriptor SourcePlanNode Plan candidate node for data flow sources that have no input and no special strategies.StaticDynamicPathIdentifier 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".StepFunctionValidator A traversal that checks if the Workset of a delta iteration is used in the data flow of its step function.TempMode Enumeration to indicate the mode of temporarily materializing the data that flows across a connection.TwoInputNode A node in the optimizer plan that represents an operator with a two different inputs, such as Join, Cross, CoGroup, or Union.UnaryOperatorNode UnionParallelismAndForwardEnforcer 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.Utils Utility class that contains helper methods for optimizer.UtilSinkJoinOpDescriptor WorksetIterationNode A node in the optimizer's program representation for a workset iteration.WorksetIterationNode.SingleRootJoiner WorksetIterationPlanNode A node in the execution, representing a workset iteration (delta iteration).WorksetNode The optimizer's internal representation of the partial solution that is input to a bulk iteration.WorksetPlanNode Plan candidate node for partial solution of a bulk iteration.