You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2018/07/03 17:47:46 UTC
[18/46] hive git commit: HIVE-19267: Replicate ACID/MM tables write
operations (Mahesh Kumar Behera, reviewed by Sankar Hariappan)
http://git-wip-us.apache.org/repos/asf/hive/blob/f519db7e/standalone-metastore/src/test/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClientPreCatalog.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/test/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClientPreCatalog.java b/standalone-metastore/src/test/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClientPreCatalog.java
index 2d87a2f..53c4d24 100644
--- a/standalone-metastore/src/test/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClientPreCatalog.java
+++ b/standalone-metastore/src/test/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClientPreCatalog.java
@@ -2231,10 +2231,8 @@ public class HiveMetaStoreClientPreCatalog implements IMetaStoreClient, AutoClos
}
@Override
- public void replCommitTxn(long srcTxnId, String replPolicy)
+ public void replCommitTxn(CommitTxnRequest rqst)
throws NoSuchTxnException, TxnAbortedException, TException {
- CommitTxnRequest rqst = new CommitTxnRequest(srcTxnId);
- rqst.setReplPolicy(replPolicy);
client.commit_txn(rqst);
}
@@ -2475,6 +2473,12 @@ public class HiveMetaStoreClientPreCatalog implements IMetaStoreClient, AutoClos
return client.fire_listener_event(rqst);
}
+ @InterfaceAudience.LimitedPrivate({"Apache Hive, HCatalog"})
+ @Override
+ public void addWriteNotificationLog(WriteNotificationLogRequest rqst) throws TException {
+ client.add_write_notification_log(rqst);
+ }
+
/**
* Creates a synchronized wrapper for any {@link IMetaStoreClient}.
* This may be used by multi-threaded applications until we have