Package org.apache.iceberg.parquet

Class Parquet.WriteBuilder

java.lang.Object

org.apache.iceberg.parquet.Parquet.WriteBuilder

Enclosing class:

Parquet

public static class Parquet.WriteBuilder
extends Object

Method Summary

Modifier and Type	Method	Description
<D> FileAppender<D>	build()
Parquet.WriteBuilder	createWriterFunc(Function<org.apache.parquet.schema.MessageType,ParquetValueWriter<?>> newCreateWriterFunc)
Parquet.WriteBuilder	forTable(Table table)
Parquet.WriteBuilder	meta(String property, String value)
Parquet.WriteBuilder	metricsConfig(MetricsConfig newMetricsConfig)
Parquet.WriteBuilder	named(String newName)
Parquet.WriteBuilder	overwrite()
Parquet.WriteBuilder	overwrite(boolean enabled)
Parquet.WriteBuilder	schema(Schema newSchema)
Parquet.WriteBuilder	set(String property, String value)
Parquet.WriteBuilder	setAll(Map<String,String> properties)
Parquet.WriteBuilder	withAADPrefix(ByteBuffer aadPrefix)
Parquet.WriteBuilder	withFileEncryptionKey(ByteBuffer encryptionKey)
Parquet.WriteBuilder	writerVersion(org.apache.parquet.column.ParquetProperties.WriterVersion version)
Parquet.WriteBuilder	writeSupport(org.apache.parquet.hadoop.api.WriteSupport<?> newWriteSupport)

Methods inherited from class java.lang.Object

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

Method Details

forTable

public Parquet.WriteBuilder forTable(Table table)

schema

public Parquet.WriteBuilder schema(Schema newSchema)

named

public Parquet.WriteBuilder named(String newName)

writeSupport

public Parquet.WriteBuilder writeSupport(org.apache.parquet.hadoop.api.WriteSupport<?> newWriteSupport)

set

public Parquet.WriteBuilder set(String property,
 String value)

setAll

public Parquet.WriteBuilder setAll(Map<String,String> properties)

meta

public Parquet.WriteBuilder meta(String property,
 String value)

createWriterFunc

public Parquet.WriteBuilder createWriterFunc(Function<org.apache.parquet.schema.MessageType,ParquetValueWriter<?>> newCreateWriterFunc)

metricsConfig

public Parquet.WriteBuilder metricsConfig(MetricsConfig newMetricsConfig)

overwrite

public Parquet.WriteBuilder overwrite()

overwrite

public Parquet.WriteBuilder overwrite(boolean enabled)

writerVersion

public Parquet.WriteBuilder writerVersion(org.apache.parquet.column.ParquetProperties.WriterVersion version)

withFileEncryptionKey

public Parquet.WriteBuilder withFileEncryptionKey(ByteBuffer encryptionKey)

withAADPrefix

public Parquet.WriteBuilder withAADPrefix(ByteBuffer aadPrefix)

build

public <D> FileAppender<D> build()
                          throws IOException

Throws:

IOException