org.apache.beam.runners.dataflow.util

Interface CloudObjectTranslator<T>

All Known Implementing Classes:

RowCoderCloudObjectTranslator, SchemaCoderCloudObjectTranslator

public interface CloudObjectTranslator<T>

A translator that takes an object and creates a CloudObject which can be converted back to the original object.

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.
T	fromCloudObject(CloudObject cloudObject) Converts back into the original object from a provided CloudObject.
java.lang.Class<? extends T>	getSupportedClass() Gets the class this CloudObjectTranslator is capable of converting.
CloudObject	toCloudObject(T target, org.apache.beam.sdk.util.construction.SdkComponents sdkComponents) Converts the provided object into an equivalent CloudObject.

Method Detail

toCloudObject

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

Converts the provided object into an equivalent CloudObject.

fromCloudObject

T fromCloudObject(CloudObject cloudObject)

Converts back into the original object from a provided CloudObject.

getSupportedClass

java.lang.Class<? extends T> getSupportedClass()

Gets the class this CloudObjectTranslator is capable of converting.

cloudObjectClassName

java.lang.String cloudObjectClassName()

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