This is an automated email from the ASF dual-hosted git repository.
stoty pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/phoenix.git
The following commit(s) were added to refs/heads/master by this push:
new 4ba8a33a03 PHOENIX-7188 Remove Omid TTable.getTableDescriptor() calls
4ba8a33a03 is described below
commit 4ba8a33a03429af0214a2cbd1e1abf81aa4604ba
Author: Istvan Toth <st...@apache.org>
AuthorDate: Thu Feb 8 08:30:10 2024 +0100
PHOENIX-7188 Remove Omid TTable.getTableDescriptor() calls
---
.../org/apache/phoenix/transaction/OmidTransactionTable.java | 7 ++-----
.../phoenix/compat/hbase/CompatOmidTransactionTable.java | 12 ++++++++++++
.../phoenix/compat/hbase/CompatOmidTransactionTable.java | 12 ++++++++++++
.../phoenix/compat/hbase/CompatOmidTransactionTable.java | 12 ++++++++++++
.../phoenix/compat/hbase/CompatOmidTransactionTable.java | 12 ++++++++++++
5 files changed, 50 insertions(+), 5 deletions(-)
diff --git
a/phoenix-core-client/src/main/java/org/apache/phoenix/transaction/OmidTransactionTable.java
b/phoenix-core-client/src/main/java/org/apache/phoenix/transaction/OmidTransactionTable.java
index 7d4d7bdf77..0e9ddb41a5 100644
---
a/phoenix-core-client/src/main/java/org/apache/phoenix/transaction/OmidTransactionTable.java
+++
b/phoenix-core-client/src/main/java/org/apache/phoenix/transaction/OmidTransactionTable.java
@@ -66,6 +66,7 @@ public class OmidTransactionTable extends
CompatOmidTransactionTable implements
private final boolean addShadowCells;
public OmidTransactionTable() throws SQLException {
+ super(null);
this.tTable = null;
this.tx = null;
this.addShadowCells = false;
@@ -80,6 +81,7 @@ public class OmidTransactionTable extends
CompatOmidTransactionTable implements
}
public OmidTransactionTable(PhoenixTransactionContext ctx, Table hTable,
boolean isConflictFree, boolean addShadowCells) throws SQLException {
+ super(hTable);
assert(ctx instanceof OmidTransactionContext);
OmidTransactionContext omidTransactionContext =
(OmidTransactionContext) ctx;
@@ -122,11 +124,6 @@ public class OmidTransactionTable extends
CompatOmidTransactionTable implements
return tTable.getConfiguration();
}
- @Override
- public HTableDescriptor getTableDescriptor() throws IOException {
- return tTable.getTableDescriptor();
- }
-
@Override
public boolean exists(Get get) throws IOException {
return tTable.exists(tx, get);
diff --git
a/phoenix-hbase-compat-2.4.0/src/main/java/org/apache/phoenix/compat/hbase/CompatOmidTransactionTable.java
b/phoenix-hbase-compat-2.4.0/src/main/java/org/apache/phoenix/compat/hbase/CompatOmidTransactionTable.java
index bddc7a57ec..b2997a86a1 100644
---
a/phoenix-hbase-compat-2.4.0/src/main/java/org/apache/phoenix/compat/hbase/CompatOmidTransactionTable.java
+++
b/phoenix-hbase-compat-2.4.0/src/main/java/org/apache/phoenix/compat/hbase/CompatOmidTransactionTable.java
@@ -19,12 +19,24 @@ package org.apache.phoenix.compat.hbase;
import java.io.IOException;
+import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.RowMutations;
import org.apache.hadoop.hbase.client.Table;
public abstract class CompatOmidTransactionTable implements Table {
+ protected Table hTable;
+
+ public CompatOmidTransactionTable(Table hTable) {
+ this.hTable = hTable;
+ }
+
+ @Override
+ public HTableDescriptor getTableDescriptor() throws IOException {
+ return hTable.getTableDescriptor();
+ }
+
@Override
public Result mutateRow(RowMutations rm) throws IOException {
throw new UnsupportedOperationException();
diff --git
a/phoenix-hbase-compat-2.4.1/src/main/java/org/apache/phoenix/compat/hbase/CompatOmidTransactionTable.java
b/phoenix-hbase-compat-2.4.1/src/main/java/org/apache/phoenix/compat/hbase/CompatOmidTransactionTable.java
index bddc7a57ec..b2997a86a1 100644
---
a/phoenix-hbase-compat-2.4.1/src/main/java/org/apache/phoenix/compat/hbase/CompatOmidTransactionTable.java
+++
b/phoenix-hbase-compat-2.4.1/src/main/java/org/apache/phoenix/compat/hbase/CompatOmidTransactionTable.java
@@ -19,12 +19,24 @@ package org.apache.phoenix.compat.hbase;
import java.io.IOException;
+import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.RowMutations;
import org.apache.hadoop.hbase.client.Table;
public abstract class CompatOmidTransactionTable implements Table {
+ protected Table hTable;
+
+ public CompatOmidTransactionTable(Table hTable) {
+ this.hTable = hTable;
+ }
+
+ @Override
+ public HTableDescriptor getTableDescriptor() throws IOException {
+ return hTable.getTableDescriptor();
+ }
+
@Override
public Result mutateRow(RowMutations rm) throws IOException {
throw new UnsupportedOperationException();
diff --git
a/phoenix-hbase-compat-2.5.0/src/main/java/org/apache/phoenix/compat/hbase/CompatOmidTransactionTable.java
b/phoenix-hbase-compat-2.5.0/src/main/java/org/apache/phoenix/compat/hbase/CompatOmidTransactionTable.java
index ae7992fb34..6531a49875 100644
---
a/phoenix-hbase-compat-2.5.0/src/main/java/org/apache/phoenix/compat/hbase/CompatOmidTransactionTable.java
+++
b/phoenix-hbase-compat-2.5.0/src/main/java/org/apache/phoenix/compat/hbase/CompatOmidTransactionTable.java
@@ -19,6 +19,7 @@ package org.apache.phoenix.compat.hbase;
import java.io.IOException;
+import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.client.RegionLocator;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.RowMutations;
@@ -26,6 +27,17 @@ import org.apache.hadoop.hbase.client.Table;
public abstract class CompatOmidTransactionTable implements Table {
+ protected Table hTable;
+
+ public CompatOmidTransactionTable(Table hTable) {
+ this.hTable = hTable;
+ }
+
+ @Override
+ public HTableDescriptor getTableDescriptor() throws IOException {
+ return hTable.getTableDescriptor();
+ }
+
@Override
public RegionLocator getRegionLocator() throws IOException {
throw new UnsupportedOperationException();
diff --git
a/phoenix-hbase-compat-2.5.4/src/main/java/org/apache/phoenix/compat/hbase/CompatOmidTransactionTable.java
b/phoenix-hbase-compat-2.5.4/src/main/java/org/apache/phoenix/compat/hbase/CompatOmidTransactionTable.java
index ae7992fb34..6531a49875 100644
---
a/phoenix-hbase-compat-2.5.4/src/main/java/org/apache/phoenix/compat/hbase/CompatOmidTransactionTable.java
+++
b/phoenix-hbase-compat-2.5.4/src/main/java/org/apache/phoenix/compat/hbase/CompatOmidTransactionTable.java
@@ -19,6 +19,7 @@ package org.apache.phoenix.compat.hbase;
import java.io.IOException;
+import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.client.RegionLocator;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.RowMutations;
@@ -26,6 +27,17 @@ import org.apache.hadoop.hbase.client.Table;
public abstract class CompatOmidTransactionTable implements Table {
+ protected Table hTable;
+
+ public CompatOmidTransactionTable(Table hTable) {
+ this.hTable = hTable;
+ }
+
+ @Override
+ public HTableDescriptor getTableDescriptor() throws IOException {
+ return hTable.getTableDescriptor();
+ }
+
@Override
public RegionLocator getRegionLocator() throws IOException {
throw new UnsupportedOperationException();
