Update Trino version to 359 update SPI methods

tuor713 · Aug 26, 2021 · 844c68b · 844c68b
1 parent 9cf0fde
commit 844c68b
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 8 deletions.
diff --git a/pom.xml b/pom.xml
@@ -6,11 +6,13 @@
 
     <groupId>org.uwh</groupId>
     <artifactId>trino-kdb-plugin</artifactId>
-    <version>0.0.6</version>
+    <version>0.0.7-${trino.version}</version>
 
     <properties>
         <maven.compiler.source>11</maven.compiler.source>
         <maven.compiler.target>11</maven.compiler.target>
+        <trino.version>359</trino.version>
+        <airlift.version>207</airlift.version>
     </properties>
 
     <dependencies>
@@ -23,21 +25,21 @@
         <dependency>
             <groupId>io.trino</groupId>
             <artifactId>trino-spi</artifactId>
-            <version>357</version>
+            <version>${trino.version}</version>
             <scope>provided</scope>
         </dependency>
 
         <!-- Used for additional Types not included in trino-spi -->
         <dependency>
             <groupId>io.trino</groupId>
             <artifactId>trino-main</artifactId>
-            <version>357</version>
+            <version>${trino.version}</version>
         </dependency>
 
         <dependency>
             <groupId>io.airlift</groupId>
             <artifactId>log</artifactId>
-            <version>205</version>
+            <version>${airlift.version}</version>
         </dependency>
 
         <dependency>
@@ -56,7 +58,7 @@
         <dependency>
             <groupId>io.trino</groupId>
             <artifactId>trino-testing</artifactId>
-            <version>357</version>
+            <version>${trino.version}</version>
             <scope>test</scope>
         </dependency>
     </dependencies>

diff --git a/src/main/java/org/uwh/trino/kdb/KDBMetadata.java b/src/main/java/org/uwh/trino/kdb/KDBMetadata.java
@@ -199,7 +199,8 @@ public Optional<LimitApplicationResult<ConnectorTableHandle>> applyLimit(Connect
         return Optional.of(new LimitApplicationResult<>(
                 new KDBTableHandle(khandle.getSchemaName(), khandle.getTableName(), khandle.getConstraint(), OptionalLong.of(limit), khandle.isPartitioned(), khandle.getPartitionColumn(), khandle.getPartitions()),
                 // for partitioned table since partitions are limited individually the limit is not guaranteed
-                !khandle.isPartitioned()
+                !khandle.isPartitioned(),
+                false
         ));
     }
 
@@ -214,7 +215,7 @@ public Optional<ConstraintApplicationResult<ConnectorTableHandle>> applyFilter(C
 
         KDBTableHandle newHandle = new KDBTableHandle(khandle.getSchemaName(), khandle.getTableName(), next, khandle.getLimit(), khandle.isPartitioned(), khandle.getPartitionColumn(), khandle.getPartitions());
 
-        return Optional.of(new ConstraintApplicationResult<>(newHandle, TupleDomain.all()));
+        return Optional.of(new ConstraintApplicationResult<>(newHandle, TupleDomain.all(), false));
     }
 
     private static final Map<String,String> supported_functions = ImmutableMap.<String,String>builder()
@@ -325,7 +326,8 @@ public Optional<AggregationApplicationResult<ConnectorTableHandle>> applyAggrega
                             new KDBColumnHandle(var.getName(), var.getType(), KDBType.fromTrinoType(var.getType()), Optional.empty(), false),
                             var.getType());
                 }).collect(Collectors.toList()),
-                Map.of()
+                Map.of(),
+                false
         );
 
         return Optional.of(result);