Steven Jacobs has uploaded a new change for review. https://asterix-gerrit.ics.uci.edu/1150
Change subject: Added BAD as an extension to Asterix ...................................................................... Added BAD as an extension to Asterix Users can create and delete repetitive channels Users can subscribe to and unsubscribe from channels Users can create and drop brokers Added Channel Tests Additional Changes: Allow commits to be non-sink operators (contnue job pipeline after commit) Enhanced Insert AQL Added "return records" and "returning [fieldName]" "return records" returns to the user all records that were inserted "returning [fieldName]" returns only the valuse inserted for [fieldName] Change-Id: I65789d2a861d15232dd29156a6987d0635ec6c94 --- M .gitignore M asterixdb/asterix-active/pom.xml M asterixdb/asterix-active/src/main/java/org/apache/asterix/active/IActiveEntityEventsListener.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/algebra/extension/IExtensionStatement.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/CommitOperator.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/physical/CommitPOperator.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/physical/CommitRuntime.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/physical/CommitRuntimeFactory.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/physical/UpsertCommitRuntime.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/base/RuleCollections.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceDynamicTypeCastRule.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceSecondaryIndexInsertDeleteRule.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceStaticTypeCastForInsertRule.java R asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/SetupCommitExtensionOpRule.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/UnnestToDataScanRule.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/AbstractIntroduceAccessMethodRule.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/AccessMethodUtils.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/BTreeAccessMethod.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/IOptimizableFuncExpr.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/OptimizableFuncExpr.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/OptimizableOperatorSubTree.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/CompiledStatements.java M asterixdb/asterix-algebra/src/main/java/org/apache/asterix/translator/LangExpressionToPlanTranslator.java M asterixdb/asterix-app/src/main/java/org/apache/asterix/api/http/servlet/FeedServlet.java M asterixdb/asterix-app/src/main/java/org/apache/asterix/app/translator/QueryTranslator.java M asterixdb/asterix-app/src/test/java/org/apache/asterix/app/bootstrap/TestNodeController.java M asterixdb/asterix-app/src/test/java/org/apache/asterix/test/optimizer/OptimizerTest.java M asterixdb/asterix-app/src/test/java/org/apache/asterix/test/runtime/ExecutionTestUtil.java A asterixdb/asterix-app/src/test/resources/runtimets/queries/dml/insert-return-records/insert-return-records.1.ddl.aql A asterixdb/asterix-app/src/test/resources/runtimets/queries/dml/insert-return-records/insert-return-records.3.query.aql A asterixdb/asterix-app/src/test/resources/runtimets/queries/dml/insert-returning-fieldname/insert-returning-fieldname.1.ddl.aql A asterixdb/asterix-app/src/test/resources/runtimets/queries/dml/insert-returning-fieldname/insert-returning-fieldname.3.query.aql A asterixdb/asterix-app/src/test/resources/runtimets/results/dml/insert-return-records/insert-return-records.1.adm A asterixdb/asterix-app/src/test/resources/runtimets/results/dml/insert-returning-fieldname/insert-returning-fieldname.1.adm M asterixdb/asterix-app/src/test/resources/runtimets/testsuite.xml R asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IActiveLifecycleEventSubscriber.java R asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/ActiveLifecycleEventSubscriber.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedEventsListener.java D asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedActivity.java A asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedActivityDetails.java M asterixdb/asterix-lang-aql/src/main/java/org/apache/asterix/lang/aql/statement/SubscribeFeedStatement.java M asterixdb/asterix-lang-aql/src/main/javacc/AQL.jj M asterixdb/asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/InsertStatement.java M asterixdb/asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/UpsertStatement.java M asterixdb/asterix-lang-sqlpp/src/main/javacc/SQLPP.jj M asterixdb/asterix-om/src/main/java/org/apache/asterix/om/base/ADateTime.java M asterixdb/asterix-om/src/main/java/org/apache/asterix/om/base/AUUID.java A asterixdb/asterix-opt/pom.xml A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/BADConstants.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/ChannelJobInfo.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/ChannelJobService.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/lang/BADCompilationProvider.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/lang/BADLangExtension.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/lang/BADParserFactory.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/lang/BADQueryTranslatorExtension.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/lang/BADQueryTranslatorFactory.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/lang/BADStatementExecutor.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/lang/statement/BrokerDropStatement.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/lang/statement/ChannelDropStatement.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/lang/statement/ChannelSubscribeStatement.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/lang/statement/ChannelUnsubscribeStatement.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/lang/statement/CreateBrokerStatement.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/metadata/BADMetadataExtension.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/metadata/BADMetadataIndexes.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/metadata/BADMetadataRecordTypes.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/metadata/Broker.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/metadata/BrokerSearchKey.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/metadata/BrokerTupleTranslator.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/metadata/Channel.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/metadata/ChannelEventsListener.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/metadata/ChannelSearchKey.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/metadata/ChannelTupleTranslator.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/rules/InsertBrokerNotifierForChannelRule.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerOperator.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerPOperator.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntime.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/runtime/NotifyBrokerRuntimeFactory.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/runtime/RepetitiveChannelOperatorDescriptor.java A asterixdb/asterix-opt/src/main/java/org/apache/asterix/bad/runtime/RepetitiveChannelOperatorNodePushable.java A asterixdb/asterix-opt/src/main/resources/lang-extension/lang.txt A asterixdb/asterix-opt/src/test/java/org/apache/asterix/bad/test/BADExecutionTest.java A asterixdb/asterix-opt/src/test/java/org/apache/asterix/bad/test/BADOptimizerTest.java A asterixdb/asterix-opt/src/test/resources/conf/asterix-build-configuration.xml A asterixdb/asterix-opt/src/test/resources/conf/cluster.xml A asterixdb/asterix-opt/src/test/resources/conf/hyracks-deployment.properties A asterixdb/asterix-opt/src/test/resources/conf/test.properties A asterixdb/asterix-opt/src/test/resources/optimizerts/queries/channel/channel-create.aql A asterixdb/asterix-opt/src/test/resources/optimizerts/queries/channel/channel-subscribe.aql A asterixdb/asterix-opt/src/test/resources/optimizerts/queries/channel/channel-unsubscribe.aql A asterixdb/asterix-opt/src/test/resources/optimizerts/results/channel/channel-create.plan A asterixdb/asterix-opt/src/test/resources/optimizerts/results/channel/channel-subscribe.plan A asterixdb/asterix-opt/src/test/resources/optimizerts/results/channel/channel-unsubscribe.plan A asterixdb/asterix-opt/src/test/resources/runtimets/queries/channel/create_channel_check_datasets/create_channel_check_datasets.1.ddl.aql A asterixdb/asterix-opt/src/test/resources/runtimets/queries/channel/create_channel_check_datasets/create_channel_check_datasets.2.update.aql A asterixdb/asterix-opt/src/test/resources/runtimets/queries/channel/create_channel_check_datasets/create_channel_check_datasets.3.query.aql A asterixdb/asterix-opt/src/test/resources/runtimets/queries/channel/create_channel_check_metadata/create_channel_check_metadata.1.ddl.aql A asterixdb/asterix-opt/src/test/resources/runtimets/queries/channel/create_channel_check_metadata/create_channel_check_metadata.2.update.aql A asterixdb/asterix-opt/src/test/resources/runtimets/queries/channel/create_channel_check_metadata/create_channel_check_metadata.3.query.aql A asterixdb/asterix-opt/src/test/resources/runtimets/queries/channel/drop_channel_check_datasets/drop_channel_check_datasets.1.ddl.aql A asterixdb/asterix-opt/src/test/resources/runtimets/queries/channel/drop_channel_check_datasets/drop_channel_check_datasets.2.update.aql A asterixdb/asterix-opt/src/test/resources/runtimets/queries/channel/drop_channel_check_datasets/drop_channel_check_datasets.3.query.aql A asterixdb/asterix-opt/src/test/resources/runtimets/queries/channel/drop_channel_check_metadata/drop_channel_check_metadata.1.ddl.aql A asterixdb/asterix-opt/src/test/resources/runtimets/queries/channel/drop_channel_check_metadata/drop_channel_check_metadata.2.update.aql A asterixdb/asterix-opt/src/test/resources/runtimets/queries/channel/drop_channel_check_metadata/drop_channel_check_metadata.3.query.aql A asterixdb/asterix-opt/src/test/resources/runtimets/queries/channel/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.1.ddl.aql A asterixdb/asterix-opt/src/test/resources/runtimets/queries/channel/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.2.update.aql A asterixdb/asterix-opt/src/test/resources/runtimets/queries/channel/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.3.query.aql A asterixdb/asterix-opt/src/test/resources/runtimets/results/channels/create_channel_check_datasets/create_channel_check_datasets.1.adm A asterixdb/asterix-opt/src/test/resources/runtimets/results/channels/create_channel_check_metadata/create_channel_check_metadata.1.adm A asterixdb/asterix-opt/src/test/resources/runtimets/results/channels/drop_channel_check_datasets/drop_channel_check_datasets.1.adm A asterixdb/asterix-opt/src/test/resources/runtimets/results/channels/drop_channel_check_metadata/drop_channel_check_metadata.1.adm A asterixdb/asterix-opt/src/test/resources/runtimets/results/channels/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.1.adm M asterixdb/asterix-server/pom.xml M asterixdb/pom.xml 115 files changed, 5,577 insertions(+), 562 deletions(-) git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb refs/changes/50/1150/1 -- To view, visit https://asterix-gerrit.ics.uci.edu/1150 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: newchange Gerrit-Change-Id: I65789d2a861d15232dd29156a6987d0635ec6c94 Gerrit-PatchSet: 1 Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Owner: Steven Jacobs <sjaco...@ucr.edu>
