diff --git a/core/trino-main/src/main/java/io/trino/operator/DynamicFilterSourceOperator.java b/core/trino-main/src/main/java/io/trino/operator/DynamicFilterSourceOperator.java index 7995bea62a31..a34b5b852292 100644 --- a/core/trino-main/src/main/java/io/trino/operator/DynamicFilterSourceOperator.java +++ b/core/trino-main/src/main/java/io/trino/operator/DynamicFilterSourceOperator.java @@ -79,7 +79,7 @@ public static class DynamicFilterSourceOperatorFactory private final PlanNodeId planNodeId; private final DynamicFilterSourceConsumer dynamicPredicateConsumer; private final List channels; - private final int maxDisinctValues; + private final int maxDistinctValues; private final DataSize maxFilterSize; private final int minMaxCollectionLimit; private final BlockTypeOperators blockTypeOperators; @@ -92,7 +92,7 @@ public DynamicFilterSourceOperatorFactory( PlanNodeId planNodeId, DynamicFilterSourceConsumer dynamicPredicateConsumer, List channels, - int maxDisinctValues, + int maxDistinctValues, DataSize maxFilterSize, int minMaxCollectionLimit, BlockTypeOperators blockTypeOperators) @@ -105,7 +105,7 @@ public DynamicFilterSourceOperatorFactory( "duplicate dynamic filters are not allowed"); verify(channels.stream().map(channel -> channel.index).collect(toSet()).size() == channels.size(), "duplicate channel indices are not allowed"); - this.maxDisinctValues = maxDisinctValues; + this.maxDistinctValues = maxDistinctValues; this.maxFilterSize = maxFilterSize; this.minMaxCollectionLimit = minMaxCollectionLimit; this.blockTypeOperators = requireNonNull(blockTypeOperators, "blockTypeOperators is null"); @@ -123,7 +123,7 @@ public Operator createOperator(DriverContext driverContext) dynamicPredicateConsumer, channels, planNodeId, - maxDisinctValues, + maxDistinctValues, maxFilterSize, minMaxCollectionLimit, blockTypeOperators);