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 java.lang.Object
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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)
-
-
-
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
-
-