Package org.apache.flink.client
Class StreamGraphTranslator
- java.lang.Object
-
- org.apache.flink.client.StreamGraphTranslator
-
- All Implemented Interfaces:
FlinkPipelineTranslator
public class StreamGraphTranslator extends Object implements FlinkPipelineTranslator
FlinkPipelineTranslatorfor DataStream APIStreamGraphs.Note: this is used through reflection in
FlinkPipelineTranslationUtil.
-
-
Constructor Summary
Constructors Constructor Description StreamGraphTranslator(ClassLoader userClassloader)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleancanTranslate(org.apache.flink.api.dag.Pipeline pipeline)org.apache.flink.runtime.jobgraph.JobGraphtranslateToJobGraph(org.apache.flink.api.dag.Pipeline pipeline, org.apache.flink.configuration.Configuration optimizerConfiguration, int defaultParallelism)Creates aJobGraphfrom the givenPipelineand attaches the given jar files and classpaths to theJobGraph.StringtranslateToJSONExecutionPlan(org.apache.flink.api.dag.Pipeline pipeline)Extracts the execution plan (as JSON) from the givenPipeline.
-
-
-
Constructor Detail
-
StreamGraphTranslator
public StreamGraphTranslator(ClassLoader userClassloader)
-
-
Method Detail
-
translateToJobGraph
public org.apache.flink.runtime.jobgraph.JobGraph translateToJobGraph(org.apache.flink.api.dag.Pipeline pipeline, org.apache.flink.configuration.Configuration optimizerConfiguration, int defaultParallelism)Description copied from interface:FlinkPipelineTranslatorCreates aJobGraphfrom the givenPipelineand attaches the given jar files and classpaths to theJobGraph.- Specified by:
translateToJobGraphin interfaceFlinkPipelineTranslator
-
translateToJSONExecutionPlan
public String translateToJSONExecutionPlan(org.apache.flink.api.dag.Pipeline pipeline)
Description copied from interface:FlinkPipelineTranslatorExtracts the execution plan (as JSON) from the givenPipeline.- Specified by:
translateToJSONExecutionPlanin interfaceFlinkPipelineTranslator
-
canTranslate
public boolean canTranslate(org.apache.flink.api.dag.Pipeline pipeline)
- Specified by:
canTranslatein interfaceFlinkPipelineTranslator
-
-