Package org.apache.iceberg.data
Class GenericDeleteFilter
- java.lang.Object
-
- org.apache.iceberg.data.DeleteFilter<Record>
-
- org.apache.iceberg.data.GenericDeleteFilter
-
public class GenericDeleteFilter extends DeleteFilter<Record>
-
-
Constructor Summary
Constructors Constructor Description GenericDeleteFilter(FileIO io, FileScanTask task, Schema tableSchema, Schema requestedSchema)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected StructLike
asStructLike(Record record)
protected InputFile
getInputFile(java.lang.String location)
protected long
pos(Record record)
-
Methods inherited from class org.apache.iceberg.data.DeleteFilter
columnIsDeletedPosition, deletedRowPositions, eqDeletedRowFilter, filter, findEqualityDeleteRows, hasEqDeletes, hasPosDeletes, incrementDeleteCount, loadInputFile, markRowDeleted, newDeleteLoader, requiredSchema
-
-
-
-
Constructor Detail
-
GenericDeleteFilter
public GenericDeleteFilter(FileIO io, FileScanTask task, Schema tableSchema, Schema requestedSchema)
-
-
Method Detail
-
pos
protected long pos(Record record)
- Overrides:
pos
in classDeleteFilter<Record>
-
asStructLike
protected StructLike asStructLike(Record record)
- Specified by:
asStructLike
in classDeleteFilter<Record>
-
getInputFile
protected InputFile getInputFile(java.lang.String location)
- Specified by:
getInputFile
in classDeleteFilter<Record>
-
-