You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ma...@apache.org on 2015/08/13 09:05:26 UTC
[06/10] incubator-kylin git commit: coding
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/9d9177be/storage/src/main/java/org/apache/kylin/storage/hbase/coprocessor/endpoint/protobuf/CubeVisit.proto
----------------------------------------------------------------------
diff --git a/storage/src/main/java/org/apache/kylin/storage/hbase/coprocessor/endpoint/protobuf/CubeVisit.proto b/storage/src/main/java/org/apache/kylin/storage/hbase/coprocessor/endpoint/protobuf/CubeVisit.proto
index a7fb4b7..fa7ab20 100644
--- a/storage/src/main/java/org/apache/kylin/storage/hbase/coprocessor/endpoint/protobuf/CubeVisit.proto
+++ b/storage/src/main/java/org/apache/kylin/storage/hbase/coprocessor/endpoint/protobuf/CubeVisit.proto
@@ -1,38 +1,33 @@
-
// usage:
// protoc --java_out=./storage/src/main/java ./storage/src/main/java/org/apache/kylin/storage/hbase/coprocessor/endpoint/protobuf/CubeVisit.proto
option java_package = "org.apache.kylin.storage.hbase.coprocessor.endpoint.generated";
+
option java_outer_classname = "CubeVisitProtos";
+
option java_generic_services = true;
+
option java_generate_equals_and_hash = true;
+
option optimize_for = SPEED;
message CubeVisitRequest {
- required bytes scanRequest = 1;
-}
-
-message CubeVisitResponseUncompressed {
- message Record {
- required bytes content = 1;
- }
- //all entries in this struct be optional to conveniently add more entries in the future
- message Stats {
- optional int64 serviceStartTime = 1;
- optional int64 serviceEndTime = 2;
- optional int32 scannedRowCount = 3;
- optional int32 aggregatedRowCount = 4;
- }
- repeated Record records = 1;
- required Stats stats = 2;
+ required bytes gtScanRequest = 1;
+ required bytes hbaseRawScan = 2;
}
-message CubeVisitResponse
-{
- required bytes compressed = 1;
+message CubeVisitResponse {
+ //all entries in this struct be optional to conveniently add more entries in the future
+ message Stats {
+ optional int64 serviceStartTime = 1;
+ optional int64 serviceEndTime = 2;
+ optional int32 scannedRowCount = 3;
+ optional int32 aggregatedRowCount = 4;
+ }
+ required bytes compressedRows = 1;
+ required Stats stats = 2;
}
service CubeVisitService {
- rpc visitCube(CubeVisitRequest)
- returns (CubeVisitResponse);
+ rpc visitCube (CubeVisitRequest) returns (CubeVisitResponse);
}
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/9d9177be/storage/src/main/java/org/apache/kylin/storage/hbase/coprocessor/endpoint/protobuf/II.proto
----------------------------------------------------------------------
diff --git a/storage/src/main/java/org/apache/kylin/storage/hbase/coprocessor/endpoint/protobuf/II.proto b/storage/src/main/java/org/apache/kylin/storage/hbase/coprocessor/endpoint/protobuf/II.proto
index eb33702..de7081f 100644
--- a/storage/src/main/java/org/apache/kylin/storage/hbase/coprocessor/endpoint/protobuf/II.proto
+++ b/storage/src/main/java/org/apache/kylin/storage/hbase/coprocessor/endpoint/protobuf/II.proto
@@ -1,11 +1,14 @@
-
// usage:
// protoc --java_out=./storage/src/main/java ./storage/src/main/java/org/apache/kylin/storage/hbase/coprocessor/endpoint/protobuf/II.proto
option java_package = "org.apache.kylin.storage.hbase.coprocessor.endpoint.generated";
+
option java_outer_classname = "IIProtos";
+
option java_generic_services = true;
+
option java_generate_equals_and_hash = true;
+
option optimize_for = SPEED;
message IIRequest {
@@ -17,30 +20,28 @@ message IIRequest {
}
message IIResponseInternal {
- message IIRow {
- required bytes columns = 1;
- optional bytes measures = 2;
- }
- //all entries in this struct be optional to conveniently add more entries in the future
- message Stats {
- optional int32 myShard = 1;
- optional int64 latestDataTime = 2;
- optional int64 serviceStartTime = 3;
- optional int64 serviceEndTime = 4;
- optional int32 scannedSlices = 5;
- }
- repeated IIRow rows = 1;
- required Stats stats = 2;
+ message IIRow {
+ required bytes columns = 1;
+ optional bytes measures = 2;
+ }
+ //all entries in this struct be optional to conveniently add more entries in the future
+ message Stats {
+ optional int32 myShard = 1;
+ optional int64 latestDataTime = 2;
+ optional int64 serviceStartTime = 3;
+ optional int64 serviceEndTime = 4;
+ optional int32 scannedSlices = 5;
+ }
+ repeated IIRow rows = 1;
+ required Stats stats = 2;
}
-message IIResponse
-{
+message IIResponse {
required bytes blob = 1;
}
service RowsService {
- rpc getRows(IIRequest)
- returns (IIResponse);
+ rpc getRows (IIRequest) returns (IIResponse);
}