@Test public void testPartition() { for (int i = 0; i < 70; ++i) { String key = randomKey(); assertEquals(getPartitionId(key.hashCode() & 0x7FFFFFFF), partitioner.partition(key, 4)); } }
@Override public int partition(String partitionKey, int partitionNum) { int partitionInterval = Integer.MAX_VALUE / partitionNum; return ((partitionKey.hashCode() & 0x7FFFFFFF) / partitionInterval) % partitionNum; }
SimplePartitioner implements Partitioner { @Override public int partition(String partitionKey, int partitionNum) { int partitionInterval = Integer.MAX_VALUE / partitionNum; return ((partitionKey.hashCode() & 0x7FFFFFFF) / partitionInterval) % partitionNum; } }
SimplePartitioner implements Partitioner { @Override public int partition(String partitionKey, int partitionNum) { int partitionInterval = Integer.MAX_VALUE / partitionNum; return ((partitionKey.hashCode() & 0x7FFFFFFF) / partitionInterval) % partitionNum; } SimplePartitioner(); }
SimplePartitioner implements Partitioner { @Override public int partition(String partitionKey, int partitionNum) { int partitionInterval = Integer.MAX_VALUE / partitionNum; return ((partitionKey.hashCode() & 0x7FFFFFFF) / partitionInterval) % partitionNum; } SimplePartitioner(); @Override int partition(String partitionKey, int partitionNum); }
SimplePartitioner implements Partitioner { @Override public int partition(String partitionKey, int partitionNum) { int partitionInterval = Integer.MAX_VALUE / partitionNum; return ((partitionKey.hashCode() & 0x7FFFFFFF) / partitionInterval) % partitionNum; } SimplePartitioner(); @Override int partition(String partitionKey, int partitionNum);  }