Class FanoutPositionOnlyDeleteWriter<T>

  • All Implemented Interfaces:, java.lang.AutoCloseable, PartitioningWriter<PositionDelete<T>,​DeleteWriteResult>

    public class FanoutPositionOnlyDeleteWriter<T>
    extends java.lang.Object
    A position delete writer capable of writing to multiple specs and partitions if the incoming stream of deletes is not ordered. If the incoming records are ordered by an external process, use ClusteredPositionDeleteWriter instead.

    Note this writer stores only positions. It does not store deleted records.