@Test @Category(UnitTest.class) public void getSplitLotsOfPartitions() throws Splits.SplitException { Splits splits = new PartitionerSplit(); BigTestGenerator btg = new BigTestGenerator(); splits.generateSplits(btg); Random rand = new Random(); for (int i = 0; i < 10000; i++) { long test = rand.nextInt(btg.generated[btg.generated.length - 1].intValue()); long testPartition = findSplit(btg.generated, test); PartitionerSplit.PartitionerSplitInfo split = (PartitionerSplit.PartitionerSplitInfo) splits.getSplit(test); Assert.assertEquals("Splits entry not correct", testPartition, split.getPartition()); } }
@Override public void generateSplits(SplitGenerator generator) { splits = generator.getPartitions(); }
PartitionerSplit extends Splits { @Override public void generateSplits(SplitGenerator generator) { splits = generator.getPartitions(); } }
PartitionerSplit extends Splits { @Override public void generateSplits(SplitGenerator generator) { splits = generator.getPartitions(); }  }
PartitionerSplit extends Splits { @Override public void generateSplits(SplitGenerator generator) { splits = generator.getPartitions(); }  @Override String findSplitFile(Path parent); @Override void generateSplits(SplitGenerator generator); @Override void readExternal(ObjectInput in); }
PartitionerSplit extends Splits { @Override public void generateSplits(SplitGenerator generator) { splits = generator.getPartitions(); }  @Override String findSplitFile(Path parent); @Override void generateSplits(SplitGenerator generator); @Override void readExternal(ObjectInput in); static final String SPLIT_FILE; }