@Test public void testNumPartitions() { Map<String, Long> comparisons1 = new HashMap<String, Long>() { { IntStream.range(0, 10).forEach(f -> put("f" + f, 100L)); } }; BucketizedBloomCheckPartitioner p = new BucketizedBloomCheckPartitioner(10000, comparisons1, 10); assertEquals(100, p.numPartitions(), "num partitions must equal total buckets"); }
@Override public int numPartitions() { return partitions; }
BucketizedBloomCheckPartitioner extends Partitioner { @Override public int numPartitions() { return partitions; } }
BucketizedBloomCheckPartitioner extends Partitioner { @Override public int numPartitions() { return partitions; } BucketizedBloomCheckPartitioner(int targetPartitions, Map<String, Long> fileGroupToComparisons,
      int keysPerBucket); }
BucketizedBloomCheckPartitioner extends Partitioner { @Override public int numPartitions() { return partitions; } BucketizedBloomCheckPartitioner(int targetPartitions, Map<String, Long> fileGroupToComparisons,
      int keysPerBucket); @Override int numPartitions(); @Override int getPartition(Object key); }
BucketizedBloomCheckPartitioner extends Partitioner { @Override public int numPartitions() { return partitions; } BucketizedBloomCheckPartitioner(int targetPartitions, Map<String, Long> fileGroupToComparisons,
      int keysPerBucket); @Override int numPartitions(); @Override int getPartition(Object key);  }