Package org.apache.beam.sdk.io.fileschematransform

Interface FileReadSchemaTransformFormatProvider

All Superinterfaces:

Providers.Identifyable

All Known Implementing Classes:

AvroReadSchemaTransformFormatProvider, JsonReadSchemaTransformFormatProvider, LineReadSchemaTransformFormatProvider, ParquetReadSchemaTransformFormatProvider

public interface FileReadSchemaTransformFormatProvider
extends Providers.Identifyable

Interface that provides a PTransform that reads in a PCollection of FileIO.ReadableFiles and outputs the data represented as a PCollection of Rows. Is implemented by a registered AutoService FileReadSchemaTransformFormatProvider.

Method Summary

Modifier and Type	Method	Description
PTransform<PCollection<FileIO.ReadableFile>,PCollection<Row>>	buildTransform(FileReadSchemaTransformConfiguration configuration)

Methods inherited from interface org.apache.beam.sdk.schemas.io.Providers.Identifyable

identifier

Method Details

buildTransform

PTransform<PCollection<FileIO.ReadableFile>,PCollection<Row>> buildTransform(FileReadSchemaTransformConfiguration configuration)