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

Modifier and Type	Method	Description
protected StructLike	asStructLike(Record record)
protected InputFile	getInputFile(String location)
protected long	pos(Record record)

Methods inherited from class org.apache.iceberg.data.DeleteFilter

columnIsDeletedPosition, deletedRowPositions, eqDeletedRowFilter, expectedSchema, filter, findEqualityDeleteRows, hasEqDeletes, hasPosDeletes, incrementDeleteCount, loadInputFile, markRowDeleted, newDeleteLoader, requiredSchema

Methods inherited from class java.lang.Object

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

Constructor Details

GenericDeleteFilter

public GenericDeleteFilter(FileIO io,
 FileScanTask task,
 Schema tableSchema,
 Schema requestedSchema)

Method Details

pos

protected long pos(Record record)

Overrides:

pos in class DeleteFilter<Record>

asStructLike

protected StructLike asStructLike(Record record)

Specified by:

asStructLike in class DeleteFilter<Record>

getInputFile

protected InputFile getInputFile(String location)

Specified by:

getInputFile in class DeleteFilter<Record>