remove spaces
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/c451343d Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/c451343d Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/c451343d Branch: refs/heads/omid Commit: c451343d9df44e88638487a2c509ae9b0db1664a Parents: bcffce9 Author: Ohad Shacham <[email protected]> Authored: Sun Feb 19 10:04:38 2017 +0200 Committer: Ohad Shacham <[email protected]> Committed: Sun Feb 19 10:04:38 2017 +0200 ---------------------------------------------------------------------- .../phoenix/transaction/TephraTransactionContext.java | 12 ++++++------ .../phoenix/transaction/TephraTransactionTable.java | 4 ++-- 2 files changed, 8 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/c451343d/phoenix-core/src/main/java/org/apache/phoenix/transaction/TephraTransactionContext.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/transaction/TephraTransactionContext.java b/phoenix-core/src/main/java/org/apache/phoenix/transaction/TephraTransactionContext.java index 9c7337d..8fc5e0f 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/transaction/TephraTransactionContext.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/transaction/TephraTransactionContext.java @@ -78,7 +78,7 @@ public class TephraTransactionContext implements PhoenixTransactionContext { txContext.finish(); } catch (TransactionFailureException e) { this.e = e; - if (e instanceof TransactionConflictException) { + if (e instanceof TransactionConflictException) { throw new SQLExceptionInfo.Builder(SQLExceptionCode.TRANSACTION_CONFLICT_EXCEPTION) .setMessage(e.getMessage()) .setRootCause(e) @@ -124,7 +124,7 @@ public class TephraTransactionContext implements PhoenixTransactionContext { throw new SQLException(e); } } - + if (txContext == null) { tx.setVisibility(VisibilityLevel.SNAPSHOT_EXCLUDE_CURRENT); } @@ -211,7 +211,7 @@ public class TephraTransactionContext implements PhoenixTransactionContext { public long getTransactionId() { if (this.txContext != null) { return txContext.getCurrentTransaction().getTransactionId(); - } + } if (tx != null) { return tx.getTransactionId(); @@ -224,7 +224,7 @@ public class TephraTransactionContext implements PhoenixTransactionContext { public long getReadPointer() { if (this.txContext != null) { return txContext.getCurrentTransaction().getReadPointer(); - } + } if (tx != null) { return tx.getReadPointer(); @@ -261,7 +261,7 @@ public class TephraTransactionContext implements PhoenixTransactionContext { public long getWritePointer() { if (this.txContext != null) { return txContext.getCurrentTransaction().getWritePointer(); - } + } if (tx != null) { return tx.getWritePointer(); @@ -274,7 +274,7 @@ public class TephraTransactionContext implements PhoenixTransactionContext { public VisibilityLevel getVisibilityLevel() { if (this.txContext != null) { return txContext.getCurrentTransaction().getVisibilityLevel(); - } + } if (tx != null) { return tx.getVisibilityLevel(); http://git-wip-us.apache.org/repos/asf/phoenix/blob/c451343d/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 c5ba33f..0823f89 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 @@ -17,9 +17,9 @@ import org.apache.tephra.hbase.TransactionAwareHTable; public class TephraTransactionTable implements PhoenixTransactionalTable { private TransactionAwareHTable transactionAwareHTable; - + private TephraTransactionContext tephraTransactionContext; - + public TephraTransactionTable(PhoenixTransactionContext ctx, HTableInterface hTable) { assert(ctx instanceof TephraTransactionContext);
