Package org.apache.iceberg.io

Class BaseTaskWriter.BaseEqualityDeltaWriter

java.lang.Object

org.apache.iceberg.io.BaseTaskWriter.BaseEqualityDeltaWriter

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

BaseTaskWriter<T>

protected abstract class BaseTaskWriter.BaseEqualityDeltaWriter
extends Object
implements Closeable

Base equality delta writer to write both insert records and equality-deletes.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BaseEqualityDeltaWriter(StructLike partition, Schema schema, Schema deleteSchema)
protected	BaseEqualityDeltaWriter(StructLike partition, Schema schema, Schema deleteSchema, DeleteGranularity deleteGranularity)

Method Summary

Modifier and Type	Method	Description
protected abstract StructLike	asStructLike(T data)	Wrap the data as a StructLike.
protected abstract StructLike	asStructLikeKey(T key)	Wrap the passed in key of a row as a StructLike
void	close()
void	delete(T row)	Delete those rows whose equality fields has the same values with the given row.
void	deleteKey(T key)	Delete those rows with the given key.
void	write(T row)

Methods inherited from class java.lang.Object

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

Constructor Details

BaseEqualityDeltaWriter

protected BaseEqualityDeltaWriter(StructLike partition,
 Schema schema,
 Schema deleteSchema)

BaseEqualityDeltaWriter

protected BaseEqualityDeltaWriter(StructLike partition,
 Schema schema,
 Schema deleteSchema,
 DeleteGranularity deleteGranularity)

Method Details

asStructLike

protected abstract StructLike asStructLike(T data)

Wrap the data as a StructLike.

asStructLikeKey

protected abstract StructLike asStructLikeKey(T key)

Wrap the passed in key of a row as a StructLike

write

public void write(T row)
           throws IOException

Throws:

IOException

delete

public void delete(T row)
            throws IOException

Delete those rows whose equality fields has the same values with the given row. It will write the entire row into the equality-delete file.

Parameters:

row - the given row to delete.

Throws:

IOException

deleteKey

public void deleteKey(T key)
               throws IOException

Delete those rows with the given key. It will only write the values of equality fields into the equality-delete file.

Parameters:

key - is the projected data whose columns are the same as the equality fields.

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException