You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@quickstep.apache.org by ha...@apache.org on 2017/05/02 05:13:23 UTC
[11/11] incubator-quickstep git commit: WorkOrder proto clean-up.
WorkOrder proto clean-up.
Project: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/commit/a4bfab90
Tree: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/tree/a4bfab90
Diff: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/diff/a4bfab90
Branch: refs/heads/frontend-backend
Commit: a4bfab901acbdc38f3d510380857a08dee140ade
Parents: 50401ce
Author: Zuyu Zhang <zu...@apache.org>
Authored: Thu Apr 20 15:21:22 2017 -0700
Committer: Hakan Memisoglu <ha...@apache.org>
Committed: Tue May 2 00:12:54 2017 -0500
----------------------------------------------------------------------
relational_operators/WorkOrder.proto | 69 ++++++++++++++++---------------
1 file changed, 35 insertions(+), 34 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-quickstep/blob/a4bfab90/relational_operators/WorkOrder.proto
----------------------------------------------------------------------
diff --git a/relational_operators/WorkOrder.proto b/relational_operators/WorkOrder.proto
index 12a65ca..7231c84 100644
--- a/relational_operators/WorkOrder.proto
+++ b/relational_operators/WorkOrder.proto
@@ -21,13 +21,16 @@ package quickstep.serialization;
import "relational_operators/SortMergeRunOperator.proto";
+// Next tag: 25.
enum WorkOrderType {
AGGREGATION = 1;
+ BUILD_AGGREGATION_EXISTENCE_MAP = 23;
BUILD_HASH = 2;
BUILD_LIP_FILTER = 3;
CREATE_INDEX = 4; // Placeholder.
CREATE_TABLE = 5; // Placeholder.
DELETE = 6;
+ DESTROY_AGGREGATION_STATE = 22;
DESTROY_HASH = 7;
DROP_TABLE = 8;
FINALIZE_AGGREGATION = 9;
@@ -41,11 +44,9 @@ enum WorkOrderType {
SORT_RUN_GENERATION = 17;
TABLE_GENERATOR = 18;
TEXT_SCAN = 19;
+ UNION_ALL = 24;
UPDATE = 20;
WINDOW_AGGREGATION = 21;
- DESTROY_AGGREGATION_STATE = 22;
- BUILD_AGGREGATION_EXISTENCE_MAP = 23;
- UNION_ALL = 24;
}
message WorkOrder {
@@ -53,7 +54,7 @@ message WorkOrder {
required uint64 query_id = 2;
// The convention for extension numbering is that extensions for a particular
- // WorkOrderID should begin from (operator_type + 1) * 16.
+ // WorkOrderID should begin from (operator_type * 16).
extensions 16 to max;
}
@@ -66,6 +67,15 @@ message AggregationWorkOrder {
}
}
+message BuildAggregationExistenceMapWorkOrder {
+ extend WorkOrder {
+ optional int32 relation_id = 368;
+ optional fixed64 build_block_id = 369;
+ optional int32 build_attribute = 370;
+ optional uint32 aggr_state_index = 371;
+ }
+}
+
// Next tag: 39.
message BuildHashWorkOrder {
extend WorkOrder {
@@ -100,6 +110,12 @@ message DeleteWorkOrder {
}
}
+message DestroyAggregationStateWorkOrder {
+ extend WorkOrder {
+ optional uint32 aggr_state_index = 352;
+ }
+}
+
message DestroyHashWorkOrder {
extend WorkOrder {
// All required.
@@ -248,12 +264,21 @@ message TableGeneratorWorkOrder {
message TextScanWorkOrder {
extend WorkOrder {
// All required.
- optional string filename = 301;
- optional uint64 text_offset = 302;
- optional uint64 text_segment_size = 303;
- optional uint32 field_terminator = 304; // For one-byte char.
- optional bool process_escape_sequences = 305;
- optional int32 insert_destination_index = 306;
+ optional string filename = 304;
+ optional uint64 text_offset = 305;
+ optional uint64 text_segment_size = 306;
+ optional uint32 field_terminator = 307; // For one-byte char.
+ optional bool process_escape_sequences = 308;
+ optional int32 insert_destination_index = 309;
+ }
+}
+
+message UnionAllWorkOrder {
+ extend WorkOrder {
+ optional int32 relation_id = 384;
+ optional int32 insert_destination_index = 385;
+ optional fixed64 block_id = 386;
+ repeated int32 select_attribute_id = 387;
}
}
@@ -277,27 +302,3 @@ message WindowAggregationWorkOrder {
optional int32 insert_destination_index = 338;
}
}
-
-message DestroyAggregationStateWorkOrder {
- extend WorkOrder {
- optional uint32 aggr_state_index = 352;
- }
-}
-
-message BuildAggregationExistenceMapWorkOrder {
- extend WorkOrder {
- optional int32 relation_id = 368;
- optional fixed64 build_block_id = 369;
- optional int32 build_attribute = 370;
- optional uint32 aggr_state_index = 371;
- }
-}
-
-message UnionAllWorkOrder {
- extend WorkOrder {
- optional int32 relation_id = 384;
- optional int32 insert_destination_index = 385;
- optional fixed64 block_id = 386;
- repeated int32 select_attribute_id = 387;
- }
-}