@Override
    public Void call() throws Exception {
        int rows = 0;
        Random random = new Random();
        sliceQuery.setColumnFamily(commandArgs.workingColumnFamily);
        log.debug("Starting SliceCommand");
        try {            
            while (rows < commandArgs.getKeysPerThread()) {
                long nanos = System.nanoTime();
                columnFamily.addKey(String.format("%010d", startKey + random.nextInt(commandArgs.getKeysPerThread())));
                //sliceQuery.setKey(String.format("%010d", startKey + random.nextInt(commandArgs.getKeysPerThread())));
                //sliceQuery.setRange(null, null, false, commandArgs.columnCount);
                //QueryResult<ColumnSlice<String,String>> result = sliceQuery.execute();
                columnFamily.getColumns();
                //LatencyTracker readCount = commandRunner.latencies.get(new CassandraHost("localhost:9160"));
                ///readCount.addMicro((System.nanoTime() - nanos) / 1000);
                columnFamily.removeKeys().clear();                
                rows++;
            }
        } catch (Exception e) {
            log.error("Problem: ", e);
        }
        commandRunner.doneSignal.countDown();
        log.debug("SliceCommand complete");
        return null;
    }