org.apache.iceberg.deletes

Class PositionDeleteWriter<T>

java.lang.Object

org.apache.iceberg.deletes.PositionDeleteWriter<T>

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, FileWriter<PositionDelete<T>,DeleteWriteResult>

public class PositionDeleteWriter<T>
extends java.lang.Object
implements FileWriter<PositionDelete<T>,DeleteWriteResult>

Constructor Summary

Constructors

Constructor and Description
PositionDeleteWriter(FileAppender<StructLike> appender, FileFormat format, java.lang.String location, PartitionSpec spec, StructLike partition, EncryptionKeyMetadata keyMetadata)

Method Summary

Modifier and Type	Method and Description
void	close()
void	delete(java.lang.CharSequence path, long pos) Deprecated. since 0.13.0, will be removed in 0.14.0; use write(PositionDelete) instead.
void	delete(java.lang.CharSequence path, long pos, T row) Deprecated. since 0.13.0, will be removed in 0.14.0; use write(PositionDelete) instead.
long	length() Returns the number of bytes that were currently written by this writer.
CharSequenceSet	referencedDataFiles()
DeleteWriteResult	result() Returns a result that contains information about written DataFiles or DeleteFiles.
DeleteFile	toDeleteFile()
void	write(PositionDelete<T> positionDelete) Writes a row to a predefined spec/partition.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.iceberg.io.FileWriter

write

Constructor Detail

PositionDeleteWriter

public PositionDeleteWriter(FileAppender<StructLike> appender,
                            FileFormat format,
                            java.lang.String location,
                            PartitionSpec spec,
                            StructLike partition,
                            EncryptionKeyMetadata keyMetadata)

Method Detail

write

public void write(PositionDelete<T> positionDelete)

Description copied from interface: FileWriter

Writes a row to a predefined spec/partition.

Specified by:

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

Parameters:

positionDelete - a data or delete record

delete

@Deprecated
public void delete(java.lang.CharSequence path,
                               long pos)

Deprecated. since 0.13.0, will be removed in 0.14.0; use write(PositionDelete) instead.

Writes a position delete.

delete

@Deprecated
public void delete(java.lang.CharSequence path,
                               long pos,
                               T row)

Deprecated. since 0.13.0, will be removed in 0.14.0; use write(PositionDelete) instead.

Writes a position delete and persists the deleted row.

length

public long length()

Description copied from interface: FileWriter

Returns the number of bytes that were currently written by this writer.

Specified by:

length in interface FileWriter<PositionDelete<T>,DeleteWriteResult>

Returns:

the number of written bytes

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

referencedDataFiles

public CharSequenceSet referencedDataFiles()

toDeleteFile

public DeleteFile toDeleteFile()

result

public DeleteWriteResult result()

Description copied from interface: FileWriter

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 FileWriter<PositionDelete<T>,DeleteWriteResult>

Returns:

the file writer result