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

Interface SchemaTransform

  • @Internal
@Experimental(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.