This is an automated email from the ASF dual-hosted git repository.

wyk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/asterixdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 82bf771275 [NO ISSUE][COMP] Include RUNNINGAGGREGATE & INTERSECT as 
scoped operators
82bf771275 is described below

commit 82bf771275e2f7c8ce68870be2dc3f6bd75662c4
Author: Wail Alkowaileet <[email protected]>
AuthorDate: Sat Dec 16 09:39:16 2023 -0800

    [NO ISSUE][COMP] Include RUNNINGAGGREGATE & INTERSECT as scoped operators
    
    - user model changes: no
    - storage format changes: no
    - interface changes: no
    
    Details:
    Include RUNNINGAGGREGATE & INTERSECT as scoped operators in
    pushdown context.
    
    Change-Id: I3a7b316d2bd04c64f0e328e7077a75eb784c4eb1
    Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/18015
    Integration-Tests: Jenkins <[email protected]>
    Tested-by: Jenkins <[email protected]>
    Reviewed-by: Wail Alkowaileet <[email protected]>
    Reviewed-by: Ali Alsuliman <[email protected]>
---
 .../org/apache/asterix/optimizer/rules/pushdown/PushdownContext.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/pushdown/PushdownContext.java
 
b/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/pushdown/PushdownContext.java
index 51d25a4cc2..e565b8d2ff 100644
--- 
a/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/pushdown/PushdownContext.java
+++ 
b/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/pushdown/PushdownContext.java
@@ -244,7 +244,8 @@ public class PushdownContext {
 
     private static Set<LogicalOperatorTag> getScopeOperators() {
         return EnumSet.of(LogicalOperatorTag.INNERJOIN, 
LogicalOperatorTag.LEFTOUTERJOIN, LogicalOperatorTag.GROUP,
-                LogicalOperatorTag.AGGREGATE, LogicalOperatorTag.WINDOW, 
LogicalOperatorTag.UNIONALL);
+                LogicalOperatorTag.AGGREGATE, LogicalOperatorTag.WINDOW, 
LogicalOperatorTag.RUNNINGAGGREGATE,
+                LogicalOperatorTag.UNIONALL, LogicalOperatorTag.INTERSECT);
     }
 
 }

Reply via email to