Introducing BAD-CQ
authorXikui Wang <xkkwww@gmail.com>
Fri, 21 Aug 2020 04:18:04 +0000 (21:18 -0700)
committerXikui Wang <xkkwww@gmail.com>
Fri, 21 Aug 2020 04:18:04 +0000 (21:18 -0700)
commit9d26e078d1d7c64c137d2e7752756efd40c49fad
treebaa6bfe9343262d7877915e52e2a781695f997e8
parent1ef044918ac590e643c7579adcdece3334a7511e
Introducing BAD-CQ

a. Active datasets
  Active datasets are like regular datasets that can be
  inserted/upserted/deleted with statements and fed with data feeds
  directly.  Records stored in active datasets contain an additional
  active timestamp field (implemented using meta-records). The active
  timestamp is assigned inside the storage, right before persistence.
  This patch introduced new syntactic components to enable creating
  active datasets.  It also created a BAD query translator to make sure
  all DML statements can operate on active datasets.
b. Continuous channels
  Continuous channels are built on repetitive channels but provide
  continuous query semantics. To ensure that, this patch introduced an
  active timestamp manager on each node to manage channel execution
  times locally. Active timestamp managers are a local class that is
  tied to a JVM on a node. There is also an optimization rule for
  ensuring continuous query semantics in a distributed environment.
c. Active functions
  Active functions are used for helping users create continuous queries.
  They were added through the extension APIs.
d. BAD Islands
  As an application built on BAD-CQ, BAD islands show how we connect
  data channels to data feeds and share data between different BAD
  systems declaratively.
e. Cleanups and fixes
  This patch also cleaned up the BAD codebase and introduced tests for
  metadata, optimizer, and runtime. It fixed a type inferencing issue in
  InsertBrokerNotifierForChannelRule when there is a group-by in the
  query. Also, it optimized the broker notification delivery to use
  separate threads.

Change-Id: I77263c3fedd03205b83fe13978649b33fccda11c
235 files changed:
asterix-bad/data/tweets.txt [new file with mode: 0644]
asterix-bad/pom.xml
asterix-bad/src/main/java/org/apache/asterix/bad/BADConstants.java
asterix-bad/src/main/java/org/apache/asterix/bad/BADJobService.java
asterix-bad/src/main/java/org/apache/asterix/bad/BADUtils.java [new file with mode: 0644]
asterix-bad/src/main/java/org/apache/asterix/bad/extension/BADLangExtension.java [moved from asterix-bad/src/main/java/org/apache/asterix/bad/lang/BADLangExtension.java with 98% similarity]
asterix-bad/src/main/java/org/apache/asterix/bad/extension/BADMetadataExtension.java [moved from asterix-bad/src/main/java/org/apache/asterix/bad/metadata/BADMetadataExtension.java with 75% similarity]
asterix-bad/src/main/java/org/apache/asterix/bad/extension/BADQueryTranslatorExtension.java [moved from asterix-bad/src/main/java/org/apache/asterix/bad/lang/BADQueryTranslatorExtension.java with 94% similarity]
asterix-bad/src/main/java/org/apache/asterix/bad/extension/BADRecoveryExtension.java [moved from asterix-bad/src/main/java/org/apache/asterix/bad/recovery/BADRecoveryExtension.java with 94% similarity]
asterix-bad/src/main/java/org/apache/asterix/bad/feed/operators/BADLSMPrimaryInsertOperatorDescriptor.java [new file with mode: 0644]
asterix-bad/src/main/java/org/apache/asterix/bad/feed/operators/BADLSMPrimaryInsertOperatorNodePushable.java [new file with mode: 0644]
asterix-bad/src/main/java/org/apache/asterix/bad/feed/operators/BADLSMPrimaryUpsertOperatorDescriptor.java [new file with mode: 0644]
asterix-bad/src/main/java/org/apache/asterix/bad/feed/operators/BADLSMPrimaryUpsertOperatorNodePushable.java [new file with mode: 0644]
asterix-bad/src/main/java/org/apache/asterix/bad/function/BADFunctionCollection.java [new file with mode: 0644]
asterix-bad/src/main/java/org/apache/asterix/bad/function/BADFunctionRegistrant.java [new file with mode: 0644]
asterix-bad/src/main/java/org/apache/asterix/bad/function/BADFunctions.java [new file with mode: 0644]
asterix-bad/src/main/java/org/apache/asterix/bad/function/rewriter/BADFeedRewriter.java [new file with mode: 0644]
asterix-bad/src/main/java/org/apache/asterix/bad/function/runtime/CurrentChannelTimeDescriptor.java [new file with mode: 0644]
asterix-bad/src/main/java/org/apache/asterix/bad/function/runtime/PreviousChannelTimeDescriptor.java [new file with mode: 0644]
asterix-bad/src/main/java/org/apache/asterix/bad/lang/BADCompilationProvider.java
asterix-bad/src/main/java/org/apache/asterix/bad/lang/BADExpressionToPlanTranslator.java [new file with mode: 0644]
asterix-bad/src/main/java/org/apache/asterix/bad/lang/BADExpressionToPlanTranslatorFactory.java [new file with mode: 0644]
asterix-bad/src/main/java/org/apache/asterix/bad/lang/BADLangUtils.java [new file with mode: 0644]
asterix-bad/src/main/java/org/apache/asterix/bad/lang/BADQueryTranslator.java [moved from asterix-bad/src/main/java/org/apache/asterix/bad/lang/BADStatementExecutor.java with 71% similarity]
asterix-bad/src/main/java/org/apache/asterix/bad/lang/BADQueryTranslatorFactory.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 [moved from asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java with 79% similarity]
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/BrokerDropStatement.java
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelDropStatement.java
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelSubscribeStatement.java
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelUnsubscribeStatement.java
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateBrokerStatement.java
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateContinuousChannelStatement.java [new file with mode: 0644]
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateProcedureStatement.java
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateRepetitiveChannelStatement.java [new file with mode: 0644]
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ExecuteProcedureStatement.java
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ProcedureDropStatement.java
asterix-bad/src/main/java/org/apache/asterix/bad/metadata/BADMetadataIndexes.java
asterix-bad/src/main/java/org/apache/asterix/bad/metadata/BADMetadataProvider.java [new file with mode: 0644]
asterix-bad/src/main/java/org/apache/asterix/bad/metadata/BADMetadataRecordTypes.java
asterix-bad/src/main/java/org/apache/asterix/bad/metadata/Broker.java
asterix-bad/src/main/java/org/apache/asterix/bad/metadata/BrokerTupleTranslator.java
asterix-bad/src/main/java/org/apache/asterix/bad/metadata/Channel.java
asterix-bad/src/main/java/org/apache/asterix/bad/metadata/Procedure.java
asterix-bad/src/main/java/org/apache/asterix/bad/recovery/BADGlobalRecoveryManager.java
asterix-bad/src/main/java/org/apache/asterix/bad/rules/InsertBrokerNotifierForChannelRule.java
asterix-bad/src/main/java/org/apache/asterix/bad/rules/RewriteChannelTimeFunctionToLocalVarRule.java [new file with mode: 0644]
asterix-bad/src/main/java/org/apache/asterix/bad/runtime/ActiveTimestampManager.java [new file with mode: 0644]
asterix-bad/src/main/java/org/apache/asterix/bad/runtime/ActiveTimestampState.java [new file with mode: 0644]
asterix-bad/src/main/java/org/apache/asterix/bad/runtime/operators/NotifyBrokerOperator.java [moved from asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerOperator.java with 86% similarity]
asterix-bad/src/main/java/org/apache/asterix/bad/runtime/operators/NotifyBrokerPOperator.java [moved from asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerPOperator.java with 92% similarity]
asterix-bad/src/main/java/org/apache/asterix/bad/runtime/operators/NotifyBrokerRuntime.java [moved from asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntime.java with 65% similarity]
asterix-bad/src/main/java/org/apache/asterix/bad/runtime/operators/NotifyBrokerRuntimeFactory.java [moved from asterix-bad/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntimeFactory.java with 86% similarity]
asterix-bad/src/main/resources/META-INF/services/org.apache.asterix.om.functions.IFunctionRegistrant [new file with mode: 0644]
asterix-bad/src/main/resources/asterix-build-configuration.xml
asterix-bad/src/main/resources/cc.conf
asterix-bad/src/main/resources/lang-extension/lang.txt
asterix-bad/src/main/resources/log4j2-bad.xml [new file with mode: 0644]
asterix-bad/src/test/java/org/apache/asterix/bad/test/BADAsterixHyracksIntegrationUtil.java
asterix-bad/src/test/java/org/apache/asterix/bad/test/BADExecutionTest.java
asterix-bad/src/test/java/org/apache/asterix/bad/test/BADListenerTest.java
asterix-bad/src/test/java/org/apache/asterix/bad/test/BADMetadataTest.java [new file with mode: 0644]
asterix-bad/src/test/java/org/apache/asterix/bad/test/BADOptimizerTest.java
asterix-bad/src/test/resources/metadata/queries/bad_cq/continuous_channel/continuous_channel.1.ddl.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/metadata/queries/bad_cq/continuous_channel/continuous_channel.2.update.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/metadata/queries/bad_cq/continuous_channel/continuous_channel.3.update.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/add_index/add_index.3.update.sqlpp with 76% similarity]
asterix-bad/src/test/resources/metadata/queries/bad_cq/continuous_channel/continuous_channel.4.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/metadata/queries/bad_cq/create_active_datasets/create_active_datasets.1.ddl.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/metadata/queries/bad_cq/create_active_datasets/create_active_datasets.2.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/metadata/queries/bad_cq/create_bad_broker/create_bad_broker.1.ddl.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/room_occupants/room_occupants.2.update.sqlpp with 80% similarity]
asterix-bad/src/test/resources/metadata/queries/bad_cq/create_bad_broker/create_bad_broker.2.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/metadata/queries/bad_cq/create_bad_feed/create_bad_feed.1.ddl.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/metadata/queries/bad_cq/create_bad_feed/create_bad_feed.2.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/metadata/results/bad_cq/continuous_channel/continuous_channel.1.adm [new file with mode: 0644]
asterix-bad/src/test/resources/metadata/results/bad_cq/create_active_datasets/create_active_datasets.1.adm [new file with mode: 0644]
asterix-bad/src/test/resources/metadata/results/bad_cq/create_bad_broker/create_bad_broker.1.adm [new file with mode: 0644]
asterix-bad/src/test/resources/metadata/results/bad_cq/create_bad_feed/create_bad_feed.1.adm [new file with mode: 0644]
asterix-bad/src/test/resources/metadata/testsuite.xml [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/ignore.txt [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/only.txt [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/queries/bad_cq/cq_udf_test.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/room_occupants/room_occupants.4.query.sqlpp with 52% similarity]
asterix-bad/src/test/resources/optimizerts/queries/bad_cq/new_nearby_tweets.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/queries/bad_cq/new_tweets.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/queries/bad_cq/new_tweets_push.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/queries/bad_cq/threatening_event_near.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/queries/bad_cq/unseen_nearby_tweets.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/queries/bad_rq/channel-advanced-index-only.sqlpp [moved from asterix-bad/src/test/resources/optimizerts/queries/channel/channel-advanced-index-only.sqlpp with 100% similarity]
asterix-bad/src/test/resources/optimizerts/queries/bad_rq/channel-advanced.sqlpp [moved from asterix-bad/src/test/resources/optimizerts/queries/channel/channel-advanced.sqlpp with 100% similarity]
asterix-bad/src/test/resources/optimizerts/queries/bad_rq/channel-create.sqlpp [moved from asterix-bad/src/test/resources/optimizerts/queries/channel/channel-create.sqlpp with 100% similarity]
asterix-bad/src/test/resources/optimizerts/queries/bad_rq/channel-push.sqlpp [moved from asterix-bad/src/test/resources/optimizerts/queries/channel/channel-push.sqlpp with 100% similarity]
asterix-bad/src/test/resources/optimizerts/queries/bad_rq/channel-subscribe.sqlpp [moved from asterix-bad/src/test/resources/optimizerts/queries/channel/channel-subscribe.sqlpp with 100% similarity]
asterix-bad/src/test/resources/optimizerts/queries/bad_rq/channel-unsubscribe.sqlpp [moved from asterix-bad/src/test/resources/optimizerts/queries/channel/channel-unsubscribe.sqlpp with 100% similarity]
asterix-bad/src/test/resources/optimizerts/results/bad_cq/cq_udf_test.plan [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/results/bad_cq/new_nearby_tweets.plan [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/results/bad_cq/new_tweets.plan [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/results/bad_cq/new_tweets_push.plan [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/results/bad_cq/threatening_event_near.plan [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/results/bad_cq/unseen_nearby_tweets.plan [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/results/bad_rq/channel-advanced-index-only.plan [moved from asterix-bad/src/test/resources/optimizerts/results/channel/channel-advanced-index-only.plan with 66% similarity]
asterix-bad/src/test/resources/optimizerts/results/bad_rq/channel-advanced.plan [moved from asterix-bad/src/test/resources/optimizerts/results/channel/channel-advanced.plan with 67% similarity]
asterix-bad/src/test/resources/optimizerts/results/bad_rq/channel-create.plan [moved from asterix-bad/src/test/resources/optimizerts/results/channel/channel-create.plan with 92% similarity]
asterix-bad/src/test/resources/optimizerts/results/bad_rq/channel-push.plan [new file with mode: 0644]
asterix-bad/src/test/resources/optimizerts/results/bad_rq/channel-subscribe.plan [moved from asterix-bad/src/test/resources/optimizerts/results/channel/channel-subscribe.plan with 93% similarity]
asterix-bad/src/test/resources/optimizerts/results/bad_rq/channel-unsubscribe.plan [moved from asterix-bad/src/test/resources/optimizerts/results/channel/channel-unsubscribe.plan with 93% similarity]
asterix-bad/src/test/resources/optimizerts/results/channel/channel-push.plan [deleted file]
asterix-bad/src/test/resources/runtimets/only_bad.xml [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_dataset_delete/active_dataset_delete.1.ddl.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_dataset_delete/active_dataset_delete.2.update.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_dataset_delete/active_dataset_delete.3.update.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_dataset_delete/active_dataset_delete.4.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_dataset_delete/active_dataset_delete.5.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_dataset_insert/active_dataset_insert.1.ddl.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_dataset_insert/active_dataset_insert.2.update.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/disasters_with_friends/disasters_with_friends.2.update.sqlpp with 78% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_dataset_insert/active_dataset_insert.3.update.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/add_index/add_index.4.sleep.sqlpp with 78% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_dataset_insert/active_dataset_insert.4.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_dataset_insert/active_dataset_insert.5.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_dataset_upsert/active_dataset_upsert.1.ddl.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_dataset_upsert/active_dataset_upsert.2.update.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/add_index/add_index.6.ddl.sqlpp with 78% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_dataset_upsert/active_dataset_upsert.3.update.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_dataset_upsert/active_dataset_upsert.4.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_dataset_upsert/active_dataset_upsert.5.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_feeds/active_feeds.1.ddl.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_feeds/active_feeds.2.update.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/ten_minute_channel/ten_minute_channel.2.update.sqlpp with 78% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_feeds/active_feeds.3.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_function_in_udf/active_function_in_udf.1.ddl.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/room_occupants/room_occupants.3.update.sqlpp with 77% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_function_in_udf/active_function_in_udf.2.update.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_function_in_udf/active_function_in_udf.3.update.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_function_in_udf/active_function_in_udf.4.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_functions/active_functions.1.ddl.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_functions/active_functions.2.update.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/active_functions/active_functions.3.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/bad_http_feed/bad_http_feed.1.ddl.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/bad_http_feed/bad_http_feed.2.update.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/bad_http_feed/bad_http_feed.3.post.http [moved from asterix-bad/src/test/resources/runtimets/queries/channel/add_index/add_index.5.query.sqlpp with 67% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/bad_http_feed/bad_http_feed.4.post.http [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/bad_http_feed/bad_http_feed.5.sleep.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/bad_http_feed/bad_http_feed.6.update.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/bad_http_feed/bad_http_feed.7.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/bad_http_feed/bad_http_feed.8.ddl.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/bad_islands/bad_islands.1.ddl.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/bad_islands/bad_islands.10.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/bad_islands/bad_islands.2.ddl.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/disasters_with_friends/disasters_with_friends.6.ddl.sqlpp with 81% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/bad_islands/bad_islands.3.ddl.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/bad_islands/bad_islands.4.post.http [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/bad_islands/bad_islands.5.sleep.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/bad_islands/bad_islands.6.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/bad_islands/bad_islands.7.ddl.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/bad_islands/bad_islands.8.post.http [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/bad_islands/bad_islands.9.sleep.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/new_tweets_from_area/new_tweets_from_area.1.ddl.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/new_tweets_from_area/new_tweets_from_area.2.update.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/new_tweets_from_area/new_tweets_from_area.3.update.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/new_tweets_from_area/new_tweets_from_area.4.update.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/new_tweets_from_area/new_tweets_from_area.5.sleep.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_cq/new_tweets_from_area/new_tweets_from_area.6.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/add_index/add_index.1.ddl.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/add_index/add_index.1.ddl.sqlpp with 87% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/add_index/add_index.2.update.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/add_index/add_index.2.update.sqlpp with 99% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/add_index/add_index.3.update.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/add_index/add_index.4.sleep.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/add_index/add_index.5.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/add_index/add_index.6.ddl.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/create_channel_check_datasets/create_channel_check_datasets.1.ddl.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/create_channel_check_metadata/create_channel_check_metadata.1.ddl.sqlpp with 89% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/create_channel_check_datasets/create_channel_check_datasets.3.query.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/create_channel_check_datasets/create_channel_check_datasets.3.query.sqlpp with 100% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/create_channel_check_metadata/create_channel_check_metadata.1.ddl.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/create_channel_check_datasets/create_channel_check_datasets.1.ddl.sqlpp with 86% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/create_channel_check_metadata/create_channel_check_metadata.3.query.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/create_channel_check_metadata/create_channel_check_metadata.3.query.sqlpp with 100% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/disasters_with_friends/disasters_with_friends.1.ddl.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/disasters_with_friends/disasters_with_friends.1.ddl.sqlpp with 90% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/disasters_with_friends/disasters_with_friends.2.update.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/disasters_with_friends/disasters_with_friends.3.update.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/disasters_with_friends/disasters_with_friends.3.update.sqlpp with 79% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/disasters_with_friends/disasters_with_friends.4.sleep.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/disasters_with_friends/disasters_with_friends.5.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/disasters_with_friends/disasters_with_friends.6.ddl.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/drop_channel_check_datasets/drop_channel_check_datasets.1.ddl.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/drop_channel_check_datasets/drop_channel_check_datasets.1.ddl.sqlpp with 92% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/drop_channel_check_datasets/drop_channel_check_datasets.2.ddl.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/drop_channel_check_datasets/drop_channel_check_datasets.2.ddl.sqlpp with 100% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/drop_channel_check_datasets/drop_channel_check_datasets.3.query.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/drop_channel_check_datasets/drop_channel_check_datasets.3.query.sqlpp with 100% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/drop_channel_check_metadata/drop_channel_check_metadata.1.ddl.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/drop_channel_check_metadata/drop_channel_check_metadata.1.ddl.sqlpp with 92% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/drop_channel_check_metadata/drop_channel_check_metadata.2.ddl.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/drop_channel_check_metadata/drop_channel_check_metadata.2.ddl.sqlpp with 100% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/drop_channel_check_metadata/drop_channel_check_metadata.3.query.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/drop_channel_check_metadata/drop_channel_check_metadata.3.query.sqlpp with 100% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/drop_function/drop_function.1.ddl.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/drop_function_dataverse/drop_function_dataverse.1.ddl.sqlpp with 90% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/drop_function_dataverse/drop_function_dataverse.1.ddl.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/drop_function/drop_function.1.ddl.sqlpp with 89% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/drop_index/drop_index.1.ddl.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/drop_index/drop_index.1.ddl.sqlpp with 93% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/drop_results/drop_results.1.ddl.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/drop_results/drop_results.1.ddl.sqlpp with 90% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/drop_subscriptions/drop_subscriptions.1.ddl.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/drop_subscriptions/drop_subscriptions.1.ddl.sqlpp with 89% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/room_occupants/room_occupants.1.ddl.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/room_occupants/room_occupants.1.ddl.sqlpp with 94% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/room_occupants/room_occupants.2.update.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/room_occupants/room_occupants.3.update.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/room_occupants/room_occupants.4.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/room_occupants/room_occupants.5.update.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/room_occupants/room_occupants.5.update.sqlpp with 88% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/room_occupants/room_occupants.6.sleep.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/room_occupants/room_occupants.7.update.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/room_occupants/room_occupants.7.update.sqlpp with 88% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/room_occupants/room_occupants.8.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/room_occupants/room_occupants.9.ddl.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/room_occupants/room_occupants.9.ddl.sqlpp with 100% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.1.ddl.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.1.ddl.sqlpp with 88% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.2.update.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.2.update.sqlpp with 100% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.3.update.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.3.update.sqlpp with 100% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.4.update.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.4.update.sqlpp with 100% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.5.query.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.5.query.sqlpp with 100% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/ten_minute_channel/ten_minute_channel.1.ddl.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/ten_minute_channel/ten_minute_channel.1.ddl.sqlpp with 80% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/ten_minute_channel/ten_minute_channel.2.update.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/ten_minute_channel/ten_minute_channel.3.update.sqlpp [moved from asterix-bad/src/test/resources/runtimets/queries/channel/ten_minute_channel/ten_minute_channel.3.update.sqlpp with 88% similarity]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/ten_minute_channel/ten_minute_channel.4.sleep.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/bad_rq/ten_minute_channel/ten_minute_channel.5.query.sqlpp [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/queries/channel/disasters_with_friends/disasters_with_friends.4.pollquery.sqlpp [deleted file]
asterix-bad/src/test/resources/runtimets/queries/channel/room_occupants/room_occupants.6.sleep.sqlpp [deleted file]
asterix-bad/src/test/resources/runtimets/queries/channel/room_occupants/room_occupants.8.query.sqlpp [deleted file]
asterix-bad/src/test/resources/runtimets/queries/channel/ten_minute_channel/ten_minute_channel.4.sleep.sqlpp [deleted file]
asterix-bad/src/test/resources/runtimets/queries/channel/ten_minute_channel/ten_minute_channel.5.query.sqlpp [deleted file]
asterix-bad/src/test/resources/runtimets/queries/procedure/create_procedure_check_metadata/create_procedure_check_metadata.1.ddl.sqlpp
asterix-bad/src/test/resources/runtimets/results/bad_cq/active_dataset_delete/active_datasets.4.adm [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/results/bad_cq/active_dataset_delete/active_datasets.5.adm [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/results/bad_cq/active_dataset_insert/active_datasets.4.adm [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/results/bad_cq/active_dataset_insert/active_datasets.5.adm [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/results/bad_cq/active_dataset_upsert/active_datasets.4.adm [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/results/bad_cq/active_dataset_upsert/active_datasets.5.adm [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/results/bad_cq/active_feeds/active_feeds.1.adm [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/results/bad_cq/active_function_in_udf/active_function_in_udf.1.adm [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/results/bad_cq/active_functions/active_functions.1.adm [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/results/bad_cq/bad_http_feed/bad_http_feed.3.adm [moved from asterix-bad/src/test/resources/runtimets/results/channel/disasters_with_friends/disasters_with_friends.1.adm with 100% similarity]
asterix-bad/src/test/resources/runtimets/results/bad_cq/bad_http_feed/bad_http_feed.4.adm [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/results/bad_cq/bad_http_feed/bad_http_feed.7.adm [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/results/bad_cq/bad_islands/bad_islands.10.adm [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/results/bad_cq/bad_islands/bad_islands.4.adm [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/results/bad_cq/bad_islands/bad_islands.6.adm [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/results/bad_cq/bad_islands/bad_islands.8.adm [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/results/bad_cq/new_tweets_from_area/new_tweets_from_area.1.adm [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/results/bad_rq/add_index/add_index.1.adm [moved from asterix-bad/src/test/resources/runtimets/results/channel/add_index/add_index.1.adm with 100% similarity]
asterix-bad/src/test/resources/runtimets/results/bad_rq/create_channel_check_datasets/create_channel_check_datasets.1.adm [moved from asterix-bad/src/test/resources/runtimets/results/channel/create_channel_check_datasets/create_channel_check_datasets.1.adm with 100% similarity]
asterix-bad/src/test/resources/runtimets/results/bad_rq/create_channel_check_metadata/create_channel_check_metadata.1.adm [moved from asterix-bad/src/test/resources/runtimets/results/channel/create_channel_check_metadata/create_channel_check_metadata.1.adm with 73% similarity]
asterix-bad/src/test/resources/runtimets/results/bad_rq/disasters_with_friends/disasters_with_friends.5.adm [new file with mode: 0644]
asterix-bad/src/test/resources/runtimets/results/bad_rq/drop_channel_check_datasets/drop_channel_check_datasets.1.adm [moved from asterix-bad/src/test/resources/runtimets/results/channel/drop_channel_check_datasets/drop_channel_check_datasets.1.adm with 100% similarity]
asterix-bad/src/test/resources/runtimets/results/bad_rq/drop_channel_check_metadata/drop_channel_check_metadata.1.adm [moved from asterix-bad/src/test/resources/runtimets/results/channel/drop_channel_check_metadata/drop_channel_check_metadata.1.adm with 72% similarity]
asterix-bad/src/test/resources/runtimets/results/bad_rq/room_occupants/room_occupants.1.adm [moved from asterix-bad/src/test/resources/runtimets/results/channel/room_occupants/room_occupants.1.adm with 100% similarity]
asterix-bad/src/test/resources/runtimets/results/bad_rq/room_occupants/room_occupants.2.adm [moved from asterix-bad/src/test/resources/runtimets/results/channel/room_occupants/room_occupants.2.adm with 100% similarity]
asterix-bad/src/test/resources/runtimets/results/bad_rq/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.1.adm [moved from asterix-bad/src/test/resources/runtimets/results/channel/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.1.adm with 100% similarity]
asterix-bad/src/test/resources/runtimets/results/bad_rq/ten_minute_channel/ten_minute_channel.5.adm [moved from asterix-bad/src/test/resources/runtimets/results/channel/ten_minute_channel/ten_minute_channel.5.adm with 100% similarity]
asterix-bad/src/test/resources/runtimets/testsuite_bad.xml [moved from asterix-bad/src/test/resources/runtimets/testsuite.xml with 77% similarity]