扩展Hadoop的TableInputFormat以使用用于分发时间戳记密钥的前缀进行扫描

扩展Hadoop的TableInputFormat以使用用于分发时间戳记密钥的前缀进行扫描

您将需要在每次迭代中复制拆分的深层副本：

for (int prefix = -128; prefix < 128; prefix++) {  prefixedStartRow[0] = (byte) prefix;  prefixedStopRow[0] = (byte) prefix;  scan.setStartRow(prefixedStartRow);  scan.setStopRow(prefixedStopRow);  setScan(scan);  for (InputSplit subSplit : super.getSplits(context)) {    splits.add((InputSplit) ReflectionUtils.copy(conf,          (TableSplit) subSplit, new TableSplit());  }}