You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2016/10/21 02:37:34 UTC
kylin git commit: KYLIN-2070 add more info in the REST API
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 <sh...@apache.org>
Authored: Fri Oct 21 10:37:24 2016 +0800
Committer: shaofengshi <sh...@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;
+ }
}