Modifier and Type | Class and Description |
---|---|
class |
Plan
This class represents Flink programs, in the form of dataflow plans.
|
Modifier and Type | Method and Description |
---|---|
boolean |
StreamGraphTranslator.canTranslate(Pipeline pipeline) |
boolean |
FlinkPipelineTranslator.canTranslate(Pipeline pipeline) |
boolean |
PlanTranslator.canTranslate(Pipeline pipeline) |
static JobGraph |
FlinkPipelineTranslationUtil.getJobGraph(Pipeline pipeline,
Configuration optimizerConfiguration,
int defaultParallelism)
|
static JobGraph |
FlinkPipelineTranslationUtil.getJobGraphUnderUserClassLoader(ClassLoader userClassloader,
Pipeline pipeline,
Configuration configuration,
int defaultParallelism)
|
JobGraph |
StreamGraphTranslator.translateToJobGraph(Pipeline pipeline,
Configuration optimizerConfiguration,
int defaultParallelism) |
JobGraph |
FlinkPipelineTranslator.translateToJobGraph(Pipeline pipeline,
Configuration optimizerConfiguration,
int defaultParallelism)
|
JobGraph |
PlanTranslator.translateToJobGraph(Pipeline pipeline,
Configuration optimizerConfiguration,
int defaultParallelism) |
static String |
FlinkPipelineTranslationUtil.translateToJSONExecutionPlan(Pipeline pipeline)
Extracts the execution plan (as JSON) from the given
Pipeline . |
String |
StreamGraphTranslator.translateToJSONExecutionPlan(Pipeline pipeline) |
String |
FlinkPipelineTranslator.translateToJSONExecutionPlan(Pipeline pipeline)
Extracts the execution plan (as JSON) from the given
Pipeline . |
String |
PlanTranslator.translateToJSONExecutionPlan(Pipeline pipeline) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobClient> |
EmbeddedExecutor.execute(Pipeline pipeline,
Configuration configuration,
ClassLoader userCodeClassloader) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobClient> |
LocalExecutor.execute(Pipeline pipeline,
Configuration configuration,
ClassLoader userCodeClassloader) |
CompletableFuture<JobClient> |
AbstractJobClusterExecutor.execute(Pipeline pipeline,
Configuration configuration,
ClassLoader userCodeClassloader) |
CompletableFuture<JobClient> |
AbstractSessionClusterExecutor.execute(Pipeline pipeline,
Configuration configuration,
ClassLoader userCodeClassloader) |
static JobGraph |
PipelineExecutorUtils.getJobGraph(Pipeline pipeline,
Configuration configuration)
|
Modifier and Type | Method and Description |
---|---|
Pipeline |
OptimizerPlanEnvironment.getPipeline() |
Pipeline |
StreamPlanEnvironment.getPipeline() |
static Pipeline |
PackagedProgramUtils.getPipelineFromProgram(PackagedProgram program,
Configuration configuration,
int parallelism,
boolean suppressOutput) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobClient> |
PipelineExecutor.execute(Pipeline pipeline,
Configuration configuration,
ClassLoader userCodeClassloader)
|
Modifier and Type | Class and Description |
---|---|
class |
StreamGraph
Class representing the streaming topology.
|
Modifier and Type | Method and Description |
---|---|
Pipeline |
StreamTableEnvironmentImpl.getPipeline(String jobName)
This method is used for sql client to submit job.
|
Modifier and Type | Method and Description |
---|---|
Pipeline |
ExecutionContext.createPipeline(String name) |
Constructor and Description |
---|
ProgramDeployer(Configuration configuration,
String jobName,
Pipeline pipeline,
ClassLoader userCodeClassloader)
Deploys a table program on the cluster.
|
Modifier and Type | Method and Description |
---|---|
Pipeline |
Executor.createPipeline(List<Transformation<?>> transformations,
TableConfig tableConfig,
String jobName)
Translates the given transformations to a Pipeline.
|
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
Executor.execute(Pipeline pipeline)
Executes the given pipeline.
|
JobClient |
Executor.executeAsync(Pipeline pipeline)
Executes the given pipeline asynchronously.
|
Modifier and Type | Method and Description |
---|---|
Pipeline |
StreamExecutor.createPipeline(List<Transformation<?>> transformations,
TableConfig tableConfig,
String jobName) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
StreamExecutor.execute(Pipeline pipeline) |
JobClient |
StreamExecutor.executeAsync(Pipeline pipeline) |
Modifier and Type | Method and Description |
---|---|
Pipeline |
BatchExecutor.createPipeline(List<Transformation<?>> transformations,
TableConfig tableConfig,
String jobName) |
Pipeline |
StreamExecutor.createPipeline(List<Transformation<?>> transformations,
TableConfig tableConfig,
String jobName) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
ExecutorBase.execute(Pipeline pipeline) |
JobClient |
ExecutorBase.executeAsync(Pipeline pipeline) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.