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–2020 The Apache Software Foundation. All rights reserved.