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

Class RowCoderCloudObjectTranslator

java.lang.Object

org.apache.beam.runners.dataflow.util.RowCoderCloudObjectTranslator

All Implemented Interfaces:

CloudObjectTranslator<RowCoder>

public class RowCoderCloudObjectTranslator
extends Object
implements CloudObjectTranslator<RowCoder>

Translator for row coders.

Constructor Summary

Constructors

Constructor	Description
RowCoderCloudObjectTranslator()

Method Summary

Modifier and Type	Method	Description
String	cloudObjectClassName()	Gets the class name that will represent the CloudObject created by this CloudObjectTranslator.
RowCoder	fromCloudObject(CloudObject cloudObject)	Convert from a cloud object.
Class<? extends RowCoder>	getSupportedClass()	Gets the class this CloudObjectTranslator is capable of converting.
CloudObject	toCloudObject(RowCoder 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

RowCoderCloudObjectTranslator

public RowCoderCloudObjectTranslator()

Method Details

getSupportedClass

public Class<? extends RowCoder> getSupportedClass()

Description copied from interface: CloudObjectTranslator

Gets the class this CloudObjectTranslator is capable of converting.

Specified by:

getSupportedClass in interface CloudObjectTranslator<RowCoder>

toCloudObject

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

Convert to a cloud object.

Specified by:

toCloudObject in interface CloudObjectTranslator<RowCoder>

fromCloudObject

public RowCoder fromCloudObject(CloudObject cloudObject)

Convert from a cloud object.

Specified by:

fromCloudObject in interface CloudObjectTranslator<RowCoder>

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<RowCoder>