@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).

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

Transforms for reading and writing from Parquet.