Repository: phoenix Updated Branches: refs/heads/omid2 8a52aa40b -> 0e54b313e
PHOENIX-4986 Support low latency version of Omid Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/0e54b313 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/0e54b313 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/0e54b313 Branch: refs/heads/omid2 Commit: 0e54b313e7fca2e7a4142cf0aaef4c6750fa7548 Parents: 8a52aa4 Author: James Taylor <[email protected]> Authored: Fri Oct 19 08:09:34 2018 -0700 Committer: James Taylor <[email protected]> Committed: Fri Oct 19 08:09:34 2018 -0700 ---------------------------------------------------------------------- .../apache/phoenix/transaction/OmidTransactionContext.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/0e54b313/phoenix-core/src/main/java/org/apache/phoenix/transaction/OmidTransactionContext.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/transaction/OmidTransactionContext.java b/phoenix-core/src/main/java/org/apache/phoenix/transaction/OmidTransactionContext.java index f36ef6e..6093f88 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/transaction/OmidTransactionContext.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/transaction/OmidTransactionContext.java @@ -70,7 +70,8 @@ public class OmidTransactionContext implements PhoenixTransactionContext { this(); if (txnBytes != null && txnBytes.length > 0) { TSOProto.Transaction transaction = TSOProto.Transaction.parseFrom(txnBytes); - tx = new HBaseTransaction(transaction.getTimestamp(), transaction.getEpoch(), new HashSet<HBaseCellId>(), new HashSet<HBaseCellId>(), null); + tx = new HBaseTransaction(transaction.getTimestamp(), transaction.getEpoch(), new HashSet<HBaseCellId>(), + new HashSet<HBaseCellId>(), null, tm.isLowLatency()); } else { tx = null; } @@ -85,7 +86,9 @@ public class OmidTransactionContext implements PhoenixTransactionContext { if (subTask) { if (omidTransactionContext.isTransactionRunning()) { Transaction transaction = omidTransactionContext.getTransaction(); - this.tx = new HBaseTransaction(transaction.getTransactionId(), transaction.getEpoch(), new HashSet<HBaseCellId>(), new HashSet<HBaseCellId>(), this.tm, transaction.getReadTimestamp(), transaction.getWriteTimestamp()); + this.tx = new HBaseTransaction(transaction.getTransactionId(), transaction.getEpoch(), + new HashSet<HBaseCellId>(), new HashSet<HBaseCellId>(), this.tm, + transaction.getReadTimestamp(), transaction.getWriteTimestamp(), tm.isLowLatency()); } else { this.tx = null; }
