Repository: kylin Updated Branches: refs/heads/master 0eab5e0ad -> 4f76e16c4
KYLIN-2070 add more info in the REST API Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/4f76e16c Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/4f76e16c Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/4f76e16c Branch: refs/heads/master Commit: 4f76e16c491b0d50a61bd68c9d0fd54ee4f87e4a Parents: 0eab5e0 Author: shaofengshi <shaofeng...@apache.org> Authored: Fri Oct 21 10:37:24 2016 +0800 Committer: shaofengshi <shaofeng...@apache.org> Committed: Fri Oct 21 10:37:24 2016 +0800 ---------------------------------------------------------------------- .../kylin/rest/controller/CubeController.java | 8 ++++- .../kylin/rest/response/HBaseResponse.java | 36 ++++++++++++++++++++ 2 files changed, 43 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/4f76e16c/server-base/src/main/java/org/apache/kylin/rest/controller/CubeController.java ---------------------------------------------------------------------- diff --git a/server-base/src/main/java/org/apache/kylin/rest/controller/CubeController.java b/server-base/src/main/java/org/apache/kylin/rest/controller/CubeController.java index eefc452..a3f9ec0 100644 --- a/server-base/src/main/java/org/apache/kylin/rest/controller/CubeController.java +++ b/server-base/src/main/java/org/apache/kylin/rest/controller/CubeController.java @@ -277,7 +277,7 @@ public class CubeController extends BasicController { @RequestMapping(value = "/{cubeName}/rebuild2", method = { RequestMethod.PUT }) @ResponseBody public JobInstance rebuild(@PathVariable String cubeName, @RequestBody JobBuildRequest2 req) { - return buildInternal(cubeName, 0, 0, req.getSourceOffsetStart(), req.getSourceOffsetEnd(), req.getSourcePartitionOffsetStart(), req.getSourcePartitionOffsetEnd(), req.getBuildType(), req.isForce()); + return buildInternal(cubeName, 0, 0, req.getSourceOffsetStart(), req.getSourceOffsetEnd(), req.getSourcePartitionOffsetStart(), req.getSourcePartitionOffsetEnd(), req.getBuildType(), req.isForce()); } private JobInstance buildInternal(String cubeName, long startTime, long endTime, // @@ -527,6 +527,12 @@ public class CubeController extends BasicController { hr.setTableName(tableName); hr.setDateRangeStart(segment.getDateRangeStart()); hr.setDateRangeEnd(segment.getDateRangeEnd()); + hr.setSegmentName(segment.getName()); + hr.setSourceCount(segment.getInputRecords()); + if (segment.isSourceOffsetsOn()) { + hr.setSourceOffsetStart(segment.getSourceOffsetStart()); + hr.setSourceOffsetEnd(segment.getSourceOffsetEnd()); + } hbase.add(hr); } http://git-wip-us.apache.org/repos/asf/kylin/blob/4f76e16c/server-base/src/main/java/org/apache/kylin/rest/response/HBaseResponse.java ---------------------------------------------------------------------- diff --git a/server-base/src/main/java/org/apache/kylin/rest/response/HBaseResponse.java b/server-base/src/main/java/org/apache/kylin/rest/response/HBaseResponse.java index 607d61a..985596d 100644 --- a/server-base/src/main/java/org/apache/kylin/rest/response/HBaseResponse.java +++ b/server-base/src/main/java/org/apache/kylin/rest/response/HBaseResponse.java @@ -22,11 +22,15 @@ import java.io.Serializable; public class HBaseResponse implements Serializable { private static final long serialVersionUID = 7263557115683263492L; + private String segmentName; private String tableName; private long tableSize; private int regionCount; private long dateRangeStart; private long dateRangeEnd; + private long sourceOffsetStart; + private long sourceOffsetEnd; + private long sourceCount; public HBaseResponse() { } @@ -105,4 +109,36 @@ public class HBaseResponse implements Serializable { public void setDateRangeEnd(long dateRangeEnd) { this.dateRangeEnd = dateRangeEnd; } + + public String getSegmentName() { + return segmentName; + } + + public void setSegmentName(String segmentName) { + this.segmentName = segmentName; + } + + public long getSourceOffsetStart() { + return sourceOffsetStart; + } + + public void setSourceOffsetStart(long sourceOffsetStart) { + this.sourceOffsetStart = sourceOffsetStart; + } + + public long getSourceOffsetEnd() { + return sourceOffsetEnd; + } + + public void setSourceOffsetEnd(long sourceOffsetEnd) { + this.sourceOffsetEnd = sourceOffsetEnd; + } + + public long getSourceCount() { + return sourceCount; + } + + public void setSourceCount(long sourceCount) { + this.sourceCount = sourceCount; + } }
