Package org.apache.iceberg.data

Class GenericDeleteFilter

java.lang.Object

org.apache.iceberg.data.DeleteFilter<org.apache.iceberg.data.Record>

org.apache.iceberg.data.GenericDeleteFilter

public class GenericDeleteFilter
extends DeleteFilter<org.apache.iceberg.data.Record>

Constructor Summary

Constructors

Constructor	Description
GenericDeleteFilter(org.apache.iceberg.io.FileIO io, org.apache.iceberg.FileScanTask task, org.apache.iceberg.Schema tableSchema, org.apache.iceberg.Schema requestedSchema)

Method Summary

Modifier and Type	Method	Description
protected org.apache.iceberg.StructLike	asStructLike(org.apache.iceberg.data.Record record)
protected org.apache.iceberg.io.InputFile	getInputFile(String location)
protected long	pos(org.apache.iceberg.data.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(org.apache.iceberg.io.FileIO io,
 org.apache.iceberg.FileScanTask task,
 org.apache.iceberg.Schema tableSchema,
 org.apache.iceberg.Schema requestedSchema)

Method Details

pos

protected long pos(org.apache.iceberg.data.Record record)

Overrides:

pos in class DeleteFilter<org.apache.iceberg.data.Record>

asStructLike

protected org.apache.iceberg.StructLike asStructLike(org.apache.iceberg.data.Record record)

Specified by:

asStructLike in class DeleteFilter<org.apache.iceberg.data.Record>

getInputFile

protected org.apache.iceberg.io.InputFile getInputFile(String location)

Specified by:

getInputFile in class DeleteFilter<org.apache.iceberg.data.Record>