Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Drill, mail # dev - [13/24] diag wip


Copy link to this message
-
[13/24] diag wip
jacques@... 2014-05-22, 01:14
http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/cb90852a/protocol/src/main/protobuf/BitControl.proto
diff --git a/protocol/src/main/protobuf/BitControl.proto b/protocol/src/main/protobuf/BitControl.proto
index d9fa4b4..386f692 100644
+++ b/protocol/src/main/protobuf/BitControl.proto
@@ -40,27 +40,8 @@ message BitStatus {
 }
 
 message FragmentStatus {
-  
-  enum FragmentState {
-    SENDING = 0;
-    AWAITING_ALLOCATION = 1;
-    RUNNING = 2;
-    FINISHED = 3;
-    CANCELLED = 4;
-    FAILED = 5;
-  }
-  
-  optional int64 memory_use = 1;
-  optional int64 batches_completed = 2;
-  optional int64 records_completed = 3;
-  optional int32 estimated_completion_percentage = 4;
-  optional FragmentState state = 5;
-  optional int64 data_processed = 6;
-  
-  optional FragmentHandle handle = 7;
-  optional exec.shared.DrillPBError error = 8;
-  optional int64 running_time = 9;
-  optional exec.shared.MinorFragmentProfile profile = 10;
+  optional exec.shared.MinorFragmentProfile profile = 1;
+  optional FragmentHandle handle = 2;
 }
 
 message PlanFragment {

http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/cb90852a/protocol/src/main/protobuf/UserBitShared.proto
diff --git a/protocol/src/main/protobuf/UserBitShared.proto b/protocol/src/main/protobuf/UserBitShared.proto
index c379112..9a3dd2a 100644
+++ b/protocol/src/main/protobuf/UserBitShared.proto
@@ -82,7 +82,8 @@ message QueryProfile {
   optional int64 start = 3;
   optional int64 end = 4;
   optional string query = 5;
-  repeated MajorFragmentProfile fragment_profile = 6;
+  optional string plan = 6;
+  repeated MajorFragmentProfile fragment_profile = 7;
 }
 
 message MajorFragmentProfile {
@@ -91,15 +92,19 @@ message MajorFragmentProfile {
 }
 
 message MinorFragmentProfile {
-  optional int32 minor_fragment_id = 1;
-  repeated OperatorProfile operator_profile = 2;
-  optional int64 start_time = 3;
-  optional int64 end_time = 4;  
+  optional FragmentState state = 1;
+  optional DrillPBError error = 2;
+  optional int32 minor_fragment_id = 3;
+  repeated OperatorProfile operator_profile = 4;
+  optional int64 start_time = 5;
+  optional int64 end_time = 6;
+  optional int64 memory_used = 7;
+  optional int64 max_memory_used = 8;
+  optional DrillbitEndpoint endpoint = 9;
 }
 
 message OperatorProfile {
   repeated StreamProfile input_profile = 1;
-  optional StreamProfile output_profile = 2;
   optional int32 operator_id = 3;
   optional int32 operator_type = 4;
   optional int64 setup_nanos = 5;
@@ -120,6 +125,14 @@ message MetricValue {
   optional double double_value = 3;
 }
 
+enum FragmentState {
+  SENDING = 0;
+  AWAITING_ALLOCATION = 1;
+  RUNNING = 2;
+  FINISHED = 3;
+  CANCELLED = 4;
+  FAILED = 5;
+}
 
 enum CoreOperatorType {
   SINGLE_SENDER = 0;