Add support for filter functions in partial aggregation pushdown
@@ -76,9 +76,7 @@ public class PushPartialAggregationThroughJoin
JoinNode joinNode = (JoinNode) childNode;
- if (joinNode.getType() != JoinNode.Type.INNER || joinNode.getFilter().isPresent()) {
- // TODO: add support for filter function.
- // All availableSymbols used in filter function could be added to pushedDownGroupingSet
+ if (joinNode.getType() != JoinNode.Type.INNER) {
return Optional.empty();
}
