src/java/org/apache/cassandra/db/compaction/CompactionManager.java
/**
     * Does not mutate data, so is not scheduled.
     */
Does not mutate data, so is not scheduled.
Does not mutate data so is not scheduled .
public Future<Object> submitValidation(final ColumnFamilyStore cfStore, final AntiEntropyService.Validator validator)
    {
        Callable<Object> callable = new Callable<Object>()
        {
            public Object call() throws IOException
            {
                compactionLock.readLock().lock();
                try
                {
                    doValidationCompaction(cfStore, validator);
                    return this;
                }
                finally
                {
                    compactionLock.readLock().unlock();
                }
            }
        };
        return validationExecutor.submit(callable);
    }
public Future < Object > submitValidation ( final ColumnFamilyStore cfStore , final AntiEntropyService . Validator validator ) { Callable < Object > callable = new Callable < Object > ( ) { public Object call ( ) throws IOException { compactionLock . readLock ( ) . lock ( ) ; try { doValidationCompaction ( cfStore , validator ) ; return this ; } finally { compactionLock . readLock ( ) . unlock ( ) ; } } } ; return validationExecutor . submit ( callable ) ; }
Does not mutate data, so is not scheduled.
Does not mutate data so is not scheduled .