public void deleteTimeseries()

in src/main/java/com/netflix/bdp/s3mper/metastore/impl/MetastoreJanitor.java [110:128]

• 13 lines of code
• 2 McCabe index (conditional complexity)

    public void deleteTimeseries(TimeUnit unit, long time) throws Exception {
        log.info("Starting Timeseries Delete");
        log.info(format("read_units=%d, write_units=%d, queue_size=%d, scan_threads=%d, delete_threads=%d", scanLimit, deleteLimit, queueSize, scanThreads, deleteThreads));
        
        executor = Executors.newFixedThreadPool(scanThreads+deleteThreads);
        
        for (int i = 0; i < scanThreads; i++) {
            TimeseriesScannerTask scanner = new TimeseriesScannerTask(db, scanLimiter, queue, queueSize, unit.toMillis(time));
            
            tasks.add(scanner);
            
            Future scanFuture = executor.submit(scanner);
            
            futures.add(scanFuture);
            scanFutures.add(scanFuture);
        }
        
        processDelete();
    }