Class DeleteFilter<T>

  • Direct Known Subclasses:
    GenericDeleteFilter

    public abstract class DeleteFilter<T>
    extends java.lang.Object
    • Method Detail

      • requiredSchema

        public Schema requiredSchema()
      • hasPosDeletes

        public boolean hasPosDeletes()
      • hasEqDeletes

        public boolean hasEqDeletes()
      • asStructLike

        protected abstract StructLike asStructLike​(T record)
      • getInputFile

        protected abstract InputFile getInputFile​(java.lang.String location)
      • pos

        protected long pos​(T record)
      • eqDeletedRowFilter

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