org.apache.iceberg.io

Class BasePositionDeltaWriter<T>

java.lang.Object

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

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, PositionDeltaWriter<T>

public class BasePositionDeltaWriter<T>
extends java.lang.Object
implements PositionDeltaWriter<T>

Constructor Summary

Constructors

Constructor and Description
BasePositionDeltaWriter(PartitioningWriter<T,DataWriteResult> dataWriter, PartitioningWriter<PositionDelete<T>,DeleteWriteResult> deleteWriter)

Method Summary

Modifier and Type	Method and Description
void	close()
void	delete(java.lang.CharSequence path, long pos, T row, PartitionSpec spec, StructLike partition) Deletes a position in the provided spec/partition and records the deleted row in the delete file.
void	insert(T row, PartitionSpec spec, StructLike partition) Inserts a row to the provided spec/partition.
WriteResult	result() Returns a result that contains information about written DataFiles or DeleteFiles.

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.PositionDeltaWriter

delete

Constructor Detail

BasePositionDeltaWriter

public BasePositionDeltaWriter(PartitioningWriter<T,DataWriteResult> dataWriter,
                               PartitioningWriter<PositionDelete<T>,DeleteWriteResult> deleteWriter)

Method Detail

insert

public void insert(T row,
                   PartitionSpec spec,
                   StructLike partition)

Description copied from interface: PositionDeltaWriter

Inserts a row to the provided spec/partition.

Specified by:

insert in interface PositionDeltaWriter<T>

Parameters:

row - a data record

spec - a partition spec

partition - a partition or null if the spec is unpartitioned

delete

public void delete(java.lang.CharSequence path,
                   long pos,
                   T row,
                   PartitionSpec spec,
                   StructLike partition)

Description copied from interface: PositionDeltaWriter

Deletes a position in the provided spec/partition and records the deleted row in the delete file.

Specified by:

delete in interface PositionDeltaWriter<T>

Parameters:

path - a data file path

pos - a position

row - a deleted row

spec - a partition spec

partition - a partition or null if the spec is unpartitioned

result

public WriteResult result()

Description copied from interface: PositionDeltaWriter

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 PositionDeltaWriter<T>

Returns:

the writer result

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