private Path createStagingDir(Path baseDir, User user, String randomDir) throws IOException {
    Path p = new Path(baseDir, randomDir);
    sinkFs.mkdirs(p, PERM_ALL_ACCESS);
    sinkFs.setPermission(p, PERM_ALL_ACCESS);
    return p;
  }
Number of hfiles to copy per thread during replication
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/HFileReplicator.java