From bfbc2b2dee764047a398aef0ab4b88941301b379 Mon Sep 17 00:00:00 2001 From: Piotr Findeisen Date: Fri, 1 Dec 2023 18:35:25 +0100 Subject: [PATCH] fixup! Implement complex join pushdown in JDBC connectors --- .../src/main/java/io/trino/plugin/jdbc/DefaultJdbcMetadata.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/DefaultJdbcMetadata.java b/plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/DefaultJdbcMetadata.java index 244b34e7c30c..7d0d7f6d6b08 100644 --- a/plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/DefaultJdbcMetadata.java +++ b/plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/DefaultJdbcMetadata.java @@ -498,7 +498,7 @@ public Optional> applyJoin( .collect(toImmutableMap(Entry::getKey, entry -> newLeftColumns.get((JdbcColumnHandle) entry.getValue())))) .putAll(rightAssignments.entrySet().stream() .collect(toImmutableMap(Entry::getKey, entry -> newRightColumns.get((JdbcColumnHandle) entry.getValue())))) - .build(); + .buildOrThrow(); ImmutableList.Builder joinConditions = ImmutableList.builder(); for (ConnectorExpression conjunct : extractConjuncts(joinCondition)) {