Package org.apache.beam.sdk.schemas.transforms

Class SchemaTransform

java.lang.Object

org.apache.beam.sdk.transforms.PTransform<PCollectionRowTuple,PCollectionRowTuple>

org.apache.beam.sdk.schemas.transforms.SchemaTransform

All Implemented Interfaces:

Serializable, HasDisplayData

Direct Known Subclasses:

BigQueryDirectReadSchemaTransformProvider.BigQueryDirectReadSchemaTransform, BigQueryExportReadSchemaTransformProvider.BigQueryExportSchemaTransform, BigQueryFileLoadsSchemaTransformProvider.BigQueryFileLoadsSchemaTransform, BigQueryStorageWriteApiSchemaTransformProvider.BigQueryStorageWriteApiSchemaTransform, BigQueryWriteSchemaTransformProvider.BigQueryWriteSchemaTransform, CsvWriteTransformProvider.CsvWriteTransform, GenerateSequenceSchemaTransformProvider.GenerateSequenceSchemaTransform, JavaExplodeTransformProvider.ExplodeTransform, JavaFilterTransformProvider.JavaFilterTransform, JavaMapToFieldsTransformProvider.JavaMapToFieldsTransform, JdbcReadSchemaTransformProvider.JdbcReadSchemaTransform, JdbcWriteSchemaTransformProvider.JdbcWriteSchemaTransform, JsonWriteTransformProvider.JsonWriteTransform, LoggingTransformProvider.LoggingTransform

@Internal
public abstract class SchemaTransform
extends PTransform<PCollectionRowTuple,PCollectionRowTuple>

An abstraction representing schema capable and aware transforms. The interface is intended to be used in conjunction with the interface SchemaTransformProvider.

The interfaces can be implemented to make transforms available in other SDKs in addition to Beam SQL.

Internal only: This interface is actively being worked on and it will likely change as we provide implementations for more standard Beam transforms. We provide no backwards compatibility guarantees and it should not be implemented outside of the Beam repository.

See Also:

• Serialized Form

Field Summary

Fields inherited from class org.apache.beam.sdk.transforms.PTransform

annotations, displayData, name, resourceHints

Constructor Summary

Constructors

Constructor	Description
SchemaTransform()

Method Summary

Methods inherited from class org.apache.beam.sdk.transforms.PTransform

addAnnotation, compose, compose, expand, getAdditionalInputs, getAnnotations, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setDisplayData, setResourceHints, toString, validate, validate

Methods inherited from class java.lang.Object

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

Constructor Details

SchemaTransform

public SchemaTransform()