@ Override public void enqueueRepairCluster ( final int clusterId ) { if ( ! active ) return ; if ( clusterId < - 1 ) // SKIP TRANSACTIONAL RIDS return ; recordProcessed . incrementAndGet ( ) ; // ADD CLUSTER TO REPAIR clusters . put ( clusterId , Boolean . TRUE ) ; }
Enqueues the request to repair a cluster . The decision about repairing is taken by the timer task .