Package org.apache.iceberg.parquet

Class Parquet

java.lang.Object

org.apache.iceberg.parquet.Parquet

public class Parquet
extends 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

Modifier and Type	Method	Description
static void	concat(Iterable<File> inputFiles, File outputFile, int rowGroupSize, Schema schema, Map<String,String> metadata)	Combines several files into one
static Parquet.ReadBuilder	read(InputFile file)
static Parquet.WriteBuilder	write(EncryptedOutputFile file)
static Parquet.WriteBuilder	write(OutputFile file)
static Parquet.DataWriteBuilder	writeData(EncryptedOutputFile file)
static Parquet.DataWriteBuilder	writeData(OutputFile file)
static Parquet.DeleteWriteBuilder	writeDeletes(EncryptedOutputFile file)
static Parquet.DeleteWriteBuilder	writeDeletes(OutputFile file)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

write

public static Parquet.WriteBuilder write(OutputFile file)

write

public static Parquet.WriteBuilder write(EncryptedOutputFile file)

writeData

public static Parquet.DataWriteBuilder writeData(OutputFile file)

writeData

public static Parquet.DataWriteBuilder writeData(EncryptedOutputFile file)

writeDeletes

public static Parquet.DeleteWriteBuilder writeDeletes(OutputFile file)

writeDeletes

public static Parquet.DeleteWriteBuilder writeDeletes(EncryptedOutputFile file)

read

public static Parquet.ReadBuilder read(InputFile file)

concat

public static void concat(Iterable<File> inputFiles,
 File outputFile,
 int rowGroupSize,
 Schema schema,
 Map<String,String> metadata)
                   throws IOException

Combines several files into one

Parameters:

inputFiles - an Iterable of parquet files. The order of iteration determines the order in which content of files are read and written to the outputFile

outputFile - the output parquet file containing all the data from inputFiles

rowGroupSize - the row group size to use when writing the outputFile

schema - the schema of the data

metadata - extraMetadata to write at the footer of the outputFile

Throws:

IOException