augment transaction table to the new hbase functions
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/46e4b1a2 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/46e4b1a2 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/46e4b1a2 Branch: refs/heads/omid Commit: 46e4b1a2ab374d47bddf7566e1dc7e0a17d54118 Parents: f6f8dda Author: Ohad Shacham <[email protected]> Authored: Mon May 8 15:33:26 2017 +0300 Committer: Ohad Shacham <[email protected]> Committed: Mon May 8 15:33:26 2017 +0300 ---------------------------------------------------------------------- .../transaction/OmidTransactionTable.java | 24 ++++++++++++++++++++ .../transaction/TephraTransactionTable.java | 19 ++++++++++++++++ 2 files changed, 43 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/46e4b1a2/phoenix-core/src/main/java/org/apache/phoenix/transaction/OmidTransactionTable.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/transaction/OmidTransactionTable.java b/phoenix-core/src/main/java/org/apache/phoenix/transaction/OmidTransactionTable.java index d2cd020..d2fd4c5 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/transaction/OmidTransactionTable.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/transaction/OmidTransactionTable.java @@ -320,4 +320,28 @@ public class OmidTransactionTable implements PhoenixTransactionalTable { return false; } + @Override + public int getOperationTimeout() { + // TODO Auto-generated method stub + return 0; + } + + @Override + public int getRpcTimeout() { + // TODO Auto-generated method stub + return 0; + } + + @Override + public void setOperationTimeout(int arg0) { + // TODO Auto-generated method stub + + } + + @Override + public void setRpcTimeout(int arg0) { + // TODO Auto-generated method stub + + } + } http://git-wip-us.apache.org/repos/asf/phoenix/blob/46e4b1a2/phoenix-core/src/main/java/org/apache/phoenix/transaction/TephraTransactionTable.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/transaction/TephraTransactionTable.java b/phoenix-core/src/main/java/org/apache/phoenix/transaction/TephraTransactionTable.java index 49753f0..8ee784e 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/transaction/TephraTransactionTable.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/transaction/TephraTransactionTable.java @@ -311,4 +311,23 @@ public class TephraTransactionTable implements PhoenixTransactionalTable { return transactionAwareHTable.checkAndMutate(row, family, qualifier, compareOp, value, mutation); } + @Override + public void setOperationTimeout(int i) { +// transactionAwareHTable.setOperationTimeout(i); + } + + @Override + public int getOperationTimeout() { + return 0; //transactionAwareHTable.getOperationTimeout(); + } + + @Override + public void setRpcTimeout(int i) { +// transactionAwareHTable.setRpcTimeout(i); + } + + @Override + public int getRpcTimeout() { + return 0; //transactionAwareHTable.getRpcTimeout(); + } }
