You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@asterixdb.apache.org by "Steven Jacobs (Code Review)" <do...@asterixdb.incubator.apache.org> on 2016/05/05 17:59:17 UTC
Change in asterixdb[master]: Added Channels to Asterix

Hello Jenkins,

I'd like you to reexamine a change.  Please visit

    https://asterix-gerrit.ics.uci.edu/693

to look at the new patch set (#15).

Change subject: Added Channels to Asterix
......................................................................

Added Channels 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
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: I1ba31141e9e89e626a3fbe560e08b73e459af16a
---
A asterixdb/asterix-active/pom.xml
A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/ActiveActivity.java
C asterixdb/asterix-active/src/main/java/org/apache/asterix/active/ActiveConstants.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/active/ActiveEntityId.java
A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/ActiveJobId.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/active/ActiveJobInfo.java
A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/ActiveJobManager.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/active/ActiveJobsActivator.java
A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/ActiveLifecycleEventSubscriber.java
A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/api/IActiveJobManager.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/active/api/IActiveLifecycleEventSubscriber.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/active/api/IActiveMessage.java
A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/channel/ChannelActivity.java
A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/channel/ChannelJobInfo.java
A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/channel/ChannelRuntime.java
A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/channel/StoredJobRuntime.java
C asterixdb/asterix-active/src/main/java/org/apache/asterix/active/channel/api/IChannelJobService.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/active/operators/ActiveMessageOperatorDescriptor.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/active/operators/ActiveMessageOperatorNodePushable.java
A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/operators/ActiveMetaNodePushable.java
A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/operators/ActiveMetaOperatorDescriptor.java
A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/operators/ChannelMetaOperatorDescriptor.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/active/operators/FeedCollectOperatorDescriptor.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/active/operators/FeedCollectOperatorNodePushable.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/active/operators/FeedIntakeOperatorDescriptor.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/active/operators/FeedIntakeOperatorNodePushable.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/active/operators/FeedMetaComputeNodePushable.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/active/operators/FeedMetaNodePushable.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/active/operators/FeedMetaOperatorDescriptor.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/active/operators/FeedMetaStoreNodePushable.java
A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/operators/RepetitiveChannelOperatorDescriptor.java
A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/operators/RepetitiveChannelOperatorNodePushable.java
A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/operators/StoredJobOperatorDescriptor.java
A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/operators/StoredJobOperatorNodePushable.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/FeedOperationCounter.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IActiveLifecycleListener.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IActiveLoadManager.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IActiveManager.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IActiveRuntime.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IAdapterRuntimeManager.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/ICentralActiveManager.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IExceptionHandler.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeed.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedFrameHandler.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedJoint.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedLifecycleIntakeEventSubscriber.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedMemoryComponent.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedMemoryManager.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedMessageService.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedMetadataManager.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedMetricCollector.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedOperatorOutputSideHandler.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedProvider.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedService.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedSubscriptionManager.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedTrackingManager.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedWork.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedWorkEventListener.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedWorkManager.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFrameEventCallback.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFramePostProcessor.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFramePreprocessor.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IIntakeProgressTracker.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/IMessageReceiver.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/ISubscribableRuntime.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/ISubscriberRuntime.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/api/ISubscriptionProvider.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/ActiveRuntimeInputHandler.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/CollectTransformFeedFrameWriter.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/DataBucket.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/DataBucketPool.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/DistributeFeedFrameWriter.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FeedCollectRuntimeInputHandler.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FeedExceptionHandler.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameCache.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameCollector.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameDiscarder.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameHandlers.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameSpiller.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameTupleAccessor.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameTupleDecorator.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FrameCollection.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FrameDistributor.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FrameEventCallback.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/StorageFrameHandler.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/management/FeedCollectInfo.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionId.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionRequest.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/management/FeedJointKey.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/management/FeedMemoryManager.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/management/FeedMetadataManager.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/management/FeedRuntimeManager.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/management/FeedSubscriptionManager.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/management/FeedWorkManager.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/message/ActiveMessage.java
A asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/message/DropStoredJobOperatorMessage.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/message/EndFeedMessage.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/message/FeedCongestionMessage.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/message/FeedMessageService.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/message/FeedPartitionStartMessage.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/message/FeedReportMessage.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/message/FeedTupleCommitAckMessage.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/message/FeedTupleCommitResponseMessage.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/message/MessageListener.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/message/MessageReceiver.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/message/NodeReportMessage.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/message/PrepareStallMessage.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/message/RemoteSocketMessageListener.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/message/ScaleInReportMessage.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/message/SocketMessageListener.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/message/StorageReportFeedMessage.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/message/TerminateDataFlowMessage.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/message/ThrottlingEnabledFeedMessage.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/message/XAQLFeedMessage.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/policy/FeedPolicy.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/policy/FeedPolicyAccessor.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/policy/FeedPolicyEnforcer.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/runtime/ActiveRuntime.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/runtime/ActiveRuntimeId.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/runtime/AdapterExecutor.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/runtime/AdapterRuntimeManager.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/runtime/CollectionRuntime.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/runtime/IngestionRuntime.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/runtime/SubscribableFeedRuntimeId.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/runtime/SubscribableRuntime.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/watch/BasicMonitoredBuffer.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/watch/ComputeSideMonitoredBuffer.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/watch/FeedActivity.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/watch/FeedConnectJobInfo.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/watch/FeedIntakeInfo.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/watch/FeedMetricCollector.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/watch/IntakePartitionStatistics.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/watch/IntakeSideMonitoredBuffer.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/watch/MonitoredBuffer.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/watch/MonitoredBufferTimerTasks.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/watch/NodeLoad.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/watch/NodeLoadReport.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/watch/NodeLoadReportService.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/watch/Series.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/watch/SeriesAvg.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/watch/SeriesRate.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/feed/watch/StorageSideMonitoredBuffer.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/library/adapter/TestTypedAdapter.java
R asterixdb/asterix-active/src/main/java/org/apache/asterix/external/library/adapter/TestTypedAdapterFactory.java
A asterixdb/asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/ReplaceableSinkOperator.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/rules/ReplaceSinkOpWithCommitOpRule.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/translator/AqlPlusExpressionToPlanTranslator.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/pom.xml
M asterixdb/asterix-app/src/main/java/org/apache/asterix/api/common/AsterixAppRuntimeContext.java
M asterixdb/asterix-app/src/main/java/org/apache/asterix/api/http/servlet/ConnectorAPIServlet.java
M asterixdb/asterix-app/src/main/java/org/apache/asterix/api/http/servlet/DDLAPIServlet.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/api/http/servlet/FeedServletUtil.java
M asterixdb/asterix-app/src/main/java/org/apache/asterix/api/http/servlet/QueryAPIServlet.java
M asterixdb/asterix-app/src/main/java/org/apache/asterix/api/http/servlet/UpdateAPIServlet.java
R asterixdb/asterix-app/src/main/java/org/apache/asterix/app/external/ActiveJobNotificationHandler.java
R asterixdb/asterix-app/src/main/java/org/apache/asterix/app/external/ActiveLifecycleListener.java
R asterixdb/asterix-app/src/main/java/org/apache/asterix/app/external/ActiveManager.java
R asterixdb/asterix-app/src/main/java/org/apache/asterix/app/external/ActiveWorkRequestResponseHandler.java
R asterixdb/asterix-app/src/main/java/org/apache/asterix/app/external/CentralActiveManager.java
A asterixdb/asterix-app/src/main/java/org/apache/asterix/app/external/ChannelJobService.java
A asterixdb/asterix-app/src/main/java/org/apache/asterix/app/external/ChannelOperations.java
M asterixdb/asterix-app/src/main/java/org/apache/asterix/app/external/FeedJoint.java
M asterixdb/asterix-app/src/main/java/org/apache/asterix/app/external/FeedLoadManager.java
M asterixdb/asterix-app/src/main/java/org/apache/asterix/app/external/FeedMessageReceiver.java
M asterixdb/asterix-app/src/main/java/org/apache/asterix/app/external/FeedOperations.java
M asterixdb/asterix-app/src/main/java/org/apache/asterix/app/external/FeedTrackingManager.java
M asterixdb/asterix-app/src/main/java/org/apache/asterix/app/external/FeedWorkCollection.java
M asterixdb/asterix-app/src/main/java/org/apache/asterix/aql/translator/QueryTranslator.java
M asterixdb/asterix-app/src/main/java/org/apache/asterix/hyracks/bootstrap/CCApplicationEntryPoint.java
M asterixdb/asterix-app/src/main/java/org/apache/asterix/hyracks/bootstrap/FeedBootstrap.java
M asterixdb/asterix-app/src/main/java/org/apache/asterix/hyracks/bootstrap/GlobalRecoveryManager.java
M asterixdb/asterix-app/src/main/java/org/apache/asterix/messaging/CCMessageBroker.java
M asterixdb/asterix-app/src/test/java/org/apache/asterix/api/http/servlet/ConnectorAPIServletTest.java
M asterixdb/asterix-app/src/test/resources/metadata/results/basic/metadata_dataset/metadata_dataset.1.adm
M asterixdb/asterix-app/src/test/resources/metadata/results/basic/metadata_datatype/metadata_datatype.1.adm
M asterixdb/asterix-app/src/test/resources/metadata/results/basic/metadata_index/metadata_index.1.adm
M asterixdb/asterix-app/src/test/resources/metadata/results/basic/metadata_selfjoin/metadata_selfjoin.1.adm
A asterixdb/asterix-app/src/test/resources/optimizerts/queries/channels/channel-create.aql
A asterixdb/asterix-app/src/test/resources/optimizerts/queries/channels/channel-subscribe.aql
A asterixdb/asterix-app/src/test/resources/optimizerts/queries/channels/channel-unsubscribe.aql
A asterixdb/asterix-app/src/test/resources/optimizerts/results/channels/channel-create.plan
A asterixdb/asterix-app/src/test/resources/optimizerts/results/channels/channel-subscribe.plan
A asterixdb/asterix-app/src/test/resources/optimizerts/results/channels/channel-unsubscribe.plan
A asterixdb/asterix-app/src/test/resources/runtimets/queries/channels/create_channel_check_datasets/create_channel_check_datasets.1.ddl.aql
A asterixdb/asterix-app/src/test/resources/runtimets/queries/channels/create_channel_check_datasets/create_channel_check_datasets.2.update.aql
A asterixdb/asterix-app/src/test/resources/runtimets/queries/channels/create_channel_check_datasets/create_channel_check_datasets.3.query.aql
A asterixdb/asterix-app/src/test/resources/runtimets/queries/channels/create_channel_check_metadata/create_channel_check_metadata.1.ddl.aql
A asterixdb/asterix-app/src/test/resources/runtimets/queries/channels/create_channel_check_metadata/create_channel_check_metadata.2.update.aql
A asterixdb/asterix-app/src/test/resources/runtimets/queries/channels/create_channel_check_metadata/create_channel_check_metadata.3.query.aql
A asterixdb/asterix-app/src/test/resources/runtimets/queries/channels/drop_channel_check_datasets/drop_channel_check_datasets.1.ddl.aql
A asterixdb/asterix-app/src/test/resources/runtimets/queries/channels/drop_channel_check_datasets/drop_channel_check_datasets.2.update.aql
A asterixdb/asterix-app/src/test/resources/runtimets/queries/channels/drop_channel_check_datasets/drop_channel_check_datasets.3.query.aql
A asterixdb/asterix-app/src/test/resources/runtimets/queries/channels/drop_channel_check_metadata/drop_channel_check_metadata.1.ddl.aql
A asterixdb/asterix-app/src/test/resources/runtimets/queries/channels/drop_channel_check_metadata/drop_channel_check_metadata.2.update.aql
A asterixdb/asterix-app/src/test/resources/runtimets/queries/channels/drop_channel_check_metadata/drop_channel_check_metadata.3.query.aql
A asterixdb/asterix-app/src/test/resources/runtimets/queries/channels/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.1.ddl.aql
A asterixdb/asterix-app/src/test/resources/runtimets/queries/channels/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.2.update.aql
A asterixdb/asterix-app/src/test/resources/runtimets/queries/channels/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.3.query.aql
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/channels/create_channel_check_datasets/create_channel_check_datasets.1.adm
A asterixdb/asterix-app/src/test/resources/runtimets/results/channels/create_channel_check_metadata/create_channel_check_metadata.1.adm
A asterixdb/asterix-app/src/test/resources/runtimets/results/channels/drop_channel_check_datasets/drop_channel_check_datasets.1.adm
A asterixdb/asterix-app/src/test/resources/runtimets/results/channels/drop_channel_check_metadata/drop_channel_check_metadata.1.adm
A asterixdb/asterix-app/src/test/resources/runtimets/results/channels/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.1.adm
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/results/user-defined-functions/udf23/udf23.1.adm
M asterixdb/asterix-app/src/test/resources/runtimets/testsuite.xml
M asterixdb/asterix-common/src/main/java/org/apache/asterix/common/api/IAsterixAppRuntimeContext.java
D asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedConnectionManager.java
D asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionManager.java
D asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedInfo.java
D asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedLifecycleEventSubscriber.java
M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedConstants.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/base/Statement.java
A asterixdb/asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/BrokerDropStatement.java
A asterixdb/asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/ChannelDropStatement.java
A asterixdb/asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/ChannelSubscribeStatement.java
A asterixdb/asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/ChannelUnsubscribeStatement.java
A asterixdb/asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/CreateBrokerStatement.java
A asterixdb/asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/CreateChannelStatement.java
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-common/src/main/java/org/apache/asterix/lang/common/visitor/FormatPrintVisitor.java
M asterixdb/asterix-lang-common/src/main/java/org/apache/asterix/lang/common/visitor/base/AbstractQueryExpressionVisitor.java
M asterixdb/asterix-lang-common/src/main/java/org/apache/asterix/lang/common/visitor/base/ILangVisitor.java
M asterixdb/asterix-lang-sqlpp/src/main/javacc/SQLPP.jj
M asterixdb/asterix-metadata/pom.xml
M asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataCache.java
M asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataManager.java
M asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataNode.java
M asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataTransactionContext.java
M asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/api/IMetadataManager.java
M asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/api/IMetadataNode.java
M asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/bootstrap/MetadataBootstrap.java
M asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/bootstrap/MetadataIndexImmutableProperties.java
M asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/bootstrap/MetadataPrimaryIndexes.java
M asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/bootstrap/MetadataRecordTypes.java
M asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/declared/AqlMetadataProvider.java
M asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/declared/FeedDataSource.java
A asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/Broker.java
A asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/Channel.java
M asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/Feed.java
A asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/BrokerTupleTranslator.java
A asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/ChannelTupleTranslator.java
R asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/feeds/ActiveMetadataUtil.java
M asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/utils/MetadataLockManager.java
M asterixdb/pom.xml
M pom.xml
263 files changed, 6,777 insertions(+), 1,959 deletions(-)


  git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb refs/changes/93/693/15
-- 
To view, visit https://asterix-gerrit.ics.uci.edu/693
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings

Gerrit-MessageType: newpatchset
Gerrit-Change-Id: I1ba31141e9e89e626a3fbe560e08b73e459af16a
Gerrit-PatchSet: 15
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: Steven Jacobs <sj...@ucr.edu>
Gerrit-Reviewer: Ildar Absalyamov <il...@gmail.com>
Gerrit-Reviewer: Jenkins <je...@fulliautomatix.ics.uci.edu>
Gerrit-Reviewer: Steven Jacobs <sj...@ucr.edu>
Gerrit-Reviewer: Till Westmann <ti...@apache.org>
Gerrit-Reviewer: abdullah alamoudi <ba...@gmail.com>