You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ek...@apache.org on 2018/07/23 18:42:07 UTC
hive git commit: ADDENDUM: HIVE-17683: Add explain locks
command (Igor Kryvenko via Eugene Koifman)
Repository: hive
Updated Branches:
refs/heads/master 90d19acd2 -> 5e7aa0986
ADDENDUM: HIVE-17683: Add explain locks <sql> command (Igor Kryvenko via Eugene Koifman)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/5e7aa098
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/5e7aa098
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/5e7aa098
Branch: refs/heads/master
Commit: 5e7aa0986b29edb3325378a83bf02a26e760f857
Parents: 90d19ac
Author: Igor Kryvenko <kr...@gmail.com>
Authored: Mon Jul 23 11:42:01 2018 -0700
Committer: Eugene Koifman <ek...@apache.org>
Committed: Mon Jul 23 11:42:01 2018 -0700
----------------------------------------------------------------------
.../hadoop/hive/ql/plan/ExplainLockDesc.java | 116 +++++++++++++++++++
1 file changed, 116 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/5e7aa098/ql/src/java/org/apache/hadoop/hive/ql/plan/ExplainLockDesc.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/plan/ExplainLockDesc.java b/ql/src/java/org/apache/hadoop/hive/ql/plan/ExplainLockDesc.java
new file mode 100644
index 0000000..1e7fb2e
--- /dev/null
+++ b/ql/src/java/org/apache/hadoop/hive/ql/plan/ExplainLockDesc.java
@@ -0,0 +1,116 @@
+/*
+ * 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.hadoop.hive.ql.plan;
+
+import org.apache.commons.lang.StringUtils;
+import org.apache.hadoop.hive.metastore.api.LockComponent;
+import org.apache.hadoop.hive.metastore.api.LockType;
+
+import java.util.ArrayList;
+
+/**
+ * ExplainLockDesc represents lock entity in query plan.
+ */
+public class ExplainLockDesc {
+ private String catalogName;
+ private String dbName;
+ private String tableName;
+ private String partitionName;
+ private LockType lockType;
+
+ public ExplainLockDesc() {
+ }
+
+ public ExplainLockDesc(LockComponent component) {
+ this.dbName = component.getDbname();
+ if (null != component.getTablename()) {
+ this.tableName = component.getTablename();
+ }
+ if (null != component.getPartitionname()) {
+ this.partitionName = component.getPartitionname();
+ }
+ this.lockType = component.getType();
+ }
+
+ public String getCatalogName() {
+ return catalogName;
+ }
+
+ public ExplainLockDesc setCatalogName(String catalogName) {
+ this.catalogName = catalogName;
+ return this;
+ }
+
+ public String getDbName() {
+ return dbName;
+ }
+
+ public ExplainLockDesc setDbName(String dbName) {
+ this.dbName = dbName;
+ return this;
+ }
+
+ public String getTableName() {
+ return tableName;
+ }
+
+ public ExplainLockDesc setTableName(String tableName) {
+ this.tableName = tableName;
+ return this;
+ }
+
+ public String getPartitionName() {
+ return partitionName;
+ }
+
+ public ExplainLockDesc setPartitionName(String partitionName) {
+ this.partitionName = partitionName;
+ return this;
+ }
+
+ public LockType getLockType() {
+ return lockType;
+ }
+
+ public ExplainLockDesc setLockType(LockType lockType) {
+ this.lockType = lockType;
+ return this;
+ }
+
+ public String getFullName() {
+ ArrayList<String> list = new ArrayList<String>();
+ if (null != catalogName) {
+ list.add(catalogName);
+ }
+ if (null != dbName) {
+ list.add(dbName);
+ }
+ if (null != tableName) {
+ list.add(tableName);
+ }
+ if (null != partitionName) {
+ list.add(partitionName);
+ }
+ return StringUtils.join(list, '.');
+ }
+
+ @Override public String toString() {
+ return getFullName() + " -> " + this.getLockType();
+ }
+}