Skip to content

Commit

Permalink
code style
Browse files Browse the repository at this point in the history
  • Loading branch information
zhangrusong committed Dec 30, 2020
1 parent bf233c4 commit d37b1e7
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -64,13 +64,13 @@ public HadoopShellExecutable createCreateHTableStep(String jobId, CuboidModeEnum
appendExecCmdParameters(cmd, BatchConstants.ARG_SEGMENT_ID, seg.getUuid());
appendExecCmdParameters(cmd, BatchConstants.ARG_PARTITION,
getRowkeyDistributionOutputPath(jobId) + "/part-r-00000");
String partitionOutputPath = null;
if(this.seg.getConfig().isHFileDistCP()){
String partitionOutputPath = getRealizationRootPath(jobId) + "/rowkey_stats/part-r-00000_hfile";
appendExecCmdParameters(cmd, BatchConstants.ARG_PARTITION, partitionOutputPath);
partitionOutputPath = getRealizationRootPath(jobId) + "/rowkey_stats/part-r-00000_hfile";
}else {
appendExecCmdParameters(cmd, BatchConstants.ARG_PARTITION,
getRowkeyDistributionOutputPath(jobId) + "/part-r-00000");
partitionOutputPath = getRowkeyDistributionOutputPath(jobId) + "/part-r-00000";
}
appendExecCmdParameters(cmd, BatchConstants.ARG_PARTITION, partitionOutputPath);
appendExecCmdParameters(cmd, BatchConstants.ARG_CUBOID_MODE, cuboidMode.toString());
appendExecCmdParameters(cmd, BatchConstants.ARG_HBASE_CONF_PATH, getHBaseConfFilePath(jobId));

Expand Down

0 comments on commit d37b1e7

Please sign in to comment.