Package org.apache.beam.sdk.schemas.io

Interface SchemaIO

All Known Implementing Classes:

DataStoreV1SchemaIOProvider.DataStoreV1SchemaIO

@Internal
public interface SchemaIO

An abstraction to create schema capable and aware IOs. The interface is intended to be used in conjunction with the interface SchemaIOProvider.

The interfaces can be implemented to make IOs 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 IOs. We provide no backwards compatibility guarantees and it should not be implemented outside of the Beam repository.

For a detailed walkthrough of implementation, see s.apache.org/schemaio-development-guide

Method Summary

Modifier and Type	Method	Description
PTransform<PBegin,PCollection<Row>>	buildReader()	Returns a schema aware reader.
PTransform<PCollection<Row>,? extends POutput>	buildWriter()	Returns a schema aware writer.
Schema	schema()	Returns the schema of the data.

Method Details

schema

Schema schema()

Returns the schema of the data.

buildReader

PTransform<PBegin,PCollection<Row>> buildReader()

Returns a schema aware reader.

buildWriter

PTransform<PCollection<Row>,? extends POutput> buildWriter()

Returns a schema aware writer.