com.google.cloud.dataflow.sdk.runners.dataflow

Class PubsubIOTranslator.WriteTranslator<T>

java.lang.Object

com.google.cloud.dataflow.sdk.runners.dataflow.PubsubIOTranslator.WriteTranslator<T>

All Implemented Interfaces:

DataflowPipelineTranslator.TransformTranslator<DataflowPipelineRunner.StreamingPubsubIOWrite<T>>

Enclosing class:

PubsubIOTranslator

public static class PubsubIOTranslator.WriteTranslator<T>
extends Object
implements DataflowPipelineTranslator.TransformTranslator<DataflowPipelineRunner.StreamingPubsubIOWrite<T>>

Implements PubsubIO Write translation for the Dataflow backend.

Constructor Summary

Constructors

Constructor and Description
WriteTranslator()

Method Summary

Modifier and Type	Method and Description
void	translate(DataflowPipelineRunner.StreamingPubsubIOWrite transform, DataflowPipelineTranslator.TranslationContext context)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WriteTranslator

public WriteTranslator()

Method Detail

translate

public void translate(DataflowPipelineRunner.StreamingPubsubIOWrite transform,
                      DataflowPipelineTranslator.TranslationContext context)

Specified by:

translate in interface DataflowPipelineTranslator.TransformTranslator<DataflowPipelineRunner.StreamingPubsubIOWrite<T>>