org.apache.beam.sdk.schemas.transforms

Class SchemaTransformTranslation.SchemaTransformPayloadTranslator<T extends SchemaTransform>

java.lang.Object

org.apache.beam.sdk.schemas.transforms.SchemaTransformTranslation.SchemaTransformPayloadTranslator<T>

All Implemented Interfaces:

org.apache.beam.sdk.util.construction.PTransformTranslation.TransformPayloadTranslator<T>

Direct Known Subclasses:

BigQuerySchemaTransformTranslation.BigQueryStorageReadSchemaTransformTranslator, BigQuerySchemaTransformTranslation.BigQueryWriteSchemaTransformTranslator, TFRecordSchemaTransformTranslation.TFRecordReadSchemaTransformTranslator, TFRecordSchemaTransformTranslation.TFRecordWriteSchemaTransformTranslator

Enclosing class:

SchemaTransformTranslation

public abstract static class SchemaTransformTranslation.SchemaTransformPayloadTranslator<T extends SchemaTransform>
extends java.lang.Object
implements org.apache.beam.sdk.util.construction.PTransformTranslation.TransformPayloadTranslator<T>

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.sdk.util.construction.PTransformTranslation.TransformPayloadTranslator

org.apache.beam.sdk.util.construction.PTransformTranslation.TransformPayloadTranslator.NotSerializable<T extends PTransform<?,?>>

Constructor Summary

Constructors

Constructor and Description
SchemaTransformPayloadTranslator()

Method Summary

Modifier and Type	Method and Description
T	fromConfigRow(Row configRow, PipelineOptions options)
java.lang.String	getUrn()
abstract SchemaTransformProvider	provider()
@Nullable org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec	translate(org.apache.beam.sdk.runners.AppliedPTransform<?,?,T> application, org.apache.beam.sdk.util.construction.SdkComponents components)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.beam.sdk.util.construction.PTransformTranslation.TransformPayloadTranslator

getUrn, toConfigRow

Constructor Detail

SchemaTransformPayloadTranslator

public SchemaTransformPayloadTranslator()

Method Detail

provider

public abstract SchemaTransformProvider provider()

getUrn

public java.lang.String getUrn()

Specified by:

getUrn in interface org.apache.beam.sdk.util.construction.PTransformTranslation.TransformPayloadTranslator<T extends SchemaTransform>

translate

public @Nullable org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec translate(org.apache.beam.sdk.runners.AppliedPTransform<?,?,T> application,
                                                                                    org.apache.beam.sdk.util.construction.SdkComponents components)
                                                                             throws java.io.IOException

Specified by:

translate in interface org.apache.beam.sdk.util.construction.PTransformTranslation.TransformPayloadTranslator<T extends SchemaTransform>

Throws:

java.io.IOException

fromConfigRow

public T fromConfigRow(Row configRow,
                       PipelineOptions options)

Specified by:

fromConfigRow in interface org.apache.beam.sdk.util.construction.PTransformTranslation.TransformPayloadTranslator<T extends SchemaTransform>