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 java.lang.Object

Method Summary

Modifier and Type	Method and Description
<D> FileAppender<D>	build()
Parquet.WriteBuilder	createWriterFunc(java.util.function.Function<org.apache.parquet.schema.MessageType,ParquetValueWriter<?>> newCreateWriterFunc)
Parquet.WriteBuilder	forTable(Table table)
Parquet.WriteBuilder	meta(java.lang.String property, java.lang.String value)
Parquet.WriteBuilder	metricsConfig(MetricsConfig newMetricsConfig)
Parquet.WriteBuilder	named(java.lang.String newName)
Parquet.WriteBuilder	overwrite()
Parquet.WriteBuilder	overwrite(boolean enabled)
Parquet.WriteBuilder	schema(Schema newSchema)
Parquet.WriteBuilder	set(java.lang.String property, java.lang.String value)
Parquet.WriteBuilder	setAll(java.util.Map<java.lang.String,java.lang.String> properties)
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 Detail

forTable

public Parquet.WriteBuilder forTable(Table table)

schema

public Parquet.WriteBuilder schema(Schema newSchema)

named

public Parquet.WriteBuilder named(java.lang.String newName)

writeSupport

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

set

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

setAll

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

meta

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

createWriterFunc

public Parquet.WriteBuilder createWriterFunc(java.util.function.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)

build

public <D> FileAppender<D> build()
                          throws java.io.IOException

Throws:

java.io.IOException