public class StreamGraphTranslator extends Object implements FlinkPipelineTranslator
FlinkPipelineTranslator
for DataStream API StreamGraphs
.
Note: this is used through reflection in FlinkPipelineTranslationUtil
.
Constructor and Description |
---|
StreamGraphTranslator() |
Modifier and Type | Method and Description |
---|---|
boolean |
canTranslate(Pipeline pipeline) |
JobGraph |
translateToJobGraph(Pipeline pipeline,
Configuration optimizerConfiguration,
int defaultParallelism)
|
String |
translateToJSONExecutionPlan(Pipeline pipeline)
Extracts the execution plan (as JSON) from the given
Pipeline . |
public JobGraph translateToJobGraph(Pipeline pipeline, Configuration optimizerConfiguration, int defaultParallelism)
FlinkPipelineTranslator
JobGraph
from the given Pipeline
and attaches the given jar files
and classpaths to the JobGraph
.translateToJobGraph
in interface FlinkPipelineTranslator
public String translateToJSONExecutionPlan(Pipeline pipeline)
FlinkPipelineTranslator
Pipeline
.translateToJSONExecutionPlan
in interface FlinkPipelineTranslator
public boolean canTranslate(Pipeline pipeline)
canTranslate
in interface FlinkPipelineTranslator
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.