>From Wail Alkowaileet <[email protected]>: Wail Alkowaileet has submitted this change. ( https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/17811 )
Change subject: [NO ISSUE][COMP] Use data-scan select condition in filters ...................................................................... [NO ISSUE][COMP] Use data-scan select condition in filters - user model changes: no - storage format changes: no - interface changes: no Details: Allow pushed filter in data-scan to utilize columnar and external filters. Change-Id: Iedee5e54bb0344616589076ea3ed65cded6c9b5a Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/17811 Integration-Tests: Jenkins <[email protected]> Tested-by: Jenkins <[email protected]> Reviewed-by: Wail Alkowaileet <[email protected]> Reviewed-by: Ali Alsuliman <[email protected]> --- M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/pushdown/processor/AbstractFilterPushdownProcessor.java 1 file changed, 25 insertions(+), 1 deletion(-) Approvals: Wail Alkowaileet: Looks good to me, but someone else must approve Ali Alsuliman: Looks good to me, approved Jenkins: Verified; Verified diff --git a/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/pushdown/processor/AbstractFilterPushdownProcessor.java b/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/pushdown/processor/AbstractFilterPushdownProcessor.java index 4a1f156..6ca553a 100644 --- a/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/pushdown/processor/AbstractFilterPushdownProcessor.java +++ b/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/pushdown/processor/AbstractFilterPushdownProcessor.java @@ -129,7 +129,9 @@ */ ILogicalOperator useOperator = useDescriptor.getOperator(); if (useDescriptor.getScope() == scanDefineDescriptor.getScope() - && useOperator.getOperatorTag() == LogicalOperatorTag.SELECT && isPushdownAllowed(useOperator)) { + && (useOperator.getOperatorTag() == LogicalOperatorTag.SELECT + || useOperator.getOperatorTag() == LogicalOperatorTag.DATASOURCESCAN) + && isPushdownAllowed(useOperator)) { inlineAndPushdownFilter(useDescriptor, scanDefineDescriptor); } else if (useOperator.getOperatorTag() == LogicalOperatorTag.INNERJOIN) { inlineAndPushdownFilter(useDescriptor, scanDefineDescriptor); -- To view, visit https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/17811 To unsubscribe, or for help writing mail filters, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Change-Id: Iedee5e54bb0344616589076ea3ed65cded6c9b5a Gerrit-Change-Number: 17811 Gerrit-PatchSet: 2 Gerrit-Owner: Wail Alkowaileet <[email protected]> Gerrit-Reviewer: Ali Alsuliman <[email protected]> Gerrit-Reviewer: Hussain Towaileb <[email protected]> Gerrit-Reviewer: Jenkins <[email protected]> Gerrit-Reviewer: Wail Alkowaileet <[email protected]> Gerrit-MessageType: merged
