gistfile1.java

SliceQuery<String,Composite, Integer> sliceQuery = HFactory.createSliceQuery(keyspace, StringSerializer.get(),
            new CompositeSerializer().get(), IntegerSerializer.get());
        sliceQuery.setColumnFamily("metrics_work_queue");
        sliceQuery.setKey("raw_metrics");

        ColumnSliceIterator<String, Composite, Integer> iterator = new ColumnSliceIterator<String, Composite, Integer>(
            sliceQuery, (Composite) null, (Composite) null, false);

        assertTrue(iterator.hasNext());
        HColumn<Composite, Integer> actualQueueValue = iterator.next();
        HColumn<Composite, Integer> expectedQueueValue = HFactory.createColumn(new Composite(theHour.getMillis(),
            scheduleId), 0, CompositeSerializer.get(), IntegerSerializer.get());
        assertPropertiesMatch("The column in the queue does not match the expected value", expectedQueueValue,
            actualQueueValue, "clock");