org.apache.beam.sdk.schemas.transforms

Interface SchemaTransform

@Internal
 @Experimental(value=SCHEMAS)
public interface SchemaTransform

An abstraction to create 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.

Method Summary

Modifier and Type	Method and Description
PTransform<PCollectionRowTuple,PCollectionRowTuple>	buildTransform()

Method Detail

buildTransform

PTransform<PCollectionRowTuple,PCollectionRowTuple> buildTransform()