Class ReplicaFilteringProtection<E extends Endpoints<E>>


  • public class ReplicaFilteringProtection<E extends Endpoints<E>>
    extends java.lang.Object
    Helper in charge of collecting additional queries to be done on the coordinator to protect against invalid results being included due to replica-side filtering (secondary indexes or ALLOW * FILTERING).

    When using replica-side filtering with CL>ONE, a replica can send a stale result satisfying the filter, while updated replicas won't send a corresponding tombstone to discard that result during reconciliation. This helper identifies the rows in a replica response that don't have a corresponding row in other replica responses, and requests them by primary key to the "silent" replicas in a second fetch round.

    See CASSANDRA-8272, CASSANDRA-8273, and CASSANDRA-15907 for further details.

    • Method Summary

      • Methods inherited from class java.lang.Object

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