Package | Description |
---|---|
org.apache.flink.client.program | |
org.apache.flink.optimizer | |
org.apache.flink.optimizer.dag | |
org.apache.flink.optimizer.postpass | |
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.
|
Class and Description |
---|
CompilerException
An exception that is thrown by the Optimizer when encountering an illegal condition.
|
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.
|
Class and Description |
---|
CompilerException
An exception that is thrown by the Optimizer when encountering an illegal condition.
|
DataStatistics
The collection of access methods that can be used to retrieve statistical information about the
data processed in a job.
|
Class and Description |
---|
CompilerException
An exception that is thrown by the Optimizer when encountering an illegal condition.
|
DataStatistics
The collection of access methods that can be used to retrieve statistical information about the
data processed in a job.
|
Class and Description |
---|
CompilerPostPassException
An exception that is thrown by the Optimizer when encountering
a problem during the optimizer post pass.
|
Class and Description |
---|
DataStatistics
The collection of access methods that can be used to retrieve statistical information about the
data processed in a job.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.