Package 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 Object

Method Summary

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

Methods inherited from class java.lang.Object

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

Method Details

forTable

public Parquet.DeleteWriteBuilder forTable(Table table)

set

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

setAll

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

meta

public Parquet.DeleteWriteBuilder meta(String property,
 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(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)

withFileEncryptionKey

public Parquet.DeleteWriteBuilder withFileEncryptionKey(ByteBuffer fileEncryptionKey)

withAADPrefix

public Parquet.DeleteWriteBuilder withAADPrefix(ByteBuffer aadPrefix)

equalityFieldIds

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

equalityFieldIds

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

transformPaths

public Parquet.DeleteWriteBuilder transformPaths(Function<CharSequence,?> newPathTransformFunc)

withSortOrder

public Parquet.DeleteWriteBuilder withSortOrder(SortOrder newSortOrder)

buildEqualityWriter

public <T> EqualityDeleteWriter<T> buildEqualityWriter()
                                                throws IOException

Throws:

IOException

buildPositionWriter

public <T> PositionDeleteWriter<T> buildPositionWriter()
                                                throws IOException

Throws:

IOException