@Test @Category(UnitTest.class) public void getSplit() throws Splits.SplitException { Splits splits = new PartitionerSplit(); splits.generateSplits(new TestGenerator()); Random rand = new Random(); for (int i = 0; i < 1000; i++) { long test = rand.nextInt(generated[generated.length - 1].intValue()); long testPartition = findSplit(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; }