Package org.apache.iceberg.io

Class PartitioningDVWriter<T>

java.lang.Object

org.apache.iceberg.io.PartitioningDVWriter<T>

All Implemented Interfaces:

Closeable, AutoCloseable, PartitioningWriter<PositionDelete<T>,DeleteWriteResult>

public class PartitioningDVWriter<T>
extends Object
implements PartitioningWriter<PositionDelete<T>,DeleteWriteResult>

PartitioningDVWriter is a PartitioningWriter implementation that accumulates deleted positions for data files across different partitions and writes out deletion vector files.

Constructor Summary

Constructors

Constructor	Description
PartitioningDVWriter(OutputFileFactory fileFactory, Function<CharSequence,PositionDeleteIndex> loadPreviousDeletes)

Method Summary

Modifier and Type	Method	Description
void	close()
DeleteWriteResult	result()	Returns a result that contains information about written DataFiles or DeleteFiles.
void	write(PositionDelete<T> row, PartitionSpec spec, StructLike partition)	Writes a row to the provided spec/partition.

Methods inherited from class java.lang.Object

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

Constructor Details

PartitioningDVWriter

public PartitioningDVWriter(OutputFileFactory fileFactory,
 Function<CharSequence,PositionDeleteIndex> loadPreviousDeletes)

Method Details

write

public void write(PositionDelete<T> row,
 PartitionSpec spec,
 StructLike partition)

Description copied from interface: PartitioningWriter

Writes a row to the provided spec/partition.

Specified by:

write in interface PartitioningWriter<PositionDelete<T>,DeleteWriteResult>

Parameters:

row - a data or delete record

spec - a partition spec

partition - a partition or null if the spec is unpartitioned

result

public DeleteWriteResult result()

Description copied from interface: PartitioningWriter

Returns a result that contains information about written DataFiles or DeleteFiles. The result is valid only after the writer is closed.

Specified by:

result in interface PartitioningWriter<PositionDelete<T>,DeleteWriteResult>

Returns:

the writer result

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException