Package 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 Details

    • 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

      Class<? extends T> getSupportedClass()
      Gets the class this CloudObjectTranslator is capable of converting.

    • cloudObjectClassName

      String cloudObjectClassName()
      Gets the class name that will represent the CloudObject created by this CloudObjectTranslator.