deps: Upgraded to trino 393

Author: Julien Ruaux

.github/workflows/early-access.yml

@@ -62,7 +62,7 @@ jobs:
           JRELEASER_GPG_PASSPHRASE: ${{ secrets.GPG_PASSPHRASE }}
           JRELEASER_GPG_PUBLIC_KEY: ${{ secrets.GPG_PUBLIC_KEY }}
           JRELEASER_GPG_SECRET_KEY: ${{ secrets.GPG_SECRET_KEY }}
-          JRELEASER_SLACK_WEBHOOK: ${{ secrets.JRELEASER_SLACK_WEBHOOK }}
+          JRELEASER_ANNOUNCE_ACTIVE: false
 
       - name: JReleaser output
         if: always()

.gitignore

@@ -39,3 +39,4 @@ out/
 .vscode/
 .DS_Store
 /target/
+.checkstyle

Dockerfile

@@ -1,4 +1,4 @@
-ARG TRINO_VERSION=380
+ARG TRINO_VERSION=393
 
 FROM docker.io/library/maven:3.6.3-openjdk-11 AS builder
 WORKDIR /root/trino-redisearch

pom.xml

@@ -5,7 +5,7 @@
 	<parent>
 		<groupId>io.trino</groupId>
 		<artifactId>trino-root</artifactId>
-		<version>380</version>
+		<version>393</version>
 	</parent>
 
 	<groupId>com.redis</groupId>

src/main/java/com/redis/trino/RediSearchMetadata.java

@@ -42,6 +42,8 @@
 
 import io.airlift.log.Logger;
 import io.airlift.slice.Slice;
+import io.trino.spi.StandardErrorCode;
+import io.trino.spi.TrinoException;
 import io.trino.spi.connector.AggregateFunction;
 import io.trino.spi.connector.AggregationApplicationResult;
 import io.trino.spi.connector.Assignment;
@@ -60,6 +62,7 @@
 import io.trino.spi.connector.ConstraintApplicationResult;
 import io.trino.spi.connector.LimitApplicationResult;
 import io.trino.spi.connector.NotFoundException;
+import io.trino.spi.connector.RetryMode;
 import io.trino.spi.connector.SchemaTableName;
 import io.trino.spi.connector.SchemaTablePrefix;
 import io.trino.spi.connector.TableNotFoundException;
@@ -182,7 +185,10 @@ public void dropColumn(ConnectorSession session, ConnectorTableHandle tableHandl
 
 	@Override
 	public ConnectorOutputTableHandle beginCreateTable(ConnectorSession session, ConnectorTableMetadata tableMetadata,
-			Optional<ConnectorTableLayout> layout) {
+			Optional<ConnectorTableLayout> layout, RetryMode retryMode) {
+		if (retryMode != RetryMode.NO_RETRIES) {
+			throw new TrinoException(StandardErrorCode.NOT_SUPPORTED, "This connector does not support query retries");
+		}
 		List<RediSearchColumnHandle> columns = buildColumnHandles(tableMetadata);
 
 		rediSearchSession.createTable(tableMetadata.getTable(), columns);
@@ -202,7 +208,11 @@ public Optional<ConnectorOutputMetadata> finishCreateTable(ConnectorSession sess
 	}
 
 	@Override
-	public ConnectorInsertTableHandle beginInsert(ConnectorSession session, ConnectorTableHandle tableHandle) {
+	public ConnectorInsertTableHandle beginInsert(ConnectorSession session, ConnectorTableHandle tableHandle,
+			List<ColumnHandle> insertedColumns, RetryMode retryMode) {
+		if (retryMode != RetryMode.NO_RETRIES) {
+			throw new TrinoException(StandardErrorCode.NOT_SUPPORTED, "This connector does not support query retries");
+		}
 		RediSearchTableHandle table = (RediSearchTableHandle) tableHandle;
 		List<RediSearchColumnHandle> columns = rediSearchSession.getTable(table.getSchemaTableName()).getColumns();
 

src/main/java/com/redis/trino/RediSearchSplitManager.java

@@ -35,6 +35,7 @@
 import io.trino.spi.connector.ConnectorSplitSource;
 import io.trino.spi.connector.ConnectorTableHandle;
 import io.trino.spi.connector.ConnectorTransactionHandle;
+import io.trino.spi.connector.Constraint;
 import io.trino.spi.connector.DynamicFilter;
 import io.trino.spi.connector.FixedSplitSource;
 
@@ -47,9 +48,14 @@ public RediSearchSplitManager(RediSearchSession session) {
 		this.addresses = session.getAddresses();
 	}
 
-	@Override
-	public ConnectorSplitSource getSplits(ConnectorTransactionHandle transaction, ConnectorSession session,
-			ConnectorTableHandle table, SplitSchedulingStrategy splitSchedulingStrategy, DynamicFilter dynamicFilter) {
+    @Override
+    public ConnectorSplitSource getSplits(
+            ConnectorTransactionHandle transaction,
+            ConnectorSession session,
+            ConnectorTableHandle tableHandle,
+            DynamicFilter dynamicFilter,
+            Constraint constraint)
+    {
 		RediSearchSplit split = new RediSearchSplit(addresses);
 
 		return new FixedSplitSource(ImmutableList.of(split));