@Override
    public int partition(int total, T data) {
        return Math.abs(i++ % total);
    }
@Test
    public void testPartition() {
        SimpleRollingPartitioner<SampleData> partitioner = new SimpleRollingPartitioner<SampleData>();
        assertEquals(partitioner.partition(10, new SampleData()), 0);
        assertEquals(partitioner.partition(10, new SampleData()), 1);
        assertEquals(partitioner.partition(10, new SampleData()), 2);
    }