Update to Trino 370

tuor713 · Feb 14, 2022 · 45c83c1 · 45c83c1
1 parent e71a54f
commit 45c83c1
Show file tree

Hide file tree

Showing 6 changed files with 6 additions and 21 deletions.
diff --git a/pom.xml b/pom.xml
@@ -6,13 +6,13 @@
 
     <groupId>org.uwh</groupId>
     <artifactId>trino-kdb-plugin</artifactId>
-    <version>0.0.9-${trino.version}-SNAPSHOT</version>
+    <version>0.0.9-${trino.version}</version>
 
     <properties>
         <maven.compiler.source>11</maven.compiler.source>
         <maven.compiler.target>11</maven.compiler.target>
-        <trino.version>365</trino.version>
-        <airlift.version>209</airlift.version>
+        <trino.version>370</trino.version>
+        <airlift.version>214</airlift.version>
     </properties>
 
     <dependencies>
@@ -45,7 +45,7 @@
         <dependency>
             <groupId>com.google.guava</groupId>
             <artifactId>guava</artifactId>
-            <version>30.1.1-jre</version>
+            <version>31.0.1-jre</version>
         </dependency>
 
         <dependency>

diff --git a/src/main/java/org/uwh/trino/kdb/KDBConnector.java b/src/main/java/org/uwh/trino/kdb/KDBConnector.java
@@ -40,11 +40,6 @@ public ConnectorMetadata getMetadata(ConnectorTransactionHandle transactionHandl
         return metadata;
     }
 
-    @Override
-    public Optional<ConnectorHandleResolver> getHandleResolver() {
-        return Optional.of(new KDBHandleResolver());
-    }
-
     @Override
     public ConnectorSplitManager getSplitManager() {
         return new KDBSplitManager();

diff --git a/src/main/java/org/uwh/trino/kdb/KDBConnectorFactory.java b/src/main/java/org/uwh/trino/kdb/KDBConnectorFactory.java
@@ -13,11 +13,6 @@ public String getName() {
         return "kdb";
     }
 
-    @Override
-    public ConnectorHandleResolver getHandleResolver() {
-        return new KDBHandleResolver();
-    }
-
     @Override
     public Connector create(String catalogName, Map<String, String> config, ConnectorContext context) {
         Config cfg = new Config(config);

diff --git a/src/main/java/org/uwh/trino/kdb/KDBMetadata.java b/src/main/java/org/uwh/trino/kdb/KDBMetadata.java
@@ -176,11 +176,6 @@ public ConnectorTableMetadata getTableMetadata(ConnectorSession session, Connect
         }
     }
 
-    @Override
-    public boolean usesLegacyTableLayouts() {
-        return false;
-    }
-
     @Override
     public ConnectorTableProperties getTableProperties(ConnectorSession session, ConnectorTableHandle table) {
         return new ConnectorTableProperties();

diff --git a/src/main/java/org/uwh/trino/kdb/KDBPageSource.java b/src/main/java/org/uwh/trino/kdb/KDBPageSource.java
@@ -67,7 +67,7 @@ public Page getNextPage() {
     }
 
     @Override
-    public long getSystemMemoryUsage() {
+    public long getMemoryUsage() {
         return 0;
     }
 

diff --git a/src/test/java/org/uwh/trino/kdb/TestKDBPlugin.java b/src/test/java/org/uwh/trino/kdb/TestKDBPlugin.java
@@ -1,11 +1,11 @@
 package org.uwh.trino.kdb;
 
+import com.google.common.collect.ImmutableMap;
 import io.trino.Session;
 import io.trino.metadata.SessionPropertyManager;
 import io.trino.spi.type.ArrayType;
 import io.trino.spi.type.BigintType;
 import io.trino.testing.*;
-import org.testcontainers.shaded.com.google.common.collect.ImmutableMap;
 import org.testng.annotations.BeforeClass;
 import org.testng.annotations.Test;