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(Supplier<OutputFile> dvOutputFile, Function<String,PositionDeleteIndex> loadPreviousDeletes)
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.
void	delete(String path, PositionDeleteIndex positionDeleteIndex, PartitionSpec spec, StructLike partition)	Marks every position that is deleted in positionDeleteIndex as deleted in the given data file.
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)

BaseDVFileWriter

public BaseDVFileWriter(Supplier<OutputFile> dvOutputFile,
 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

delete

public void delete(String path,
 PositionDeleteIndex positionDeleteIndex,
 PartitionSpec spec,
 StructLike partition)

Description copied from interface: DVFileWriter

Marks every position that is deleted in positionDeleteIndex as deleted in the given data file. Implementations should merge with existing position indices for the provided path

Specified by:

delete in interface DVFileWriter

Parameters:

path - the data file path

positionDeleteIndex - the position delete index containing all the positions to delete

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