org.apache.iceberg.parquet

Class Parquet.DeleteWriteBuilder

java.lang.Object

org.apache.iceberg.parquet.Parquet.DeleteWriteBuilder

Enclosing class:

Parquet

public static class Parquet.DeleteWriteBuilder
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
<T> EqualityDeleteWriter<T>	buildEqualityWriter()
<T> PositionDeleteWriter<T>	buildPositionWriter()
Parquet.DeleteWriteBuilder	createWriterFunc(java.util.function.Function<org.apache.parquet.schema.MessageType,ParquetValueWriter<?>> newCreateWriterFunc)
Parquet.DeleteWriteBuilder	equalityFieldIds(int... fieldIds)
Parquet.DeleteWriteBuilder	equalityFieldIds(java.util.List<java.lang.Integer> fieldIds)
Parquet.DeleteWriteBuilder	forTable(Table table)
Parquet.DeleteWriteBuilder	meta(java.lang.String property, java.lang.String value)
Parquet.DeleteWriteBuilder	metricsConfig(MetricsConfig newMetricsConfig)
Parquet.DeleteWriteBuilder	overwrite()
Parquet.DeleteWriteBuilder	overwrite(boolean enabled)
Parquet.DeleteWriteBuilder	rowSchema(Schema newSchema)
Parquet.DeleteWriteBuilder	set(java.lang.String property, java.lang.String value)
Parquet.DeleteWriteBuilder	setAll(java.util.Map<java.lang.String,java.lang.String> properties)
Parquet.DeleteWriteBuilder	transformPaths(java.util.function.Function<java.lang.CharSequence,?> newPathTransformFunc)
Parquet.DeleteWriteBuilder	withKeyMetadata(EncryptionKeyMetadata metadata)
Parquet.DeleteWriteBuilder	withPartition(StructLike key)
Parquet.DeleteWriteBuilder	withSpec(PartitionSpec newSpec)

Methods inherited from class java.lang.Object

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

Method Detail

forTable

public Parquet.DeleteWriteBuilder forTable(Table table)

set

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

setAll

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

meta

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

overwrite

public Parquet.DeleteWriteBuilder overwrite()

overwrite

public Parquet.DeleteWriteBuilder overwrite(boolean enabled)

metricsConfig

public Parquet.DeleteWriteBuilder metricsConfig(MetricsConfig newMetricsConfig)

createWriterFunc

public Parquet.DeleteWriteBuilder createWriterFunc(java.util.function.Function<org.apache.parquet.schema.MessageType,ParquetValueWriter<?>> newCreateWriterFunc)

rowSchema

public Parquet.DeleteWriteBuilder rowSchema(Schema newSchema)

withSpec

public Parquet.DeleteWriteBuilder withSpec(PartitionSpec newSpec)

withPartition

public Parquet.DeleteWriteBuilder withPartition(StructLike key)

withKeyMetadata

public Parquet.DeleteWriteBuilder withKeyMetadata(EncryptionKeyMetadata metadata)

equalityFieldIds

public Parquet.DeleteWriteBuilder equalityFieldIds(java.util.List<java.lang.Integer> fieldIds)

equalityFieldIds

public Parquet.DeleteWriteBuilder equalityFieldIds(int... fieldIds)

transformPaths

public Parquet.DeleteWriteBuilder transformPaths(java.util.function.Function<java.lang.CharSequence,?> newPathTransformFunc)

buildEqualityWriter

public <T> EqualityDeleteWriter<T> buildEqualityWriter()
                                                throws java.io.IOException

Throws:

java.io.IOException

buildPositionWriter

public <T> PositionDeleteWriter<T> buildPositionWriter()
                                                throws java.io.IOException

Throws:

java.io.IOException