Class DeleteFilter<T>

  • Direct Known Subclasses:
    GenericDeleteFilter

    public abstract class DeleteFilter<T>
    extends java.lang.Object
    • 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)
      • markRowDeleted

        protected void markRowDeleted​(T item)
      • eqDeletedRowFilter

        public java.util.function.Predicate<T> eqDeletedRowFilter()