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

Class AvroIOTranslator.ReadTranslator

java.lang.Object

com.google.cloud.dataflow.sdk.runners.dataflow.AvroIOTranslator.ReadTranslator

All Implemented Interfaces:

DataflowPipelineTranslator.TransformTranslator<AvroIO.Read.Bound>

Enclosing class:

AvroIOTranslator

public static class AvroIOTranslator.ReadTranslator
extends Object
implements DataflowPipelineTranslator.TransformTranslator<AvroIO.Read.Bound>

Implements AvroIO Read translation for the Dataflow backend.

Constructor Summary

Constructors

Constructor and Description
ReadTranslator()

Method Summary

Modifier and Type	Method and Description
void	translate(AvroIO.Read.Bound transform, DataflowPipelineTranslator.TranslationContext context)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReadTranslator

public ReadTranslator()

Method Detail

translate

public void translate(AvroIO.Read.Bound transform,
                      DataflowPipelineTranslator.TranslationContext context)

Specified by:

translate in interface DataflowPipelineTranslator.TransformTranslator<AvroIO.Read.Bound>