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 --- a/protocol/src/main/protobuf/BitControl.proto +++ 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 --- a/protocol/src/main/protobuf/UserBitShared.proto +++ 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;
