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(java.lang.String filePath, java.util.List<DeleteFile> deletes, Schema tableSchema, Schema requestedSchema)
protected
DeleteFilter(java.lang.String filePath, java.util.List<DeleteFile> deletes, Schema tableSchema, Schema requestedSchema, DeleteCounter counter)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected abstract StructLike
asStructLike(T record)
protected int
columnIsDeletedPosition()
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()
void
incrementDeleteCount()
protected void
markRowDeleted(T item)
protected long
pos(T record)
Schema
requiredSchema()
-
-
-
Constructor Detail
-
DeleteFilter
protected DeleteFilter(java.lang.String filePath, java.util.List<DeleteFile> deletes, Schema tableSchema, Schema requestedSchema, DeleteCounter counter)
-
DeleteFilter
protected DeleteFilter(java.lang.String filePath, java.util.List<DeleteFile> deletes, Schema tableSchema, Schema requestedSchema)
-
-
Method Detail
-
columnIsDeletedPosition
protected int columnIsDeletedPosition()
-
requiredSchema
public Schema requiredSchema()
-
hasPosDeletes
public boolean hasPosDeletes()
-
hasEqDeletes
public boolean hasEqDeletes()
-
incrementDeleteCount
public void incrementDeleteCount()
-
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)
-
markRowDeleted
protected void markRowDeleted(T item)
-
eqDeletedRowFilter
public java.util.function.Predicate<T> eqDeletedRowFilter()
-
deletedRowPositions
public PositionDeleteIndex deletedRowPositions()
-
-