StreamGraphTranslator (Flink : Clients 1.18.1-cp5 API)

java.lang.Object
- org.apache.flink.client.StreamGraphTranslator

All Implemented Interfaces:

FlinkPipelineTranslator
```
public class StreamGraphTranslator
extends Object
implements FlinkPipelineTranslator
```
FlinkPipelineTranslator for DataStream API StreamGraphs.
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
`boolean`	`canTranslate(org.apache.flink.api.dag.Pipeline pipeline)`
`org.apache.flink.runtime.jobgraph.JobGraph`	`translateToJobGraph(org.apache.flink.api.dag.Pipeline pipeline, org.apache.flink.configuration.Configuration optimizerConfiguration, int defaultParallelism)`	Creates a `JobGraph` from the given `Pipeline` and attaches the given jar files and classpaths to the `JobGraph`.
`String`	`translateToJSONExecutionPlan(org.apache.flink.api.dag.Pipeline pipeline)`	Extracts the execution plan (as JSON) from the given `Pipeline`.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 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: FlinkPipelineTranslator
    
    Creates a JobGraph from the given Pipeline and attaches the given jar files and classpaths to the JobGraph.
    
    Specified by:
    
    translateToJobGraph in interface FlinkPipelineTranslator
  - translateToJSONExecutionPlan
```
public String translateToJSONExecutionPlan(org.apache.flink.api.dag.Pipeline pipeline)
```
    Description copied from interface: FlinkPipelineTranslator
    
    Extracts the execution plan (as JSON) from the given Pipeline.
    
    Specified by:
    
    translateToJSONExecutionPlan in interface FlinkPipelineTranslator
  - canTranslate
```
public boolean canTranslate(org.apache.flink.api.dag.Pipeline pipeline)
```
    Specified by:
    
    canTranslate in interface FlinkPipelineTranslator