Package org.apache.iceberg.deletes

Class BaseDVFileWriter

java.lang.Object

org.apache.iceberg.deletes.BaseDVFileWriter

All Implemented Interfaces:

Closeable, AutoCloseable, DVFileWriter

public class BaseDVFileWriter
extends Object
implements DVFileWriter

Constructor Summary

Constructors

Constructor	Description
BaseDVFileWriter(OutputFileFactory fileFactory, Function<String,PositionDeleteIndex> loadPreviousDeletes)

Method Summary

Modifier and Type	Method	Description
void	close()
void	delete(String path, long pos, PartitionSpec spec, StructLike partition)	Marks a position in a given data file as deleted.
DeleteWriteResult	result()	Returns a result that contains information about written DeleteFiles.

Methods inherited from class java.lang.Object

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

Constructor Details

BaseDVFileWriter

public BaseDVFileWriter(OutputFileFactory fileFactory,
 Function<String,PositionDeleteIndex> loadPreviousDeletes)

Method Details

delete

public void delete(String path,
 long pos,
 PartitionSpec spec,
 StructLike partition)

Description copied from interface: DVFileWriter

Marks a position in a given data file as deleted.

Specified by:

delete in interface DVFileWriter

Parameters:

path - the data file path

pos - the data file position

spec - the data file partition spec

partition - the data file partition

result

public DeleteWriteResult result()

Description copied from interface: DVFileWriter

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

Specified by:

result in interface DVFileWriter

Returns:

the writer result

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException