Package org.apache.beam.sdk.io.parquet
Transforms for reading and writing from Parquet.
-
Class Summary Class Description ParquetIO IO to read and write Parquet files.ParquetIO.Parse<T> Implementation ofParquetIO.parseGenericRecords(SerializableFunction).ParquetIO.ParseFiles<T> Implementation ofParquetIO.parseFilesGenericRecords(SerializableFunction).ParquetIO.Read Implementation ofParquetIO.read(Schema).ParquetIO.ReadFiles Implementation ofParquetIO.readFiles(Schema).ParquetIO.ReadFiles.BeamParquetInputFile ParquetIO.ReadFiles.BlockTracker ParquetIO.Sink Implementation ofParquetIO.sink(org.apache.avro.Schema).