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 |
PlanTranslator.canTranslate(Pipeline pipeline) |
boolean |
FlinkPipelineTranslator.canTranslate(Pipeline pipeline) |
static JobGraph |
FlinkPipelineTranslationUtil.getJobGraph(Pipeline pipeline,
Configuration optimizerConfiguration,
int defaultParallelism)
|
JobGraph |
PlanTranslator.translateToJobGraph(Pipeline pipeline,
Configuration optimizerConfiguration,
int defaultParallelism) |
JobGraph |
FlinkPipelineTranslator.translateToJobGraph(Pipeline pipeline,
Configuration optimizerConfiguration,
int defaultParallelism)
|
static String |
FlinkPipelineTranslationUtil.translateToJSONExecutionPlan(Pipeline pipeline)
Extracts the execution plan (as JSON) from the given
Pipeline . |
String |
PlanTranslator.translateToJSONExecutionPlan(Pipeline pipeline) |
String |
FlinkPipelineTranslator.translateToJSONExecutionPlan(Pipeline pipeline)
Extracts the execution plan (as JSON) from the given
Pipeline . |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobClient> |
AbstractJobClusterExecutor.execute(Pipeline pipeline,
Configuration configuration) |
CompletableFuture<? extends JobClient> |
LocalExecutor.execute(Pipeline pipeline,
Configuration configuration) |
CompletableFuture<JobClient> |
AbstractSessionClusterExecutor.execute(Pipeline pipeline,
Configuration configuration) |
static JobGraph |
ExecutorUtils.getJobGraph(Pipeline pipeline,
Configuration configuration)
|
Modifier and Type | Method and Description |
---|---|
Pipeline |
OptimizerPlanEnvironment.getPipeline(PackagedProgram prog,
boolean suppressOutput)
Retrieves the JobGraph from a PackagedProgram.
|
static Pipeline |
PackagedProgramUtils.getPipelineFromProgram(PackagedProgram prog,
Configuration configuration,
int parallelism,
boolean suppressOutput) |
Modifier and Type | Method and Description |
---|---|
void |
OptimizerPlanEnvironment.setPipeline(Pipeline pipeline) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<? extends JobClient> |
PipelineExecutor.execute(Pipeline pipeline,
Configuration configuration)
|
Modifier and Type | Class and Description |
---|---|
class |
StreamGraph
Class representing the streaming topology.
|
Modifier and Type | Method and Description |
---|---|
boolean |
StreamGraphTranslator.canTranslate(Pipeline pipeline) |
JobGraph |
StreamGraphTranslator.translateToJobGraph(Pipeline pipeline,
Configuration optimizerConfiguration,
int defaultParallelism) |
String |
StreamGraphTranslator.translateToJSONExecutionPlan(Pipeline pipeline) |
Modifier and Type | Method and Description |
---|---|
Pipeline |
ExecutionContext.createPipeline(String name) |
Constructor and Description |
---|
ProgramDeployer(Configuration configuration,
String jobName,
Pipeline pipeline)
Deploys a table program on the cluster.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.