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<DeleteFile> deletes, Function<Integer,Types.NestedField> fieldLookup, Schema expectedSchema, DeleteCounter counter, boolean needRowPosCol)
protected	DeleteFilter(String filePath, List<DeleteFile> deletes, Schema tableSchema, Schema requestedSchema)
protected	DeleteFilter(String filePath, List<DeleteFile> deletes, Schema tableSchema, Schema requestedSchema, DeleteCounter counter)
protected	DeleteFilter(String filePath, List<DeleteFile> deletes, Schema tableSchema, Schema expectedSchema, DeleteCounter counter, boolean needRowPosCol)

Method Summary

Modifier and Type	Method	Description
protected abstract StructLike	asStructLike(T record)
protected int	columnIsDeletedPosition()
PositionDeleteIndex	deletedRowPositions()
Predicate<T>	eqDeletedRowFilter()
Schema	expectedSchema()
CloseableIterable<T>	filter(CloseableIterable<T> records)
CloseableIterable<T>	findEqualityDeleteRows(CloseableIterable<T> records)
protected abstract InputFile	getInputFile(String location)
boolean	hasEqDeletes()
boolean	hasPosDeletes()
void	incrementDeleteCount()
protected InputFile	loadInputFile(DeleteFile deleteFile)
protected void	markRowDeleted(T item)
protected DeleteLoader	newDeleteLoader()
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 Details

DeleteFilter

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

DeleteFilter

protected DeleteFilter(String filePath,
 List<DeleteFile> deletes,
 Function<Integer,Types.NestedField> fieldLookup,
 Schema expectedSchema,
 DeleteCounter counter,
 boolean needRowPosCol)

DeleteFilter

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

DeleteFilter

protected DeleteFilter(String filePath,
 List<DeleteFile> deletes,
 Schema tableSchema,
 Schema requestedSchema)

Method Details

columnIsDeletedPosition

protected int columnIsDeletedPosition()

requiredSchema

public Schema requiredSchema()

expectedSchema

public Schema expectedSchema()

hasPosDeletes

public boolean hasPosDeletes()

hasEqDeletes

public boolean hasEqDeletes()

incrementDeleteCount

public void incrementDeleteCount()

asStructLike

protected abstract StructLike asStructLike(T record)

getInputFile

protected abstract InputFile getInputFile(String location)

loadInputFile

protected InputFile loadInputFile(DeleteFile deleteFile)

pos

protected long pos(T record)

newDeleteLoader

protected DeleteLoader newDeleteLoader()

filter

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

findEqualityDeleteRows

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

markRowDeleted

protected void markRowDeleted(T item)

eqDeletedRowFilter

public Predicate<T> eqDeletedRowFilter()

deletedRowPositions

public PositionDeleteIndex deletedRowPositions()