Package org.apache.iceberg.data

Class DeleteFilter<T>

java.lang.Object

org.apache.iceberg.data.DeleteFilter<T>

Direct Known Subclasses:

GenericDeleteFilter

public abstract class DeleteFilter<T>
extends Object

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DeleteFilter(String filePath, List<org.apache.iceberg.DeleteFile> deletes, org.apache.iceberg.Schema tableSchema, org.apache.iceberg.Schema requestedSchema)
protected	DeleteFilter(String filePath, List<org.apache.iceberg.DeleteFile> deletes, org.apache.iceberg.Schema tableSchema, org.apache.iceberg.Schema requestedSchema, org.apache.iceberg.deletes.DeleteCounter counter)
protected	DeleteFilter(String filePath, List<org.apache.iceberg.DeleteFile> deletes, org.apache.iceberg.Schema tableSchema, org.apache.iceberg.Schema expectedSchema, org.apache.iceberg.deletes.DeleteCounter counter, boolean needRowPosCol)

Method Summary

Modifier and Type	Method	Description
protected abstract org.apache.iceberg.StructLike	asStructLike(T record)
protected int	columnIsDeletedPosition()
org.apache.iceberg.deletes.PositionDeleteIndex	deletedRowPositions()
Predicate<T>	eqDeletedRowFilter()
org.apache.iceberg.Schema	expectedSchema()
org.apache.iceberg.io.CloseableIterable<T>	filter(org.apache.iceberg.io.CloseableIterable<T> records)
org.apache.iceberg.io.CloseableIterable<T>	findEqualityDeleteRows(org.apache.iceberg.io.CloseableIterable<T> records)
protected abstract org.apache.iceberg.io.InputFile	getInputFile(String location)
boolean	hasEqDeletes()
boolean	hasPosDeletes()
void	incrementDeleteCount()
protected org.apache.iceberg.io.InputFile	loadInputFile(org.apache.iceberg.DeleteFile deleteFile)
protected void	markRowDeleted(T item)
protected DeleteLoader	newDeleteLoader()
protected long	pos(T record)
org.apache.iceberg.Schema	requiredSchema()

Methods inherited from class java.lang.Object

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

Constructor Details

DeleteFilter

protected DeleteFilter(String filePath,
 List<org.apache.iceberg.DeleteFile> deletes,
 org.apache.iceberg.Schema tableSchema,
 org.apache.iceberg.Schema expectedSchema,
 org.apache.iceberg.deletes.DeleteCounter counter,
 boolean needRowPosCol)

DeleteFilter

protected DeleteFilter(String filePath,
 List<org.apache.iceberg.DeleteFile> deletes,
 org.apache.iceberg.Schema tableSchema,
 org.apache.iceberg.Schema requestedSchema,
 org.apache.iceberg.deletes.DeleteCounter counter)

DeleteFilter

protected DeleteFilter(String filePath,
 List<org.apache.iceberg.DeleteFile> deletes,
 org.apache.iceberg.Schema tableSchema,
 org.apache.iceberg.Schema requestedSchema)

Method Details

columnIsDeletedPosition

protected int columnIsDeletedPosition()

requiredSchema

public org.apache.iceberg.Schema requiredSchema()

expectedSchema

public org.apache.iceberg.Schema expectedSchema()

hasPosDeletes

public boolean hasPosDeletes()

hasEqDeletes

public boolean hasEqDeletes()

incrementDeleteCount

public void incrementDeleteCount()

asStructLike

protected abstract org.apache.iceberg.StructLike asStructLike(T record)

getInputFile

protected abstract org.apache.iceberg.io.InputFile getInputFile(String location)

loadInputFile

protected org.apache.iceberg.io.InputFile loadInputFile(org.apache.iceberg.DeleteFile deleteFile)

pos

protected long pos(T record)

newDeleteLoader

protected DeleteLoader newDeleteLoader()

filter

public org.apache.iceberg.io.CloseableIterable<T> filter(org.apache.iceberg.io.CloseableIterable<T> records)

findEqualityDeleteRows

public org.apache.iceberg.io.CloseableIterable<T> findEqualityDeleteRows(org.apache.iceberg.io.CloseableIterable<T> records)

markRowDeleted

protected void markRowDeleted(T item)

eqDeletedRowFilter

public Predicate<T> eqDeletedRowFilter()

deletedRowPositions

public org.apache.iceberg.deletes.PositionDeleteIndex deletedRowPositions()