You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2016/11/22 23:15:56 UTC
hive git commit: HIVE-15247 : Pass the purge option for drop table to
storage handlers (Ashutosh Chauhan via Jesus Camacho Rodriguez)
Repository: hive
Updated Branches:
refs/heads/master acc847a86 -> f9c6d1858
HIVE-15247 : Pass the purge option for drop table to storage handlers (Ashutosh Chauhan via Jesus Camacho Rodriguez)
Signed-off-by: Ashutosh Chauhan <ha...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/f9c6d185
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/f9c6d185
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/f9c6d185
Branch: refs/heads/master
Commit: f9c6d18580ad52c0e628bdcb2b41a0b4c6bd2951
Parents: acc847a
Author: Ashutosh Chauhan <ha...@apache.org>
Authored: Fri Nov 18 15:37:40 2016 -0800
Committer: Ashutosh Chauhan <ha...@apache.org>
Committed: Tue Nov 22 15:15:30 2016 -0800
----------------------------------------------------------------------
.../org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/f9c6d185/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
----------------------------------------------------------------------
diff --git a/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java b/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
index 2f59054..823827d 100644
--- a/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
+++ b/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
@@ -319,6 +319,7 @@ public class HiveMetaStoreClient implements IMetaStoreClient {
alter_table_with_environmentContext(dbname, tbl_name, new_tbl, null);
}
+ @Override
public void alter_table_with_environmentContext(String dbname, String tbl_name, Table new_tbl,
EnvironmentContext envContext) throws InvalidOperationException, MetaException, TException {
client.alter_table_with_environment_context(dbname, tbl_name, new_tbl, envContext);
@@ -490,6 +491,7 @@ public class HiveMetaStoreClient implements IMetaStoreClient {
}
}
+ @Override
public String getTokenStrForm() throws IOException {
return tokenStrForm;
}
@@ -1037,7 +1039,7 @@ public class HiveMetaStoreClient implements IMetaStoreClient {
try {
drop_table_with_environment_context(dbname, name, deleteData, envContext);
if (hook != null) {
- hook.commitDropTable(tbl, deleteData);
+ hook.commitDropTable(tbl, deleteData || (envContext != null && "TRUE".equals(envContext.getProperties().get("ifPurge"))));
}
success=true;
} catch (NoSuchObjectException e) {
@@ -1439,6 +1441,7 @@ public class HiveMetaStoreClient implements IMetaStoreClient {
* @throws NoSuchObjectException
* @throws TException
*/
+ @Override
public int getNumPartitionsByFilter(String db_name, String tbl_name,
String filter) throws MetaException,
NoSuchObjectException, TException {
@@ -2163,7 +2166,7 @@ public class HiveMetaStoreClient implements IMetaStoreClient {
public void addDynamicPartitions(long txnId, String dbName, String tableName,
List<String> partNames) throws TException {
client.add_dynamic_partitions(new AddDynamicPartitions(txnId, dbName, tableName, partNames));
- }
+ }
@Override
public void addDynamicPartitions(long txnId, String dbName, String tableName,
List<String> partNames, DataOperationType operationType) throws TException {