DataflowPipelineTranslator (Google Cloud Dataflow SDK API)

java.lang.Object
- com.google.cloud.dataflow.sdk.runners.DataflowPipelineTranslator

```
public class DataflowPipelineTranslator
extends java.lang.Object
```
DataflowPipelineTranslator knows how to translate Pipeline objects into Dataflow API Jobs.

Nested Class Summary

Nested Classes
Modifier and Type	Class and Description
`static interface`	`DataflowPipelineTranslator.TransformTranslator<PT extends PTransform>` A translator of a `PTransform`.
`static interface`	`DataflowPipelineTranslator.TranslationContext` The interface provided to registered callbacks for interacting with the `DataflowPipelineRunner`, including reading and writing the values of `PCollection`s and side inputs (`PCollectionView`s).

Method Summary

Methods
Modifier and Type	Method and Description
`static DataflowPipelineTranslator`	`fromOptions(DataflowPipelineOptions options)` Constructs a translator from the provided options.
`<PT extends PTransform> DataflowPipelineTranslator.TransformTranslator<PT>`	`getTransformTranslator(java.lang.Class<PT> transformClass)` Returns the TransformTranslator to use for instances of the specified PTransform class, or null if none registered.
`static java.lang.String`	`jobToString(com.google.api.services.dataflow.model.Job job)`
`static <PT extends PTransform> void`	`registerTransformTranslator(java.lang.Class<PT> transformClass, DataflowPipelineTranslator.TransformTranslator<? extends PT> transformTranslator)` Records that instances of the specified PTransform class should be translated by default by the corresponding TransformTranslator.
`java.lang.String`	`toString()`
`com.google.api.services.dataflow.model.Job`	`translate(Pipeline pipeline, java.util.List<com.google.api.services.dataflow.model.DataflowPackage> packages)` Translates a `Pipeline` into a `Job`.

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

Method Detail

fromOptions
```
public static DataflowPipelineTranslator fromOptions(DataflowPipelineOptions options)
```
Constructs a translator from the provided options.

Parameters:
options - Properties which configure the translator.

Returns:
The newly created translator.

translate

public com.google.api.services.dataflow.model.Job translate(Pipeline pipeline,
                                                   java.util.List<com.google.api.services.dataflow.model.DataflowPackage> packages)

Translates a Pipeline into a Job.

jobToString

public static java.lang.String jobToString(com.google.api.services.dataflow.model.Job job)
                                    throws com.fasterxml.jackson.core.JsonProcessingException

Throws:: com.fasterxml.jackson.core.JsonProcessingException

registerTransformTranslator

public static <PT extends PTransform> void registerTransformTranslator(java.lang.Class<PT> transformClass,
                                                       DataflowPipelineTranslator.TransformTranslator<? extends PT> transformTranslator)

Records that instances of the specified PTransform class should be translated by default by the corresponding TransformTranslator.

getTransformTranslator

public <PT extends PTransform> DataflowPipelineTranslator.TransformTranslator<PT> getTransformTranslator(java.lang.Class<PT> transformClass)

Returns the TransformTranslator to use for instances of the specified PTransform class, or null if none registered.

toString
```
public java.lang.String toString()
```
Overrides:

toString in class java.lang.Object

Class DataflowPipelineTranslator