Skip to content

Commit 7939c12

Browse files
committed
Add full connector expression to split factory constraint
1 parent dc70e85 commit 7939c12

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

core/trino-main/src/main/java/io/trino/sql/planner/SplitSourceFactory.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -78,8 +78,10 @@
7878

7979
import java.util.List;
8080
import java.util.Map;
81+
import java.util.Map.Entry;
8182
import java.util.Optional;
8283

84+
import static com.google.common.collect.ImmutableMap.toImmutableMap;
8385
import static com.google.common.collect.Iterables.getOnlyElement;
8486
import static io.trino.spi.connector.DynamicFilter.EMPTY;
8587
import static io.trino.sql.ir.Booleans.TRUE;
@@ -179,6 +181,9 @@ private SplitSource createSplitSource(TableHandle table, Map<Symbol, ColumnHandl
179181
// we are interested only in functional predicate here, so we set the summary to ALL.
180182
Constraint constraint = new Constraint(
181183
TupleDomain.all(),
184+
ConnectorExpressionTranslator.translateConjuncts(session, nonDynamicFilter).connectorExpression(),
185+
assignments.entrySet().stream()
186+
.collect(toImmutableMap(entry -> entry.getKey().name(), Entry::getValue)),
182187
evaluator::isCandidate,
183188
evaluator.getArguments());
184189

0 commit comments

Comments
 (0)