public class StreamGraphTranslator extends Object implements FlinkPipelineTranslator
FlinkPipelineTranslator
for DataStream API StreamGraphs
.
Note: this is used through reflection in FlinkPipelineTranslationUtil
.
Constructor and Description |
---|
StreamGraphTranslator(ClassLoader userClassloader) |
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 StreamGraphTranslator(ClassLoader userClassloader)
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–2024 The Apache Software Foundation. All rights reserved.