diff --git a/pom.xml b/pom.xml
index ebeba16..3fa30cd 100644
--- a/pom.xml
+++ b/pom.xml
@@ -9,7 +9,7 @@
trino-jtopen
- 464
+ 465
trino-plugin
Trino - JTOpen Connector
@@ -28,7 +28,7 @@
285
2.3
1.44.1
- 2.9.0
+ 2.10.0
${dep.airlift.version}
33.3.1-jre
7.0.0
diff --git a/src/main/java/io/trino/plugin/jtopen/JTOpenClient.java b/src/main/java/io/trino/plugin/jtopen/JTOpenClient.java
index b77386a..b402f4d 100644
--- a/src/main/java/io/trino/plugin/jtopen/JTOpenClient.java
+++ b/src/main/java/io/trino/plugin/jtopen/JTOpenClient.java
@@ -27,6 +27,7 @@
import io.trino.plugin.jdbc.JdbcColumnHandle;
import io.trino.plugin.jdbc.JdbcExpression;
import io.trino.plugin.jdbc.JdbcJoinCondition;
+import io.trino.plugin.jdbc.JdbcMetadata;
import io.trino.plugin.jdbc.JdbcOutputTableHandle;
import io.trino.plugin.jdbc.JdbcProcedureHandle;
import io.trino.plugin.jdbc.JdbcProcedureHandle.ProcedureQuery;
@@ -698,7 +699,7 @@ private TableStatistics readTableStatistics(ConnectorSession session, JdbcTableH
Map> allColumnStatistics = statisticsDao.getAllColumnStatistics(table);
- for (JdbcColumnHandle column : this.getColumns(session, table)) {
+ for (JdbcColumnHandle column : JdbcMetadata.getColumns(session, this, table)) {
String columnName = column.getColumnName();
Map columnStatistics = allColumnStatistics.getOrDefault(columnName, new HashMap<>());
diff --git a/src/main/java/io/trino/plugin/jtopen/JTOpenPlugin.java b/src/main/java/io/trino/plugin/jtopen/JTOpenPlugin.java
index 260dde7..6d60991 100644
--- a/src/main/java/io/trino/plugin/jtopen/JTOpenPlugin.java
+++ b/src/main/java/io/trino/plugin/jtopen/JTOpenPlugin.java
@@ -20,6 +20,6 @@ public class JTOpenPlugin
{
public JTOpenPlugin()
{
- super("jtopen", new JTOpenClientModule());
+ super("jtopen", JTOpenClientModule::new);
}
}