Package org.apache.iceberg.avro
Class Avro.WriteBuilder
- java.lang.Object
-
- org.apache.iceberg.avro.Avro.WriteBuilder
-
- Enclosing class:
- Avro
public static class Avro.WriteBuilder extends java.lang.Object
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <D> FileAppender<D>
build()
Avro.WriteBuilder
createWriterFunc(java.util.function.Function<org.apache.avro.Schema,org.apache.avro.io.DatumWriter<?>> writerFunction)
Avro.WriteBuilder
forTable(Table table)
Avro.WriteBuilder
meta(java.lang.String property, java.lang.String value)
Avro.WriteBuilder
meta(java.util.Map<java.lang.String,java.lang.String> properties)
Avro.WriteBuilder
metricsConfig(MetricsConfig newMetricsConfig)
Avro.WriteBuilder
named(java.lang.String newName)
Avro.WriteBuilder
overwrite()
Avro.WriteBuilder
overwrite(boolean enabled)
Avro.WriteBuilder
schema(Schema newSchema)
Avro.WriteBuilder
set(java.lang.String property, java.lang.String value)
Avro.WriteBuilder
setAll(java.util.Map<java.lang.String,java.lang.String> properties)
-
-
-
Method Detail
-
forTable
public Avro.WriteBuilder forTable(Table table)
-
schema
public Avro.WriteBuilder schema(Schema newSchema)
-
named
public Avro.WriteBuilder named(java.lang.String newName)
-
createWriterFunc
public Avro.WriteBuilder createWriterFunc(java.util.function.Function<org.apache.avro.Schema,org.apache.avro.io.DatumWriter<?>> writerFunction)
-
set
public Avro.WriteBuilder set(java.lang.String property, java.lang.String value)
-
setAll
public Avro.WriteBuilder setAll(java.util.Map<java.lang.String,java.lang.String> properties)
-
meta
public Avro.WriteBuilder meta(java.lang.String property, java.lang.String value)
-
meta
public Avro.WriteBuilder meta(java.util.Map<java.lang.String,java.lang.String> properties)
-
metricsConfig
public Avro.WriteBuilder metricsConfig(MetricsConfig newMetricsConfig)
-
overwrite
public Avro.WriteBuilder overwrite()
-
overwrite
public Avro.WriteBuilder overwrite(boolean enabled)
-
build
public <D> FileAppender<D> build() throws java.io.IOException
- Throws:
java.io.IOException
-
-