Package org.apache.beam.runners.dataflow.util

Class SchemaCoderCloudObjectTranslator

java.lang.Object

org.apache.beam.runners.dataflow.util.SchemaCoderCloudObjectTranslator

All Implemented Interfaces:

CloudObjectTranslator<SchemaCoder>

public class SchemaCoderCloudObjectTranslator
extends Object
implements CloudObjectTranslator<SchemaCoder>

Translator for Schema coders.

Constructor Summary

Constructors

Constructor	Description
SchemaCoderCloudObjectTranslator()

Method Summary

Modifier and Type	Method	Description
String	cloudObjectClassName()	Gets the class name that will represent the CloudObject created by this CloudObjectTranslator.
SchemaCoder	fromCloudObject(CloudObject cloudObject)	Convert from a cloud object.
Class<? extends SchemaCoder>	getSupportedClass()	Gets the class this CloudObjectTranslator is capable of converting.
CloudObject	toCloudObject(SchemaCoder target, org.apache.beam.sdk.util.construction.SdkComponents sdkComponents)	Convert to a cloud object.

Methods inherited from class java.lang.Object

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

Constructor Details

SchemaCoderCloudObjectTranslator

public SchemaCoderCloudObjectTranslator()

Method Details

toCloudObject

public CloudObject toCloudObject(SchemaCoder target,
 org.apache.beam.sdk.util.construction.SdkComponents sdkComponents)

Convert to a cloud object.

Specified by:

toCloudObject in interface CloudObjectTranslator<SchemaCoder>

fromCloudObject

public SchemaCoder fromCloudObject(CloudObject cloudObject)

Convert from a cloud object.

Specified by:

fromCloudObject in interface CloudObjectTranslator<SchemaCoder>

getSupportedClass

public Class<? extends SchemaCoder> getSupportedClass()

Description copied from interface: CloudObjectTranslator

Gets the class this CloudObjectTranslator is capable of converting.

Specified by:

getSupportedClass in interface CloudObjectTranslator<SchemaCoder>

cloudObjectClassName

public String cloudObjectClassName()

Description copied from interface: CloudObjectTranslator

Gets the class name that will represent the CloudObject created by this CloudObjectTranslator.

Specified by:

cloudObjectClassName in interface CloudObjectTranslator<SchemaCoder>