You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@drill.apache.org by GitBox <gi...@apache.org> on 2021/01/09 18:53:59 UTC
[GitHub] [drill] vvysotskyi opened a new pull request #2142: DRILL-5405: Add missing operator types without dependency on protobuf enum
vvysotskyi opened a new pull request #2142:
URL: https://github.com/apache/drill/pull/2142
# [DRILL-5405](https://issues.apache.org/jira/browse/DRILL-5405): Add missing operator types without dependency on protobuf enum
## Description
Changed all operators to use string literals to provide operator type instead of int values that correspond to entries in protobuf enum. To preserve backward compatibility, `CoreOperatorType` was moved outside of probufs and used to deserialize older query profiles, so there is no need to update it every time when new operator or plugin is introduced. Newer query profiles will write both int value if the corresponding entry is present in `CoreOperatorType` and a new string value. So with these changes, older versions of Drill will be able to read profiles created by newer versions and newer versions of Drill will be able to read profiles created by older Drill.
Storage plugins that use `EasyFormatConfig` may not specify `operatorType` value, in this case, it will be constructed using the default plugin name. For example, if the default name is `text`, `operatorType` will be `TEXT_SUB_SCAN`.
## Documentation
NA
## Testing
Checked manually different cases for backward compatibility.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [drill] cgivre commented on a change in pull request #2142: DRILL-5405: Add missing operator types without dependency on protobuf enum
Posted by GitBox <gi...@apache.org>.
cgivre commented on a change in pull request #2142:
URL: https://github.com/apache/drill/pull/2142#discussion_r554487110
##########
File path: exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/CoreOperatorType.java
##########
@@ -0,0 +1,342 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.drill.exec.server.rest.profile;
+
+
+import java.util.Arrays;
+
+/**
+ * This class is used for backward compatibility when reading older query profiles that
+ * stored operator id instead of its name.
+ * <b>Please do not update this class. It will be removed for Drill 2.0</b>
+ */
+public enum CoreOperatorType {
+
+ /**
+ * <code>SINGLE_SENDER = 0;</code>
+ */
+ SINGLE_SENDER(0),
+ /**
+ * <code>BROADCAST_SENDER = 1;</code>
+ */
+ BROADCAST_SENDER(1),
+ /**
+ * <code>FILTER = 2;</code>
+ */
+ FILTER(2),
+ /**
+ * <code>HASH_AGGREGATE = 3;</code>
+ */
+ HASH_AGGREGATE(3),
+ /**
+ * <code>HASH_JOIN = 4;</code>
+ */
+ HASH_JOIN(4),
+ /**
+ * <code>MERGE_JOIN = 5;</code>
+ */
+ MERGE_JOIN(5),
+ /**
+ * <code>HASH_PARTITION_SENDER = 6;</code>
+ */
+ HASH_PARTITION_SENDER(6),
+ /**
+ * <code>LIMIT = 7;</code>
+ */
+ LIMIT(7),
+ /**
+ * <code>MERGING_RECEIVER = 8;</code>
+ */
+ MERGING_RECEIVER(8),
+ /**
+ * <code>ORDERED_PARTITION_SENDER = 9;</code>
+ */
+ ORDERED_PARTITION_SENDER(9),
+ /**
+ * <code>PROJECT = 10;</code>
+ */
+ PROJECT(10),
+ /**
+ * <code>UNORDERED_RECEIVER = 11;</code>
+ */
+ UNORDERED_RECEIVER(11),
+ /**
+ * <code>RANGE_PARTITION_SENDER = 12;</code>
+ */
+ RANGE_PARTITION_SENDER(12),
+ /**
+ * <code>SCREEN = 13;</code>
+ */
+ SCREEN(13),
+ /**
+ * <code>SELECTION_VECTOR_REMOVER = 14;</code>
+ */
+ SELECTION_VECTOR_REMOVER(14),
+ /**
+ * <code>STREAMING_AGGREGATE = 15;</code>
+ */
+ STREAMING_AGGREGATE(15),
+ /**
+ * <code>TOP_N_SORT = 16;</code>
+ */
+ TOP_N_SORT(16),
+ /**
+ * <code>EXTERNAL_SORT = 17;</code>
+ */
+ EXTERNAL_SORT(17),
+ /**
+ * <code>TRACE = 18;</code>
+ */
+ TRACE(18),
+ /**
+ * <code>UNION = 19;</code>
+ */
+ UNION(19),
+ /**
+ * <code>OLD_SORT = 20;</code>
+ */
+ OLD_SORT(20),
+ /**
+ * <code>PARQUET_ROW_GROUP_SCAN = 21;</code>
+ */
+ PARQUET_ROW_GROUP_SCAN(21),
+ /**
+ * <code>HIVE_SUB_SCAN = 22;</code>
+ */
+ HIVE_SUB_SCAN(22),
+ /**
+ * <code>SYSTEM_TABLE_SCAN = 23;</code>
+ */
+ SYSTEM_TABLE_SCAN(23),
+ /**
+ * <code>MOCK_SUB_SCAN = 24;</code>
+ */
+ MOCK_SUB_SCAN(24),
+ /**
+ * <code>PARQUET_WRITER = 25;</code>
+ */
+ PARQUET_WRITER(25),
+ /**
+ * <code>DIRECT_SUB_SCAN = 26;</code>
+ */
+ DIRECT_SUB_SCAN(26),
+ /**
+ * <code>TEXT_WRITER = 27;</code>
+ */
+ TEXT_WRITER(27),
+ /**
+ * <code>TEXT_SUB_SCAN = 28;</code>
+ */
+ TEXT_SUB_SCAN(28),
+ /**
+ * <code>JSON_SUB_SCAN = 29;</code>
+ */
+ JSON_SUB_SCAN(29),
+ /**
+ * <code>INFO_SCHEMA_SUB_SCAN = 30;</code>
+ */
+ INFO_SCHEMA_SUB_SCAN(30),
+ /**
+ * <code>COMPLEX_TO_JSON = 31;</code>
+ */
+ COMPLEX_TO_JSON(31),
+ /**
+ * <code>PRODUCER_CONSUMER = 32;</code>
+ */
+ PRODUCER_CONSUMER(32),
+ /**
+ * <code>HBASE_SUB_SCAN = 33;</code>
+ */
+ HBASE_SUB_SCAN(33),
+ /**
+ * <code>WINDOW = 34;</code>
+ */
+ WINDOW(34),
+ /**
+ * <code>NESTED_LOOP_JOIN = 35;</code>
+ */
+ NESTED_LOOP_JOIN(35),
+ /**
+ * <code>AVRO_SUB_SCAN = 36;</code>
+ */
+ AVRO_SUB_SCAN(36),
+ /**
+ * <code>PCAP_SUB_SCAN = 37;</code>
+ */
+ PCAP_SUB_SCAN(37),
+ /**
+ * <code>KAFKA_SUB_SCAN = 38;</code>
+ */
+ KAFKA_SUB_SCAN(38),
+ /**
+ * <code>KUDU_SUB_SCAN = 39;</code>
+ */
+ KUDU_SUB_SCAN(39),
+ /**
+ * <code>FLATTEN = 40;</code>
+ */
+ FLATTEN(40),
+ /**
+ * <code>LATERAL_JOIN = 41;</code>
+ */
+ LATERAL_JOIN(41),
+ /**
+ * <code>UNNEST = 42;</code>
+ */
+ UNNEST(42),
+ /**
+ * <code>HIVE_DRILL_NATIVE_PARQUET_ROW_GROUP_SCAN = 43;</code>
+ */
+ HIVE_DRILL_NATIVE_PARQUET_ROW_GROUP_SCAN(43),
+ /**
+ * <code>JDBC_SCAN = 44;</code>
+ */
+ JDBC_SCAN(44),
+ /**
+ * <code>REGEX_SUB_SCAN = 45;</code>
+ */
+ REGEX_SUB_SCAN(45),
+ /**
+ * <code>MAPRDB_SUB_SCAN = 46;</code>
+ */
+ MAPRDB_SUB_SCAN(46),
+ /**
+ * <code>MONGO_SUB_SCAN = 47;</code>
+ */
+ MONGO_SUB_SCAN(47),
+ /**
+ * <code>KUDU_WRITER = 48;</code>
+ */
+ KUDU_WRITER(48),
+ /**
+ * <code>OPEN_TSDB_SUB_SCAN = 49;</code>
+ */
+ OPEN_TSDB_SUB_SCAN(49),
+ /**
+ * <code>JSON_WRITER = 50;</code>
+ */
+ JSON_WRITER(50),
+ /**
+ * <code>HTPPD_LOG_SUB_SCAN = 51;</code>
+ */
+ HTPPD_LOG_SUB_SCAN(51),
+ /**
+ * <code>IMAGE_SUB_SCAN = 52;</code>
+ */
+ IMAGE_SUB_SCAN(52),
+ /**
+ * <code>SEQUENCE_SUB_SCAN = 53;</code>
+ */
+ SEQUENCE_SUB_SCAN(53),
+ /**
+ * <code>PARTITION_LIMIT = 54;</code>
+ */
+ PARTITION_LIMIT(54),
+ /**
+ * <code>PCAPNG_SUB_SCAN = 55;</code>
+ */
+ PCAPNG_SUB_SCAN(55),
+ /**
+ * <code>RUNTIME_FILTER = 56;</code>
+ */
+ RUNTIME_FILTER(56),
+ /**
+ * <code>ROWKEY_JOIN = 57;</code>
+ */
+ ROWKEY_JOIN(57),
+ /**
+ * <code>SYSLOG_SUB_SCAN = 58;</code>
+ */
+ SYSLOG_SUB_SCAN(58),
+ /**
+ * <code>STATISTICS_AGGREGATE = 59;</code>
+ */
+ STATISTICS_AGGREGATE(59),
+ /**
+ * <code>UNPIVOT_MAPS = 60;</code>
+ */
+ UNPIVOT_MAPS(60),
+ /**
+ * <code>STATISTICS_MERGE = 61;</code>
+ */
+ STATISTICS_MERGE(61),
+ /**
+ * <code>LTSV_SUB_SCAN = 62;</code>
+ */
+ LTSV_SUB_SCAN(62),
+ /**
+ * <code>HDF5_SUB_SCAN = 63;</code>
+ */
+ HDF5_SUB_SCAN(63),
+ /**
+ * <code>EXCEL_SUB_SCAN = 64;</code>
+ */
+ EXCEL_SUB_SCAN(64),
+ /**
+ * <code>SHP_SUB_SCAN = 65;</code>
+ */
+ SHP_SUB_SCAN(65),
+ /**
+ * <code>METADATA_HANDLER = 66;</code>
+ */
+ METADATA_HANDLER(66),
+ /**
+ * <code>METADATA_CONTROLLER = 67;</code>
+ */
+ METADATA_CONTROLLER(67),
+ /**
+ * <code>DRUID_SUB_SCAN = 68;</code>
+ */
+ DRUID_SUB_SCAN(68),
+ /**
+ * <code>SPSS_SUB_SCAN = 69;</code>
+ */
+ SPSS_SUB_SCAN(69),
+ /**
+ * <code>HTTP_SUB_SCAN = 70;</code>
+ */
+ HTTP_SUB_SCAN(70),
+ /**
+ * <code>XML_SUB_SCAN = 71;</code>
+ */
+ XML_SUB_SCAN(71);
+
+ private final int value;
+
+ CoreOperatorType(int value) {
+ this.value = value;
+ }
+
+ public int getId() {
+ return value;
+ }
+
+ public static CoreOperatorType valueOf(int id) {
+ if (id >= 0 && id <= XML_SUB_SCAN.getId()) {
Review comment:
@vvysotskyi
Thanks for the PR. If someone submits a new format or storage plugin, do they have to modify this file?
##########
File path: exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/OperatorWrapper.java
##########
@@ -303,27 +313,27 @@ public void addSummary(TableBuilder tb, Map<String, Long> majorFragmentBusyTally
* @param operatorType
* @return index of spill metric
*/
- private int getSpillCycleMetricIndex(CoreOperatorType operatorType) {
+ private int getSpillCycleMetricIndex(String operatorType) {
// TODO: DRILL-6642, replace null values for ProtocolMessageEnum with UNRECOGNIZED NullValue to avoid null checks
if (operatorType == null) {
Review comment:
Do you think it would be worth addressing DRILL-6642 in this PR?
##########
File path: exec/java-exec/src/test/java/org/apache/drill/exec/physical/impl/scan/v3/ScanFixture.java
##########
@@ -81,8 +81,8 @@ public ScanFixture build() {
Scan scanConfig = new AbstractSubScan("bob") {
Review comment:
Bob?
##########
File path: exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/CoreOperatorType.java
##########
@@ -0,0 +1,342 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.drill.exec.server.rest.profile;
+
+
+import java.util.Arrays;
+
+/**
+ * This class is used for backward compatibility when reading older query profiles that
+ * stored operator id instead of its name.
+ * <b>Please do not update this class. It will be removed for Drill 2.0</b>
+ */
+public enum CoreOperatorType {
+
+ /**
+ * <code>SINGLE_SENDER = 0;</code>
+ */
+ SINGLE_SENDER(0),
+ /**
+ * <code>BROADCAST_SENDER = 1;</code>
+ */
+ BROADCAST_SENDER(1),
+ /**
+ * <code>FILTER = 2;</code>
+ */
+ FILTER(2),
+ /**
+ * <code>HASH_AGGREGATE = 3;</code>
+ */
+ HASH_AGGREGATE(3),
+ /**
+ * <code>HASH_JOIN = 4;</code>
+ */
+ HASH_JOIN(4),
+ /**
+ * <code>MERGE_JOIN = 5;</code>
+ */
+ MERGE_JOIN(5),
+ /**
+ * <code>HASH_PARTITION_SENDER = 6;</code>
+ */
+ HASH_PARTITION_SENDER(6),
+ /**
+ * <code>LIMIT = 7;</code>
+ */
+ LIMIT(7),
+ /**
+ * <code>MERGING_RECEIVER = 8;</code>
+ */
+ MERGING_RECEIVER(8),
+ /**
+ * <code>ORDERED_PARTITION_SENDER = 9;</code>
+ */
+ ORDERED_PARTITION_SENDER(9),
+ /**
+ * <code>PROJECT = 10;</code>
+ */
+ PROJECT(10),
+ /**
+ * <code>UNORDERED_RECEIVER = 11;</code>
+ */
+ UNORDERED_RECEIVER(11),
+ /**
+ * <code>RANGE_PARTITION_SENDER = 12;</code>
+ */
+ RANGE_PARTITION_SENDER(12),
+ /**
+ * <code>SCREEN = 13;</code>
+ */
+ SCREEN(13),
+ /**
+ * <code>SELECTION_VECTOR_REMOVER = 14;</code>
+ */
+ SELECTION_VECTOR_REMOVER(14),
+ /**
+ * <code>STREAMING_AGGREGATE = 15;</code>
+ */
+ STREAMING_AGGREGATE(15),
+ /**
+ * <code>TOP_N_SORT = 16;</code>
+ */
+ TOP_N_SORT(16),
+ /**
+ * <code>EXTERNAL_SORT = 17;</code>
+ */
+ EXTERNAL_SORT(17),
+ /**
+ * <code>TRACE = 18;</code>
+ */
+ TRACE(18),
+ /**
+ * <code>UNION = 19;</code>
+ */
+ UNION(19),
+ /**
+ * <code>OLD_SORT = 20;</code>
+ */
+ OLD_SORT(20),
+ /**
+ * <code>PARQUET_ROW_GROUP_SCAN = 21;</code>
+ */
+ PARQUET_ROW_GROUP_SCAN(21),
+ /**
+ * <code>HIVE_SUB_SCAN = 22;</code>
+ */
+ HIVE_SUB_SCAN(22),
+ /**
+ * <code>SYSTEM_TABLE_SCAN = 23;</code>
+ */
+ SYSTEM_TABLE_SCAN(23),
+ /**
+ * <code>MOCK_SUB_SCAN = 24;</code>
+ */
+ MOCK_SUB_SCAN(24),
+ /**
+ * <code>PARQUET_WRITER = 25;</code>
+ */
+ PARQUET_WRITER(25),
+ /**
+ * <code>DIRECT_SUB_SCAN = 26;</code>
+ */
+ DIRECT_SUB_SCAN(26),
+ /**
+ * <code>TEXT_WRITER = 27;</code>
+ */
+ TEXT_WRITER(27),
+ /**
+ * <code>TEXT_SUB_SCAN = 28;</code>
+ */
+ TEXT_SUB_SCAN(28),
+ /**
+ * <code>JSON_SUB_SCAN = 29;</code>
+ */
+ JSON_SUB_SCAN(29),
+ /**
+ * <code>INFO_SCHEMA_SUB_SCAN = 30;</code>
+ */
+ INFO_SCHEMA_SUB_SCAN(30),
+ /**
+ * <code>COMPLEX_TO_JSON = 31;</code>
+ */
+ COMPLEX_TO_JSON(31),
+ /**
+ * <code>PRODUCER_CONSUMER = 32;</code>
+ */
+ PRODUCER_CONSUMER(32),
+ /**
+ * <code>HBASE_SUB_SCAN = 33;</code>
+ */
+ HBASE_SUB_SCAN(33),
+ /**
+ * <code>WINDOW = 34;</code>
+ */
+ WINDOW(34),
+ /**
+ * <code>NESTED_LOOP_JOIN = 35;</code>
+ */
+ NESTED_LOOP_JOIN(35),
+ /**
+ * <code>AVRO_SUB_SCAN = 36;</code>
+ */
+ AVRO_SUB_SCAN(36),
+ /**
+ * <code>PCAP_SUB_SCAN = 37;</code>
+ */
+ PCAP_SUB_SCAN(37),
+ /**
+ * <code>KAFKA_SUB_SCAN = 38;</code>
+ */
+ KAFKA_SUB_SCAN(38),
+ /**
+ * <code>KUDU_SUB_SCAN = 39;</code>
+ */
+ KUDU_SUB_SCAN(39),
+ /**
+ * <code>FLATTEN = 40;</code>
+ */
+ FLATTEN(40),
+ /**
+ * <code>LATERAL_JOIN = 41;</code>
+ */
+ LATERAL_JOIN(41),
+ /**
+ * <code>UNNEST = 42;</code>
+ */
+ UNNEST(42),
+ /**
+ * <code>HIVE_DRILL_NATIVE_PARQUET_ROW_GROUP_SCAN = 43;</code>
+ */
+ HIVE_DRILL_NATIVE_PARQUET_ROW_GROUP_SCAN(43),
+ /**
+ * <code>JDBC_SCAN = 44;</code>
+ */
+ JDBC_SCAN(44),
+ /**
+ * <code>REGEX_SUB_SCAN = 45;</code>
+ */
+ REGEX_SUB_SCAN(45),
+ /**
+ * <code>MAPRDB_SUB_SCAN = 46;</code>
+ */
+ MAPRDB_SUB_SCAN(46),
+ /**
+ * <code>MONGO_SUB_SCAN = 47;</code>
+ */
+ MONGO_SUB_SCAN(47),
+ /**
+ * <code>KUDU_WRITER = 48;</code>
+ */
+ KUDU_WRITER(48),
+ /**
+ * <code>OPEN_TSDB_SUB_SCAN = 49;</code>
+ */
+ OPEN_TSDB_SUB_SCAN(49),
+ /**
+ * <code>JSON_WRITER = 50;</code>
+ */
+ JSON_WRITER(50),
+ /**
+ * <code>HTPPD_LOG_SUB_SCAN = 51;</code>
+ */
+ HTPPD_LOG_SUB_SCAN(51),
+ /**
+ * <code>IMAGE_SUB_SCAN = 52;</code>
+ */
+ IMAGE_SUB_SCAN(52),
+ /**
+ * <code>SEQUENCE_SUB_SCAN = 53;</code>
+ */
+ SEQUENCE_SUB_SCAN(53),
+ /**
+ * <code>PARTITION_LIMIT = 54;</code>
+ */
+ PARTITION_LIMIT(54),
+ /**
+ * <code>PCAPNG_SUB_SCAN = 55;</code>
+ */
+ PCAPNG_SUB_SCAN(55),
+ /**
+ * <code>RUNTIME_FILTER = 56;</code>
+ */
+ RUNTIME_FILTER(56),
+ /**
+ * <code>ROWKEY_JOIN = 57;</code>
+ */
+ ROWKEY_JOIN(57),
+ /**
+ * <code>SYSLOG_SUB_SCAN = 58;</code>
+ */
+ SYSLOG_SUB_SCAN(58),
+ /**
+ * <code>STATISTICS_AGGREGATE = 59;</code>
+ */
+ STATISTICS_AGGREGATE(59),
+ /**
+ * <code>UNPIVOT_MAPS = 60;</code>
+ */
+ UNPIVOT_MAPS(60),
+ /**
+ * <code>STATISTICS_MERGE = 61;</code>
+ */
+ STATISTICS_MERGE(61),
+ /**
+ * <code>LTSV_SUB_SCAN = 62;</code>
+ */
+ LTSV_SUB_SCAN(62),
+ /**
+ * <code>HDF5_SUB_SCAN = 63;</code>
+ */
+ HDF5_SUB_SCAN(63),
+ /**
+ * <code>EXCEL_SUB_SCAN = 64;</code>
+ */
+ EXCEL_SUB_SCAN(64),
+ /**
+ * <code>SHP_SUB_SCAN = 65;</code>
+ */
+ SHP_SUB_SCAN(65),
+ /**
+ * <code>METADATA_HANDLER = 66;</code>
+ */
+ METADATA_HANDLER(66),
+ /**
+ * <code>METADATA_CONTROLLER = 67;</code>
+ */
+ METADATA_CONTROLLER(67),
+ /**
+ * <code>DRUID_SUB_SCAN = 68;</code>
+ */
+ DRUID_SUB_SCAN(68),
+ /**
+ * <code>SPSS_SUB_SCAN = 69;</code>
+ */
+ SPSS_SUB_SCAN(69),
+ /**
+ * <code>HTTP_SUB_SCAN = 70;</code>
+ */
+ HTTP_SUB_SCAN(70),
+ /**
+ * <code>XML_SUB_SCAN = 71;</code>
+ */
+ XML_SUB_SCAN(71);
+
+ private final int value;
+
+ CoreOperatorType(int value) {
+ this.value = value;
+ }
+
+ public int getId() {
+ return value;
+ }
+
+ public static CoreOperatorType valueOf(int id) {
+ if (id >= 0 && id <= XML_SUB_SCAN.getId()) {
Review comment:
Perfect
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [drill] vvysotskyi commented on a change in pull request #2142: DRILL-5405: Add missing operator types without dependency on protobuf enum
Posted by GitBox <gi...@apache.org>.
vvysotskyi commented on a change in pull request #2142:
URL: https://github.com/apache/drill/pull/2142#discussion_r554488742
##########
File path: exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/CoreOperatorType.java
##########
@@ -0,0 +1,342 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.drill.exec.server.rest.profile;
+
+
+import java.util.Arrays;
+
+/**
+ * This class is used for backward compatibility when reading older query profiles that
+ * stored operator id instead of its name.
+ * <b>Please do not update this class. It will be removed for Drill 2.0</b>
+ */
+public enum CoreOperatorType {
+
+ /**
+ * <code>SINGLE_SENDER = 0;</code>
+ */
+ SINGLE_SENDER(0),
+ /**
+ * <code>BROADCAST_SENDER = 1;</code>
+ */
+ BROADCAST_SENDER(1),
+ /**
+ * <code>FILTER = 2;</code>
+ */
+ FILTER(2),
+ /**
+ * <code>HASH_AGGREGATE = 3;</code>
+ */
+ HASH_AGGREGATE(3),
+ /**
+ * <code>HASH_JOIN = 4;</code>
+ */
+ HASH_JOIN(4),
+ /**
+ * <code>MERGE_JOIN = 5;</code>
+ */
+ MERGE_JOIN(5),
+ /**
+ * <code>HASH_PARTITION_SENDER = 6;</code>
+ */
+ HASH_PARTITION_SENDER(6),
+ /**
+ * <code>LIMIT = 7;</code>
+ */
+ LIMIT(7),
+ /**
+ * <code>MERGING_RECEIVER = 8;</code>
+ */
+ MERGING_RECEIVER(8),
+ /**
+ * <code>ORDERED_PARTITION_SENDER = 9;</code>
+ */
+ ORDERED_PARTITION_SENDER(9),
+ /**
+ * <code>PROJECT = 10;</code>
+ */
+ PROJECT(10),
+ /**
+ * <code>UNORDERED_RECEIVER = 11;</code>
+ */
+ UNORDERED_RECEIVER(11),
+ /**
+ * <code>RANGE_PARTITION_SENDER = 12;</code>
+ */
+ RANGE_PARTITION_SENDER(12),
+ /**
+ * <code>SCREEN = 13;</code>
+ */
+ SCREEN(13),
+ /**
+ * <code>SELECTION_VECTOR_REMOVER = 14;</code>
+ */
+ SELECTION_VECTOR_REMOVER(14),
+ /**
+ * <code>STREAMING_AGGREGATE = 15;</code>
+ */
+ STREAMING_AGGREGATE(15),
+ /**
+ * <code>TOP_N_SORT = 16;</code>
+ */
+ TOP_N_SORT(16),
+ /**
+ * <code>EXTERNAL_SORT = 17;</code>
+ */
+ EXTERNAL_SORT(17),
+ /**
+ * <code>TRACE = 18;</code>
+ */
+ TRACE(18),
+ /**
+ * <code>UNION = 19;</code>
+ */
+ UNION(19),
+ /**
+ * <code>OLD_SORT = 20;</code>
+ */
+ OLD_SORT(20),
+ /**
+ * <code>PARQUET_ROW_GROUP_SCAN = 21;</code>
+ */
+ PARQUET_ROW_GROUP_SCAN(21),
+ /**
+ * <code>HIVE_SUB_SCAN = 22;</code>
+ */
+ HIVE_SUB_SCAN(22),
+ /**
+ * <code>SYSTEM_TABLE_SCAN = 23;</code>
+ */
+ SYSTEM_TABLE_SCAN(23),
+ /**
+ * <code>MOCK_SUB_SCAN = 24;</code>
+ */
+ MOCK_SUB_SCAN(24),
+ /**
+ * <code>PARQUET_WRITER = 25;</code>
+ */
+ PARQUET_WRITER(25),
+ /**
+ * <code>DIRECT_SUB_SCAN = 26;</code>
+ */
+ DIRECT_SUB_SCAN(26),
+ /**
+ * <code>TEXT_WRITER = 27;</code>
+ */
+ TEXT_WRITER(27),
+ /**
+ * <code>TEXT_SUB_SCAN = 28;</code>
+ */
+ TEXT_SUB_SCAN(28),
+ /**
+ * <code>JSON_SUB_SCAN = 29;</code>
+ */
+ JSON_SUB_SCAN(29),
+ /**
+ * <code>INFO_SCHEMA_SUB_SCAN = 30;</code>
+ */
+ INFO_SCHEMA_SUB_SCAN(30),
+ /**
+ * <code>COMPLEX_TO_JSON = 31;</code>
+ */
+ COMPLEX_TO_JSON(31),
+ /**
+ * <code>PRODUCER_CONSUMER = 32;</code>
+ */
+ PRODUCER_CONSUMER(32),
+ /**
+ * <code>HBASE_SUB_SCAN = 33;</code>
+ */
+ HBASE_SUB_SCAN(33),
+ /**
+ * <code>WINDOW = 34;</code>
+ */
+ WINDOW(34),
+ /**
+ * <code>NESTED_LOOP_JOIN = 35;</code>
+ */
+ NESTED_LOOP_JOIN(35),
+ /**
+ * <code>AVRO_SUB_SCAN = 36;</code>
+ */
+ AVRO_SUB_SCAN(36),
+ /**
+ * <code>PCAP_SUB_SCAN = 37;</code>
+ */
+ PCAP_SUB_SCAN(37),
+ /**
+ * <code>KAFKA_SUB_SCAN = 38;</code>
+ */
+ KAFKA_SUB_SCAN(38),
+ /**
+ * <code>KUDU_SUB_SCAN = 39;</code>
+ */
+ KUDU_SUB_SCAN(39),
+ /**
+ * <code>FLATTEN = 40;</code>
+ */
+ FLATTEN(40),
+ /**
+ * <code>LATERAL_JOIN = 41;</code>
+ */
+ LATERAL_JOIN(41),
+ /**
+ * <code>UNNEST = 42;</code>
+ */
+ UNNEST(42),
+ /**
+ * <code>HIVE_DRILL_NATIVE_PARQUET_ROW_GROUP_SCAN = 43;</code>
+ */
+ HIVE_DRILL_NATIVE_PARQUET_ROW_GROUP_SCAN(43),
+ /**
+ * <code>JDBC_SCAN = 44;</code>
+ */
+ JDBC_SCAN(44),
+ /**
+ * <code>REGEX_SUB_SCAN = 45;</code>
+ */
+ REGEX_SUB_SCAN(45),
+ /**
+ * <code>MAPRDB_SUB_SCAN = 46;</code>
+ */
+ MAPRDB_SUB_SCAN(46),
+ /**
+ * <code>MONGO_SUB_SCAN = 47;</code>
+ */
+ MONGO_SUB_SCAN(47),
+ /**
+ * <code>KUDU_WRITER = 48;</code>
+ */
+ KUDU_WRITER(48),
+ /**
+ * <code>OPEN_TSDB_SUB_SCAN = 49;</code>
+ */
+ OPEN_TSDB_SUB_SCAN(49),
+ /**
+ * <code>JSON_WRITER = 50;</code>
+ */
+ JSON_WRITER(50),
+ /**
+ * <code>HTPPD_LOG_SUB_SCAN = 51;</code>
+ */
+ HTPPD_LOG_SUB_SCAN(51),
+ /**
+ * <code>IMAGE_SUB_SCAN = 52;</code>
+ */
+ IMAGE_SUB_SCAN(52),
+ /**
+ * <code>SEQUENCE_SUB_SCAN = 53;</code>
+ */
+ SEQUENCE_SUB_SCAN(53),
+ /**
+ * <code>PARTITION_LIMIT = 54;</code>
+ */
+ PARTITION_LIMIT(54),
+ /**
+ * <code>PCAPNG_SUB_SCAN = 55;</code>
+ */
+ PCAPNG_SUB_SCAN(55),
+ /**
+ * <code>RUNTIME_FILTER = 56;</code>
+ */
+ RUNTIME_FILTER(56),
+ /**
+ * <code>ROWKEY_JOIN = 57;</code>
+ */
+ ROWKEY_JOIN(57),
+ /**
+ * <code>SYSLOG_SUB_SCAN = 58;</code>
+ */
+ SYSLOG_SUB_SCAN(58),
+ /**
+ * <code>STATISTICS_AGGREGATE = 59;</code>
+ */
+ STATISTICS_AGGREGATE(59),
+ /**
+ * <code>UNPIVOT_MAPS = 60;</code>
+ */
+ UNPIVOT_MAPS(60),
+ /**
+ * <code>STATISTICS_MERGE = 61;</code>
+ */
+ STATISTICS_MERGE(61),
+ /**
+ * <code>LTSV_SUB_SCAN = 62;</code>
+ */
+ LTSV_SUB_SCAN(62),
+ /**
+ * <code>HDF5_SUB_SCAN = 63;</code>
+ */
+ HDF5_SUB_SCAN(63),
+ /**
+ * <code>EXCEL_SUB_SCAN = 64;</code>
+ */
+ EXCEL_SUB_SCAN(64),
+ /**
+ * <code>SHP_SUB_SCAN = 65;</code>
+ */
+ SHP_SUB_SCAN(65),
+ /**
+ * <code>METADATA_HANDLER = 66;</code>
+ */
+ METADATA_HANDLER(66),
+ /**
+ * <code>METADATA_CONTROLLER = 67;</code>
+ */
+ METADATA_CONTROLLER(67),
+ /**
+ * <code>DRUID_SUB_SCAN = 68;</code>
+ */
+ DRUID_SUB_SCAN(68),
+ /**
+ * <code>SPSS_SUB_SCAN = 69;</code>
+ */
+ SPSS_SUB_SCAN(69),
+ /**
+ * <code>HTTP_SUB_SCAN = 70;</code>
+ */
+ HTTP_SUB_SCAN(70),
+ /**
+ * <code>XML_SUB_SCAN = 71;</code>
+ */
+ XML_SUB_SCAN(71);
+
+ private final int value;
+
+ CoreOperatorType(int value) {
+ this.value = value;
+ }
+
+ public int getId() {
+ return value;
+ }
+
+ public static CoreOperatorType valueOf(int id) {
+ if (id >= 0 && id <= XML_SUB_SCAN.getId()) {
Review comment:
No, this class shouldn't be modified anymore. It is used for backward compatibility only. I've tried to state that in its Javadoc, but please let me know if it should be extended with some additional details.
If someone submits a format or plugin, they will specify a string that will be used as operator type in the query profile.
##########
File path: exec/java-exec/src/test/java/org/apache/drill/exec/physical/impl/scan/v3/ScanFixture.java
##########
@@ -81,8 +81,8 @@ public ScanFixture build() {
Scan scanConfig = new AbstractSubScan("bob") {
Review comment:
It was added in the scope of from DRILL-7701, so I'm not sure about the intention, perhaps some random name that may be also used in some tests.
Or this name is used intentionally if we also have Alice somewhere in the code 🙂
##########
File path: exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/OperatorWrapper.java
##########
@@ -303,27 +313,27 @@ public void addSummary(TableBuilder tb, Map<String, Long> majorFragmentBusyTally
* @param operatorType
* @return index of spill metric
*/
- private int getSpillCycleMetricIndex(CoreOperatorType operatorType) {
+ private int getSpillCycleMetricIndex(String operatorType) {
// TODO: DRILL-6642, replace null values for ProtocolMessageEnum with UNRECOGNIZED NullValue to avoid null checks
if (operatorType == null) {
Review comment:
Looks like some other Jira ticket number was meant there since DRILL-6642 is resolved.
We can't use the non-null value for operator type (it is string now) until we preserve backward compatibility for reading older profiles. With the changes in this PR, we check whether the operator type string is set in the profile, and if not, we will read the operator id that was used before these changes. Having some default value will enforce us to move additional checks to other places, so I don't think that we should address that ticket until we use both values. Maybe for Drill 2.0 when we will be able to break the compatibility, it may be addressed.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [drill] cgivre commented on a change in pull request #2142: DRILL-5405: Add missing operator types without dependency on protobuf enum
Posted by GitBox <gi...@apache.org>.
cgivre commented on a change in pull request #2142:
URL: https://github.com/apache/drill/pull/2142#discussion_r554492899
##########
File path: exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/CoreOperatorType.java
##########
@@ -0,0 +1,342 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.drill.exec.server.rest.profile;
+
+
+import java.util.Arrays;
+
+/**
+ * This class is used for backward compatibility when reading older query profiles that
+ * stored operator id instead of its name.
+ * <b>Please do not update this class. It will be removed for Drill 2.0</b>
+ */
+public enum CoreOperatorType {
+
+ /**
+ * <code>SINGLE_SENDER = 0;</code>
+ */
+ SINGLE_SENDER(0),
+ /**
+ * <code>BROADCAST_SENDER = 1;</code>
+ */
+ BROADCAST_SENDER(1),
+ /**
+ * <code>FILTER = 2;</code>
+ */
+ FILTER(2),
+ /**
+ * <code>HASH_AGGREGATE = 3;</code>
+ */
+ HASH_AGGREGATE(3),
+ /**
+ * <code>HASH_JOIN = 4;</code>
+ */
+ HASH_JOIN(4),
+ /**
+ * <code>MERGE_JOIN = 5;</code>
+ */
+ MERGE_JOIN(5),
+ /**
+ * <code>HASH_PARTITION_SENDER = 6;</code>
+ */
+ HASH_PARTITION_SENDER(6),
+ /**
+ * <code>LIMIT = 7;</code>
+ */
+ LIMIT(7),
+ /**
+ * <code>MERGING_RECEIVER = 8;</code>
+ */
+ MERGING_RECEIVER(8),
+ /**
+ * <code>ORDERED_PARTITION_SENDER = 9;</code>
+ */
+ ORDERED_PARTITION_SENDER(9),
+ /**
+ * <code>PROJECT = 10;</code>
+ */
+ PROJECT(10),
+ /**
+ * <code>UNORDERED_RECEIVER = 11;</code>
+ */
+ UNORDERED_RECEIVER(11),
+ /**
+ * <code>RANGE_PARTITION_SENDER = 12;</code>
+ */
+ RANGE_PARTITION_SENDER(12),
+ /**
+ * <code>SCREEN = 13;</code>
+ */
+ SCREEN(13),
+ /**
+ * <code>SELECTION_VECTOR_REMOVER = 14;</code>
+ */
+ SELECTION_VECTOR_REMOVER(14),
+ /**
+ * <code>STREAMING_AGGREGATE = 15;</code>
+ */
+ STREAMING_AGGREGATE(15),
+ /**
+ * <code>TOP_N_SORT = 16;</code>
+ */
+ TOP_N_SORT(16),
+ /**
+ * <code>EXTERNAL_SORT = 17;</code>
+ */
+ EXTERNAL_SORT(17),
+ /**
+ * <code>TRACE = 18;</code>
+ */
+ TRACE(18),
+ /**
+ * <code>UNION = 19;</code>
+ */
+ UNION(19),
+ /**
+ * <code>OLD_SORT = 20;</code>
+ */
+ OLD_SORT(20),
+ /**
+ * <code>PARQUET_ROW_GROUP_SCAN = 21;</code>
+ */
+ PARQUET_ROW_GROUP_SCAN(21),
+ /**
+ * <code>HIVE_SUB_SCAN = 22;</code>
+ */
+ HIVE_SUB_SCAN(22),
+ /**
+ * <code>SYSTEM_TABLE_SCAN = 23;</code>
+ */
+ SYSTEM_TABLE_SCAN(23),
+ /**
+ * <code>MOCK_SUB_SCAN = 24;</code>
+ */
+ MOCK_SUB_SCAN(24),
+ /**
+ * <code>PARQUET_WRITER = 25;</code>
+ */
+ PARQUET_WRITER(25),
+ /**
+ * <code>DIRECT_SUB_SCAN = 26;</code>
+ */
+ DIRECT_SUB_SCAN(26),
+ /**
+ * <code>TEXT_WRITER = 27;</code>
+ */
+ TEXT_WRITER(27),
+ /**
+ * <code>TEXT_SUB_SCAN = 28;</code>
+ */
+ TEXT_SUB_SCAN(28),
+ /**
+ * <code>JSON_SUB_SCAN = 29;</code>
+ */
+ JSON_SUB_SCAN(29),
+ /**
+ * <code>INFO_SCHEMA_SUB_SCAN = 30;</code>
+ */
+ INFO_SCHEMA_SUB_SCAN(30),
+ /**
+ * <code>COMPLEX_TO_JSON = 31;</code>
+ */
+ COMPLEX_TO_JSON(31),
+ /**
+ * <code>PRODUCER_CONSUMER = 32;</code>
+ */
+ PRODUCER_CONSUMER(32),
+ /**
+ * <code>HBASE_SUB_SCAN = 33;</code>
+ */
+ HBASE_SUB_SCAN(33),
+ /**
+ * <code>WINDOW = 34;</code>
+ */
+ WINDOW(34),
+ /**
+ * <code>NESTED_LOOP_JOIN = 35;</code>
+ */
+ NESTED_LOOP_JOIN(35),
+ /**
+ * <code>AVRO_SUB_SCAN = 36;</code>
+ */
+ AVRO_SUB_SCAN(36),
+ /**
+ * <code>PCAP_SUB_SCAN = 37;</code>
+ */
+ PCAP_SUB_SCAN(37),
+ /**
+ * <code>KAFKA_SUB_SCAN = 38;</code>
+ */
+ KAFKA_SUB_SCAN(38),
+ /**
+ * <code>KUDU_SUB_SCAN = 39;</code>
+ */
+ KUDU_SUB_SCAN(39),
+ /**
+ * <code>FLATTEN = 40;</code>
+ */
+ FLATTEN(40),
+ /**
+ * <code>LATERAL_JOIN = 41;</code>
+ */
+ LATERAL_JOIN(41),
+ /**
+ * <code>UNNEST = 42;</code>
+ */
+ UNNEST(42),
+ /**
+ * <code>HIVE_DRILL_NATIVE_PARQUET_ROW_GROUP_SCAN = 43;</code>
+ */
+ HIVE_DRILL_NATIVE_PARQUET_ROW_GROUP_SCAN(43),
+ /**
+ * <code>JDBC_SCAN = 44;</code>
+ */
+ JDBC_SCAN(44),
+ /**
+ * <code>REGEX_SUB_SCAN = 45;</code>
+ */
+ REGEX_SUB_SCAN(45),
+ /**
+ * <code>MAPRDB_SUB_SCAN = 46;</code>
+ */
+ MAPRDB_SUB_SCAN(46),
+ /**
+ * <code>MONGO_SUB_SCAN = 47;</code>
+ */
+ MONGO_SUB_SCAN(47),
+ /**
+ * <code>KUDU_WRITER = 48;</code>
+ */
+ KUDU_WRITER(48),
+ /**
+ * <code>OPEN_TSDB_SUB_SCAN = 49;</code>
+ */
+ OPEN_TSDB_SUB_SCAN(49),
+ /**
+ * <code>JSON_WRITER = 50;</code>
+ */
+ JSON_WRITER(50),
+ /**
+ * <code>HTPPD_LOG_SUB_SCAN = 51;</code>
+ */
+ HTPPD_LOG_SUB_SCAN(51),
+ /**
+ * <code>IMAGE_SUB_SCAN = 52;</code>
+ */
+ IMAGE_SUB_SCAN(52),
+ /**
+ * <code>SEQUENCE_SUB_SCAN = 53;</code>
+ */
+ SEQUENCE_SUB_SCAN(53),
+ /**
+ * <code>PARTITION_LIMIT = 54;</code>
+ */
+ PARTITION_LIMIT(54),
+ /**
+ * <code>PCAPNG_SUB_SCAN = 55;</code>
+ */
+ PCAPNG_SUB_SCAN(55),
+ /**
+ * <code>RUNTIME_FILTER = 56;</code>
+ */
+ RUNTIME_FILTER(56),
+ /**
+ * <code>ROWKEY_JOIN = 57;</code>
+ */
+ ROWKEY_JOIN(57),
+ /**
+ * <code>SYSLOG_SUB_SCAN = 58;</code>
+ */
+ SYSLOG_SUB_SCAN(58),
+ /**
+ * <code>STATISTICS_AGGREGATE = 59;</code>
+ */
+ STATISTICS_AGGREGATE(59),
+ /**
+ * <code>UNPIVOT_MAPS = 60;</code>
+ */
+ UNPIVOT_MAPS(60),
+ /**
+ * <code>STATISTICS_MERGE = 61;</code>
+ */
+ STATISTICS_MERGE(61),
+ /**
+ * <code>LTSV_SUB_SCAN = 62;</code>
+ */
+ LTSV_SUB_SCAN(62),
+ /**
+ * <code>HDF5_SUB_SCAN = 63;</code>
+ */
+ HDF5_SUB_SCAN(63),
+ /**
+ * <code>EXCEL_SUB_SCAN = 64;</code>
+ */
+ EXCEL_SUB_SCAN(64),
+ /**
+ * <code>SHP_SUB_SCAN = 65;</code>
+ */
+ SHP_SUB_SCAN(65),
+ /**
+ * <code>METADATA_HANDLER = 66;</code>
+ */
+ METADATA_HANDLER(66),
+ /**
+ * <code>METADATA_CONTROLLER = 67;</code>
+ */
+ METADATA_CONTROLLER(67),
+ /**
+ * <code>DRUID_SUB_SCAN = 68;</code>
+ */
+ DRUID_SUB_SCAN(68),
+ /**
+ * <code>SPSS_SUB_SCAN = 69;</code>
+ */
+ SPSS_SUB_SCAN(69),
+ /**
+ * <code>HTTP_SUB_SCAN = 70;</code>
+ */
+ HTTP_SUB_SCAN(70),
+ /**
+ * <code>XML_SUB_SCAN = 71;</code>
+ */
+ XML_SUB_SCAN(71);
+
+ private final int value;
+
+ CoreOperatorType(int value) {
+ this.value = value;
+ }
+
+ public int getId() {
+ return value;
+ }
+
+ public static CoreOperatorType valueOf(int id) {
+ if (id >= 0 && id <= XML_SUB_SCAN.getId()) {
Review comment:
Perfect
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [drill] vvysotskyi commented on a change in pull request #2142: DRILL-5405: Add missing operator types without dependency on protobuf enum
Posted by GitBox <gi...@apache.org>.
vvysotskyi commented on a change in pull request #2142:
URL: https://github.com/apache/drill/pull/2142#discussion_r554488742
##########
File path: exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/CoreOperatorType.java
##########
@@ -0,0 +1,342 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.drill.exec.server.rest.profile;
+
+
+import java.util.Arrays;
+
+/**
+ * This class is used for backward compatibility when reading older query profiles that
+ * stored operator id instead of its name.
+ * <b>Please do not update this class. It will be removed for Drill 2.0</b>
+ */
+public enum CoreOperatorType {
+
+ /**
+ * <code>SINGLE_SENDER = 0;</code>
+ */
+ SINGLE_SENDER(0),
+ /**
+ * <code>BROADCAST_SENDER = 1;</code>
+ */
+ BROADCAST_SENDER(1),
+ /**
+ * <code>FILTER = 2;</code>
+ */
+ FILTER(2),
+ /**
+ * <code>HASH_AGGREGATE = 3;</code>
+ */
+ HASH_AGGREGATE(3),
+ /**
+ * <code>HASH_JOIN = 4;</code>
+ */
+ HASH_JOIN(4),
+ /**
+ * <code>MERGE_JOIN = 5;</code>
+ */
+ MERGE_JOIN(5),
+ /**
+ * <code>HASH_PARTITION_SENDER = 6;</code>
+ */
+ HASH_PARTITION_SENDER(6),
+ /**
+ * <code>LIMIT = 7;</code>
+ */
+ LIMIT(7),
+ /**
+ * <code>MERGING_RECEIVER = 8;</code>
+ */
+ MERGING_RECEIVER(8),
+ /**
+ * <code>ORDERED_PARTITION_SENDER = 9;</code>
+ */
+ ORDERED_PARTITION_SENDER(9),
+ /**
+ * <code>PROJECT = 10;</code>
+ */
+ PROJECT(10),
+ /**
+ * <code>UNORDERED_RECEIVER = 11;</code>
+ */
+ UNORDERED_RECEIVER(11),
+ /**
+ * <code>RANGE_PARTITION_SENDER = 12;</code>
+ */
+ RANGE_PARTITION_SENDER(12),
+ /**
+ * <code>SCREEN = 13;</code>
+ */
+ SCREEN(13),
+ /**
+ * <code>SELECTION_VECTOR_REMOVER = 14;</code>
+ */
+ SELECTION_VECTOR_REMOVER(14),
+ /**
+ * <code>STREAMING_AGGREGATE = 15;</code>
+ */
+ STREAMING_AGGREGATE(15),
+ /**
+ * <code>TOP_N_SORT = 16;</code>
+ */
+ TOP_N_SORT(16),
+ /**
+ * <code>EXTERNAL_SORT = 17;</code>
+ */
+ EXTERNAL_SORT(17),
+ /**
+ * <code>TRACE = 18;</code>
+ */
+ TRACE(18),
+ /**
+ * <code>UNION = 19;</code>
+ */
+ UNION(19),
+ /**
+ * <code>OLD_SORT = 20;</code>
+ */
+ OLD_SORT(20),
+ /**
+ * <code>PARQUET_ROW_GROUP_SCAN = 21;</code>
+ */
+ PARQUET_ROW_GROUP_SCAN(21),
+ /**
+ * <code>HIVE_SUB_SCAN = 22;</code>
+ */
+ HIVE_SUB_SCAN(22),
+ /**
+ * <code>SYSTEM_TABLE_SCAN = 23;</code>
+ */
+ SYSTEM_TABLE_SCAN(23),
+ /**
+ * <code>MOCK_SUB_SCAN = 24;</code>
+ */
+ MOCK_SUB_SCAN(24),
+ /**
+ * <code>PARQUET_WRITER = 25;</code>
+ */
+ PARQUET_WRITER(25),
+ /**
+ * <code>DIRECT_SUB_SCAN = 26;</code>
+ */
+ DIRECT_SUB_SCAN(26),
+ /**
+ * <code>TEXT_WRITER = 27;</code>
+ */
+ TEXT_WRITER(27),
+ /**
+ * <code>TEXT_SUB_SCAN = 28;</code>
+ */
+ TEXT_SUB_SCAN(28),
+ /**
+ * <code>JSON_SUB_SCAN = 29;</code>
+ */
+ JSON_SUB_SCAN(29),
+ /**
+ * <code>INFO_SCHEMA_SUB_SCAN = 30;</code>
+ */
+ INFO_SCHEMA_SUB_SCAN(30),
+ /**
+ * <code>COMPLEX_TO_JSON = 31;</code>
+ */
+ COMPLEX_TO_JSON(31),
+ /**
+ * <code>PRODUCER_CONSUMER = 32;</code>
+ */
+ PRODUCER_CONSUMER(32),
+ /**
+ * <code>HBASE_SUB_SCAN = 33;</code>
+ */
+ HBASE_SUB_SCAN(33),
+ /**
+ * <code>WINDOW = 34;</code>
+ */
+ WINDOW(34),
+ /**
+ * <code>NESTED_LOOP_JOIN = 35;</code>
+ */
+ NESTED_LOOP_JOIN(35),
+ /**
+ * <code>AVRO_SUB_SCAN = 36;</code>
+ */
+ AVRO_SUB_SCAN(36),
+ /**
+ * <code>PCAP_SUB_SCAN = 37;</code>
+ */
+ PCAP_SUB_SCAN(37),
+ /**
+ * <code>KAFKA_SUB_SCAN = 38;</code>
+ */
+ KAFKA_SUB_SCAN(38),
+ /**
+ * <code>KUDU_SUB_SCAN = 39;</code>
+ */
+ KUDU_SUB_SCAN(39),
+ /**
+ * <code>FLATTEN = 40;</code>
+ */
+ FLATTEN(40),
+ /**
+ * <code>LATERAL_JOIN = 41;</code>
+ */
+ LATERAL_JOIN(41),
+ /**
+ * <code>UNNEST = 42;</code>
+ */
+ UNNEST(42),
+ /**
+ * <code>HIVE_DRILL_NATIVE_PARQUET_ROW_GROUP_SCAN = 43;</code>
+ */
+ HIVE_DRILL_NATIVE_PARQUET_ROW_GROUP_SCAN(43),
+ /**
+ * <code>JDBC_SCAN = 44;</code>
+ */
+ JDBC_SCAN(44),
+ /**
+ * <code>REGEX_SUB_SCAN = 45;</code>
+ */
+ REGEX_SUB_SCAN(45),
+ /**
+ * <code>MAPRDB_SUB_SCAN = 46;</code>
+ */
+ MAPRDB_SUB_SCAN(46),
+ /**
+ * <code>MONGO_SUB_SCAN = 47;</code>
+ */
+ MONGO_SUB_SCAN(47),
+ /**
+ * <code>KUDU_WRITER = 48;</code>
+ */
+ KUDU_WRITER(48),
+ /**
+ * <code>OPEN_TSDB_SUB_SCAN = 49;</code>
+ */
+ OPEN_TSDB_SUB_SCAN(49),
+ /**
+ * <code>JSON_WRITER = 50;</code>
+ */
+ JSON_WRITER(50),
+ /**
+ * <code>HTPPD_LOG_SUB_SCAN = 51;</code>
+ */
+ HTPPD_LOG_SUB_SCAN(51),
+ /**
+ * <code>IMAGE_SUB_SCAN = 52;</code>
+ */
+ IMAGE_SUB_SCAN(52),
+ /**
+ * <code>SEQUENCE_SUB_SCAN = 53;</code>
+ */
+ SEQUENCE_SUB_SCAN(53),
+ /**
+ * <code>PARTITION_LIMIT = 54;</code>
+ */
+ PARTITION_LIMIT(54),
+ /**
+ * <code>PCAPNG_SUB_SCAN = 55;</code>
+ */
+ PCAPNG_SUB_SCAN(55),
+ /**
+ * <code>RUNTIME_FILTER = 56;</code>
+ */
+ RUNTIME_FILTER(56),
+ /**
+ * <code>ROWKEY_JOIN = 57;</code>
+ */
+ ROWKEY_JOIN(57),
+ /**
+ * <code>SYSLOG_SUB_SCAN = 58;</code>
+ */
+ SYSLOG_SUB_SCAN(58),
+ /**
+ * <code>STATISTICS_AGGREGATE = 59;</code>
+ */
+ STATISTICS_AGGREGATE(59),
+ /**
+ * <code>UNPIVOT_MAPS = 60;</code>
+ */
+ UNPIVOT_MAPS(60),
+ /**
+ * <code>STATISTICS_MERGE = 61;</code>
+ */
+ STATISTICS_MERGE(61),
+ /**
+ * <code>LTSV_SUB_SCAN = 62;</code>
+ */
+ LTSV_SUB_SCAN(62),
+ /**
+ * <code>HDF5_SUB_SCAN = 63;</code>
+ */
+ HDF5_SUB_SCAN(63),
+ /**
+ * <code>EXCEL_SUB_SCAN = 64;</code>
+ */
+ EXCEL_SUB_SCAN(64),
+ /**
+ * <code>SHP_SUB_SCAN = 65;</code>
+ */
+ SHP_SUB_SCAN(65),
+ /**
+ * <code>METADATA_HANDLER = 66;</code>
+ */
+ METADATA_HANDLER(66),
+ /**
+ * <code>METADATA_CONTROLLER = 67;</code>
+ */
+ METADATA_CONTROLLER(67),
+ /**
+ * <code>DRUID_SUB_SCAN = 68;</code>
+ */
+ DRUID_SUB_SCAN(68),
+ /**
+ * <code>SPSS_SUB_SCAN = 69;</code>
+ */
+ SPSS_SUB_SCAN(69),
+ /**
+ * <code>HTTP_SUB_SCAN = 70;</code>
+ */
+ HTTP_SUB_SCAN(70),
+ /**
+ * <code>XML_SUB_SCAN = 71;</code>
+ */
+ XML_SUB_SCAN(71);
+
+ private final int value;
+
+ CoreOperatorType(int value) {
+ this.value = value;
+ }
+
+ public int getId() {
+ return value;
+ }
+
+ public static CoreOperatorType valueOf(int id) {
+ if (id >= 0 && id <= XML_SUB_SCAN.getId()) {
Review comment:
No, this class shouldn't be modified anymore. It is used for backward compatibility only. I've tried to state that in its Javadoc, but please let me know if it should be extended with some additional details.
If someone submits a format or plugin, they will specify a string that will be used as operator type in the query profile.
##########
File path: exec/java-exec/src/test/java/org/apache/drill/exec/physical/impl/scan/v3/ScanFixture.java
##########
@@ -81,8 +81,8 @@ public ScanFixture build() {
Scan scanConfig = new AbstractSubScan("bob") {
Review comment:
It was added in the scope of from DRILL-7701, so I'm not sure about the intention, perhaps some random name that may be also used in some tests.
Or this name is used intentionally if we also have Alice somewhere in the code 🙂
##########
File path: exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/OperatorWrapper.java
##########
@@ -303,27 +313,27 @@ public void addSummary(TableBuilder tb, Map<String, Long> majorFragmentBusyTally
* @param operatorType
* @return index of spill metric
*/
- private int getSpillCycleMetricIndex(CoreOperatorType operatorType) {
+ private int getSpillCycleMetricIndex(String operatorType) {
// TODO: DRILL-6642, replace null values for ProtocolMessageEnum with UNRECOGNIZED NullValue to avoid null checks
if (operatorType == null) {
Review comment:
Looks like some other Jira ticket number was meant there since DRILL-6642 is resolved.
We can't use the non-null value for operator type (it is string now) until we preserve backward compatibility for reading older profiles. With the changes in this PR, we check whether the operator type string is set in the profile, and if not, we will read the operator id that was used before these changes. Having some default value will enforce us to move additional checks to other places, so I don't think that we should address that ticket until we use both values. Maybe for Drill 2.0 when we will be able to break the compatibility, it may be addressed.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [drill] cgivre merged pull request #2142: DRILL-5405: Add missing operator types without dependency on protobuf enum
Posted by GitBox <gi...@apache.org>.
cgivre merged pull request #2142:
URL: https://github.com/apache/drill/pull/2142
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [drill] cgivre commented on a change in pull request #2142: DRILL-5405: Add missing operator types without dependency on protobuf enum
Posted by GitBox <gi...@apache.org>.
cgivre commented on a change in pull request #2142:
URL: https://github.com/apache/drill/pull/2142#discussion_r554487110
##########
File path: exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/CoreOperatorType.java
##########
@@ -0,0 +1,342 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.drill.exec.server.rest.profile;
+
+
+import java.util.Arrays;
+
+/**
+ * This class is used for backward compatibility when reading older query profiles that
+ * stored operator id instead of its name.
+ * <b>Please do not update this class. It will be removed for Drill 2.0</b>
+ */
+public enum CoreOperatorType {
+
+ /**
+ * <code>SINGLE_SENDER = 0;</code>
+ */
+ SINGLE_SENDER(0),
+ /**
+ * <code>BROADCAST_SENDER = 1;</code>
+ */
+ BROADCAST_SENDER(1),
+ /**
+ * <code>FILTER = 2;</code>
+ */
+ FILTER(2),
+ /**
+ * <code>HASH_AGGREGATE = 3;</code>
+ */
+ HASH_AGGREGATE(3),
+ /**
+ * <code>HASH_JOIN = 4;</code>
+ */
+ HASH_JOIN(4),
+ /**
+ * <code>MERGE_JOIN = 5;</code>
+ */
+ MERGE_JOIN(5),
+ /**
+ * <code>HASH_PARTITION_SENDER = 6;</code>
+ */
+ HASH_PARTITION_SENDER(6),
+ /**
+ * <code>LIMIT = 7;</code>
+ */
+ LIMIT(7),
+ /**
+ * <code>MERGING_RECEIVER = 8;</code>
+ */
+ MERGING_RECEIVER(8),
+ /**
+ * <code>ORDERED_PARTITION_SENDER = 9;</code>
+ */
+ ORDERED_PARTITION_SENDER(9),
+ /**
+ * <code>PROJECT = 10;</code>
+ */
+ PROJECT(10),
+ /**
+ * <code>UNORDERED_RECEIVER = 11;</code>
+ */
+ UNORDERED_RECEIVER(11),
+ /**
+ * <code>RANGE_PARTITION_SENDER = 12;</code>
+ */
+ RANGE_PARTITION_SENDER(12),
+ /**
+ * <code>SCREEN = 13;</code>
+ */
+ SCREEN(13),
+ /**
+ * <code>SELECTION_VECTOR_REMOVER = 14;</code>
+ */
+ SELECTION_VECTOR_REMOVER(14),
+ /**
+ * <code>STREAMING_AGGREGATE = 15;</code>
+ */
+ STREAMING_AGGREGATE(15),
+ /**
+ * <code>TOP_N_SORT = 16;</code>
+ */
+ TOP_N_SORT(16),
+ /**
+ * <code>EXTERNAL_SORT = 17;</code>
+ */
+ EXTERNAL_SORT(17),
+ /**
+ * <code>TRACE = 18;</code>
+ */
+ TRACE(18),
+ /**
+ * <code>UNION = 19;</code>
+ */
+ UNION(19),
+ /**
+ * <code>OLD_SORT = 20;</code>
+ */
+ OLD_SORT(20),
+ /**
+ * <code>PARQUET_ROW_GROUP_SCAN = 21;</code>
+ */
+ PARQUET_ROW_GROUP_SCAN(21),
+ /**
+ * <code>HIVE_SUB_SCAN = 22;</code>
+ */
+ HIVE_SUB_SCAN(22),
+ /**
+ * <code>SYSTEM_TABLE_SCAN = 23;</code>
+ */
+ SYSTEM_TABLE_SCAN(23),
+ /**
+ * <code>MOCK_SUB_SCAN = 24;</code>
+ */
+ MOCK_SUB_SCAN(24),
+ /**
+ * <code>PARQUET_WRITER = 25;</code>
+ */
+ PARQUET_WRITER(25),
+ /**
+ * <code>DIRECT_SUB_SCAN = 26;</code>
+ */
+ DIRECT_SUB_SCAN(26),
+ /**
+ * <code>TEXT_WRITER = 27;</code>
+ */
+ TEXT_WRITER(27),
+ /**
+ * <code>TEXT_SUB_SCAN = 28;</code>
+ */
+ TEXT_SUB_SCAN(28),
+ /**
+ * <code>JSON_SUB_SCAN = 29;</code>
+ */
+ JSON_SUB_SCAN(29),
+ /**
+ * <code>INFO_SCHEMA_SUB_SCAN = 30;</code>
+ */
+ INFO_SCHEMA_SUB_SCAN(30),
+ /**
+ * <code>COMPLEX_TO_JSON = 31;</code>
+ */
+ COMPLEX_TO_JSON(31),
+ /**
+ * <code>PRODUCER_CONSUMER = 32;</code>
+ */
+ PRODUCER_CONSUMER(32),
+ /**
+ * <code>HBASE_SUB_SCAN = 33;</code>
+ */
+ HBASE_SUB_SCAN(33),
+ /**
+ * <code>WINDOW = 34;</code>
+ */
+ WINDOW(34),
+ /**
+ * <code>NESTED_LOOP_JOIN = 35;</code>
+ */
+ NESTED_LOOP_JOIN(35),
+ /**
+ * <code>AVRO_SUB_SCAN = 36;</code>
+ */
+ AVRO_SUB_SCAN(36),
+ /**
+ * <code>PCAP_SUB_SCAN = 37;</code>
+ */
+ PCAP_SUB_SCAN(37),
+ /**
+ * <code>KAFKA_SUB_SCAN = 38;</code>
+ */
+ KAFKA_SUB_SCAN(38),
+ /**
+ * <code>KUDU_SUB_SCAN = 39;</code>
+ */
+ KUDU_SUB_SCAN(39),
+ /**
+ * <code>FLATTEN = 40;</code>
+ */
+ FLATTEN(40),
+ /**
+ * <code>LATERAL_JOIN = 41;</code>
+ */
+ LATERAL_JOIN(41),
+ /**
+ * <code>UNNEST = 42;</code>
+ */
+ UNNEST(42),
+ /**
+ * <code>HIVE_DRILL_NATIVE_PARQUET_ROW_GROUP_SCAN = 43;</code>
+ */
+ HIVE_DRILL_NATIVE_PARQUET_ROW_GROUP_SCAN(43),
+ /**
+ * <code>JDBC_SCAN = 44;</code>
+ */
+ JDBC_SCAN(44),
+ /**
+ * <code>REGEX_SUB_SCAN = 45;</code>
+ */
+ REGEX_SUB_SCAN(45),
+ /**
+ * <code>MAPRDB_SUB_SCAN = 46;</code>
+ */
+ MAPRDB_SUB_SCAN(46),
+ /**
+ * <code>MONGO_SUB_SCAN = 47;</code>
+ */
+ MONGO_SUB_SCAN(47),
+ /**
+ * <code>KUDU_WRITER = 48;</code>
+ */
+ KUDU_WRITER(48),
+ /**
+ * <code>OPEN_TSDB_SUB_SCAN = 49;</code>
+ */
+ OPEN_TSDB_SUB_SCAN(49),
+ /**
+ * <code>JSON_WRITER = 50;</code>
+ */
+ JSON_WRITER(50),
+ /**
+ * <code>HTPPD_LOG_SUB_SCAN = 51;</code>
+ */
+ HTPPD_LOG_SUB_SCAN(51),
+ /**
+ * <code>IMAGE_SUB_SCAN = 52;</code>
+ */
+ IMAGE_SUB_SCAN(52),
+ /**
+ * <code>SEQUENCE_SUB_SCAN = 53;</code>
+ */
+ SEQUENCE_SUB_SCAN(53),
+ /**
+ * <code>PARTITION_LIMIT = 54;</code>
+ */
+ PARTITION_LIMIT(54),
+ /**
+ * <code>PCAPNG_SUB_SCAN = 55;</code>
+ */
+ PCAPNG_SUB_SCAN(55),
+ /**
+ * <code>RUNTIME_FILTER = 56;</code>
+ */
+ RUNTIME_FILTER(56),
+ /**
+ * <code>ROWKEY_JOIN = 57;</code>
+ */
+ ROWKEY_JOIN(57),
+ /**
+ * <code>SYSLOG_SUB_SCAN = 58;</code>
+ */
+ SYSLOG_SUB_SCAN(58),
+ /**
+ * <code>STATISTICS_AGGREGATE = 59;</code>
+ */
+ STATISTICS_AGGREGATE(59),
+ /**
+ * <code>UNPIVOT_MAPS = 60;</code>
+ */
+ UNPIVOT_MAPS(60),
+ /**
+ * <code>STATISTICS_MERGE = 61;</code>
+ */
+ STATISTICS_MERGE(61),
+ /**
+ * <code>LTSV_SUB_SCAN = 62;</code>
+ */
+ LTSV_SUB_SCAN(62),
+ /**
+ * <code>HDF5_SUB_SCAN = 63;</code>
+ */
+ HDF5_SUB_SCAN(63),
+ /**
+ * <code>EXCEL_SUB_SCAN = 64;</code>
+ */
+ EXCEL_SUB_SCAN(64),
+ /**
+ * <code>SHP_SUB_SCAN = 65;</code>
+ */
+ SHP_SUB_SCAN(65),
+ /**
+ * <code>METADATA_HANDLER = 66;</code>
+ */
+ METADATA_HANDLER(66),
+ /**
+ * <code>METADATA_CONTROLLER = 67;</code>
+ */
+ METADATA_CONTROLLER(67),
+ /**
+ * <code>DRUID_SUB_SCAN = 68;</code>
+ */
+ DRUID_SUB_SCAN(68),
+ /**
+ * <code>SPSS_SUB_SCAN = 69;</code>
+ */
+ SPSS_SUB_SCAN(69),
+ /**
+ * <code>HTTP_SUB_SCAN = 70;</code>
+ */
+ HTTP_SUB_SCAN(70),
+ /**
+ * <code>XML_SUB_SCAN = 71;</code>
+ */
+ XML_SUB_SCAN(71);
+
+ private final int value;
+
+ CoreOperatorType(int value) {
+ this.value = value;
+ }
+
+ public int getId() {
+ return value;
+ }
+
+ public static CoreOperatorType valueOf(int id) {
+ if (id >= 0 && id <= XML_SUB_SCAN.getId()) {
Review comment:
@vvysotskyi
Thanks for the PR. If someone submits a new format or storage plugin, do they have to modify this file?
##########
File path: exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/OperatorWrapper.java
##########
@@ -303,27 +313,27 @@ public void addSummary(TableBuilder tb, Map<String, Long> majorFragmentBusyTally
* @param operatorType
* @return index of spill metric
*/
- private int getSpillCycleMetricIndex(CoreOperatorType operatorType) {
+ private int getSpillCycleMetricIndex(String operatorType) {
// TODO: DRILL-6642, replace null values for ProtocolMessageEnum with UNRECOGNIZED NullValue to avoid null checks
if (operatorType == null) {
Review comment:
Do you think it would be worth addressing DRILL-6642 in this PR?
##########
File path: exec/java-exec/src/test/java/org/apache/drill/exec/physical/impl/scan/v3/ScanFixture.java
##########
@@ -81,8 +81,8 @@ public ScanFixture build() {
Scan scanConfig = new AbstractSubScan("bob") {
Review comment:
Bob?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org