@Experimental(value=SOURCE_SINK)

Package org.apache.beam.sdk.io.parquet

Transforms for reading and writing from Parquet.

See: Description

Class Summary

Class	Description
ParquetIO	IO to read and write Parquet files.
ParquetIO.Parse<T>	Implementation of ParquetIO.parseGenericRecords(SerializableFunction).
ParquetIO.ParseFiles<T>	Implementation of ParquetIO.parseFilesGenericRecords(SerializableFunction).
ParquetIO.Read	Implementation of ParquetIO.read(Schema).
ParquetIO.ReadFiles	Implementation of ParquetIO.readFiles(Schema).
ParquetIO.ReadFiles.BlockTracker
ParquetIO.Sink	Implementation of ParquetIO.sink(org.apache.avro.Schema).
ParquetSchemaIOProvider	An implementation of SchemaIOProvider for reading and writing parquet files with ParquetIO.

Package org.apache.beam.sdk.io.parquet Description

Transforms for reading and writing from Parquet.