org.apache.hadoop.hbase.util.RegionSplitter#UniformSplit ( )源码实例Demo

@Before
public void setUp() throws Exception {
  tableDescriptor = HTU.createModifyableTableDescriptor(test.getMethodName());
  admin = HTU.getAdmin();
  cleanerChore = new MobFileCleanerChore();
  familyDescriptor = new ColumnFamilyDescriptorBuilder.ModifyableColumnFamilyDescriptor(fam);
  familyDescriptor.setMobEnabled(true);
  familyDescriptor.setMobThreshold(mobLen);
  familyDescriptor.setMaxVersions(1);
  tableDescriptor.setColumnFamily(familyDescriptor);
  RegionSplitter.UniformSplit splitAlgo = new RegionSplitter.UniformSplit();
  byte[][] splitKeys = splitAlgo.split(numRegions);
  table = HTU.createTable(tableDescriptor, splitKeys).getName();
}
 

private byte[][] calculateRegionSplits(MongoURI uri, String tableName) throws Exception {
  DBCollection collection = uri.connectDB().getCollection(uri.getCollection());
  long size = collection.getStats().getLong("size");
  long regionSize = ConfigUtil.getPresplitTableRegionSize(_conf);
  int numRegions = (int) Math.min((size / regionSize) + 1, 4096);

  if (numRegions > 1) {
    log.info("Pre-splitting " + tableName + " into " + numRegions + " regions");
    RegionSplitter.UniformSplit splitter = new RegionSplitter.UniformSplit();
    return splitter.split(numRegions);
  } else {
    log.info("Not splitting " + tableName + ", because the data can fit into a single region");
    return new byte[0][0];
  }
}
 

@Override
public RegionSplitter.SplitAlgorithm createSplitter(int cardinality) {
    return new RegionSplitter.UniformSplit();
}
 

@Override
public RegionSplitter.SplitAlgorithm createSplitter(int cardinality) {
    return new RegionSplitter.UniformSplit();
}
 

@Override
public RegionSplitter.SplitAlgorithm createSplitter(int cardinality) {
    return new RegionSplitter.UniformSplit();
}
 

@Override
public RegionSplitter.SplitAlgorithm createSplitter(int cardinality) {
    return new RegionSplitter.UniformSplit();
}
 

@Override
public RegionSplitter.SplitAlgorithm createSplitter(int cardinality) {
    return new RegionSplitter.UniformSplit();
}
 

private static byte[][] getSplits(int numRegions) {
  RegionSplitter.UniformSplit split = new RegionSplitter.UniformSplit();
  split.setFirstRow(Bytes.toBytes(0L));
  split.setLastRow(Bytes.toBytes(Long.MAX_VALUE));
  return split.split(numRegions);
}
 

private static byte[][] getSplits(int numRegions) {
  RegionSplitter.UniformSplit split = new RegionSplitter.UniformSplit();
  split.setFirstRow(Bytes.toBytes(0L));
  split.setLastRow(Bytes.toBytes(Long.MAX_VALUE));
  return split.split(numRegions);
}
 

private static byte[][] getSplits(int numRegions) {
  RegionSplitter.UniformSplit split = new RegionSplitter.UniformSplit();
  split.setFirstRow(Bytes.toBytes(0L));
  split.setLastRow(Bytes.toBytes(Long.MAX_VALUE));
  return split.split(numRegions);
}
 

private static byte[][] getSplits(int numRegions) {
  RegionSplitter.UniformSplit split = new RegionSplitter.UniformSplit();
  split.setFirstRow(Bytes.toBytes(0L));
  split.setLastRow(Bytes.toBytes(Long.MAX_VALUE));
  return split.split(numRegions);
}
 

private byte[][] getSplits(int numRegions) {
  RegionSplitter.UniformSplit split = new RegionSplitter.UniformSplit();
  split.setFirstRow(Bytes.toBytes(0L));
  split.setLastRow(Bytes.toBytes(Long.MAX_VALUE));
  return split.split(numRegions);
}