org.apache.beam.runners.dataflow.util

Class RowCoderCloudObjectTranslator

java.lang.Object

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

All Implemented Interfaces:

CloudObjectTranslator<RowCoder>

@Experimental(value=SCHEMAS)
public class RowCoderCloudObjectTranslator
extends java.lang.Object
implements CloudObjectTranslator<RowCoder>

Translator for row coders.

Constructor Summary

Constructors

Constructor and Description
RowCoderCloudObjectTranslator()

Method Summary

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

RowCoderCloudObjectTranslator

public RowCoderCloudObjectTranslator()

Method Detail

getSupportedClass

public java.lang.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.runners.core.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 java.lang.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>