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);
}
}