Package org.apache.iceberg.parquet
Class Parquet
- java.lang.Object
-
- org.apache.iceberg.parquet.Parquet
-
public class Parquet extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
Parquet.DataWriteBuilder
static class
Parquet.DeleteWriteBuilder
static class
Parquet.ReadBuilder
static class
Parquet.WriteBuilder
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static void
concat(java.lang.Iterable<java.io.File> inputFiles, java.io.File outputFile, int rowGroupSize, Schema schema, java.util.Map<java.lang.String,java.lang.String> metadata)
Combines several files into onestatic Parquet.ReadBuilder
read(InputFile file)
static Parquet.WriteBuilder
write(OutputFile file)
static Parquet.DataWriteBuilder
writeData(OutputFile file)
static Parquet.DeleteWriteBuilder
writeDeletes(OutputFile file)
-
-
-
Method Detail
-
write
public static Parquet.WriteBuilder write(OutputFile file)
-
writeData
public static Parquet.DataWriteBuilder writeData(OutputFile file)
-
writeDeletes
public static Parquet.DeleteWriteBuilder writeDeletes(OutputFile file)
-
read
public static Parquet.ReadBuilder read(InputFile file)
-
concat
public static void concat(java.lang.Iterable<java.io.File> inputFiles, java.io.File outputFile, int rowGroupSize, Schema schema, java.util.Map<java.lang.String,java.lang.String> metadata) throws java.io.IOException
Combines several files into one- Parameters:
inputFiles
- anIterable
of parquet files. The order of iteration determines the order in which content of files are read and written to theoutputFile
outputFile
- the output parquet file containing all the data frominputFiles
rowGroupSize
- the row group size to use when writing theoutputFile
schema
- the schema of the datametadata
- extraMetadata to write at the footer of theoutputFile
- Throws:
java.io.IOException
-
-