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 java.lang.Object

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DeleteFilter(FileScanTask task, Schema tableSchema, Schema requestedSchema)

Method Summary

Modifier and Type	Method	Description
protected abstract StructLike	asStructLike(T record)
PositionDeleteIndex	deletedRowPositions()
java.util.function.Predicate<T>	eqDeletedRowFilter()
CloseableIterable<T>	filter(CloseableIterable<T> records)
CloseableIterable<T>	findEqualityDeleteRows(CloseableIterable<T> records)
protected abstract InputFile	getInputFile(java.lang.String location)
boolean	hasEqDeletes()
boolean	hasPosDeletes()
protected long	pos(T record)
Schema	requiredSchema()

Methods inherited from class java.lang.Object

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

Constructor Detail

DeleteFilter

protected DeleteFilter(FileScanTask task,
                       Schema tableSchema,
                       Schema requestedSchema)

Method Detail

requiredSchema

public Schema requiredSchema()

hasPosDeletes

public boolean hasPosDeletes()

hasEqDeletes

public boolean hasEqDeletes()

asStructLike

protected abstract StructLike asStructLike(T record)

getInputFile

protected abstract InputFile getInputFile(java.lang.String location)

pos

protected long pos(T record)

filter

public CloseableIterable<T> filter(CloseableIterable<T> records)

findEqualityDeleteRows

public CloseableIterable<T> findEqualityDeleteRows(CloseableIterable<T> records)

eqDeletedRowFilter

public java.util.function.Predicate<T> eqDeletedRowFilter()

deletedRowPositions

public PositionDeleteIndex deletedRowPositions()