Enabling Filters on Active Datasets master
authorXikui Wang <xkkwww@gmail.com>
Sat, 19 Sep 2020 18:25:23 +0000 (11:25 -0700)
committerXikui Wang <xkkwww@gmail.com>
Sat, 19 Sep 2020 18:25:23 +0000 (11:25 -0700)
commit9ffb0122ca9cec651d5f95b0770fd07baebcf019
treec6830735742ddd824b48a12547017f48d432513d
parent0bc1dfd8baae50b25740e9fc6c744b9de4c122cb
Enabling Filters on Active Datasets

Change-Id: I499b1d9a1525ba5ea9396d21118c6f6cf3e870d2
33 files changed:
asterix-bad/src/main/java/org/apache/asterix/bad/BADConstants.java
asterix-bad/src/main/java/org/apache/asterix/bad/extension/BADMetadataExtension.java
asterix-bad/src/main/java/org/apache/asterix/bad/feed/operators/BADLSMPrimaryInsertOperatorNodePushable.java
asterix-bad/src/main/java/org/apache/asterix/bad/feed/operators/BADLSMPrimaryUpsertOperatorDescriptor.java
asterix-bad/src/main/java/org/apache/asterix/bad/feed/operators/BADLSMPrimaryUpsertOperatorNodePushable.java
asterix-bad/src/main/java/org/apache/asterix/bad/function/BADFunctionCollection.java
asterix-bad/src/main/java/org/apache/asterix/bad/function/BADFunctionRegistrant.java
asterix-bad/src/main/java/org/apache/asterix/bad/function/BADFunctions.java
asterix-bad/src/main/java/org/apache/asterix/bad/function/runtime/CurrentChannelTimeDescriptor.java
asterix-bad/src/main/java/org/apache/asterix/bad/function/runtime/PreviousChannelTimeDescriptor.java
asterix-bad/src/main/java/org/apache/asterix/bad/lang/BADExpressionToPlanTranslator.java
asterix-bad/src/main/java/org/apache/asterix/bad/lang/BADRuleSetFactory.java
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/AbstractCreateChannelStatement.java
asterix-bad/src/main/java/org/apache/asterix/bad/metadata/BADMetadataProvider.java
asterix-bad/src/main/java/org/apache/asterix/bad/rules/RewriteActiveFunctionsRule.java [new file with mode: 0644]
asterix-bad/src/main/java/org/apache/asterix/bad/rules/RewriteChannelTimeFunctionToLocalVarRule.java
asterix-bad/src/main/java/org/apache/asterix/bad/runtime/ActiveTimestampManager.java
asterix-bad/src/main/java/org/apache/asterix/bad/runtime/ActiveTimestampState.java
asterix-bad/src/main/resources/lang-extension/lang.txt
asterix-bad/src/test/resources/optimizerts/queries/bad_cq/new_tweets_active_ts.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/queries/bad_cq/new_tweets_meta_and.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/queries/bad_cq/new_tweets_meta_or.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/results/bad_cq/new_nearby_tweets.plan
asterix-bad/src/test/resources/optimizerts/results/bad_cq/new_tweets.plan
asterix-bad/src/test/resources/optimizerts/results/bad_cq/new_tweets_active_ts.plan [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/results/bad_cq/new_tweets_meta_active_ts.plan [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/results/bad_cq/new_tweets_meta_and.plan [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/results/bad_cq/new_tweets_meta_or.plan [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/results/bad_cq/new_tweets_push.plan
asterix-bad/src/test/resources/optimizerts/results/bad_cq/unseen_nearby_tweets.plan
asterix-bad/src/test/resources/optimizerts/results/bad_rq/channel-subscribe.plan
asterix-bad/src/test/resources/runtimets/queries/bad_rq/add_index/add_index.5.query.sqlpp
asterix-bad/src/test/resources/runtimets/results/bad_rq/add_index/add_index.1.adm