Hello Jenkins,
I'd like you to reexamine a change. Please visit
https://asterix-gerrit.ics.uci.edu/644
to look at the new patch set (#3).
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 a few 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: I7ac820a08aa3c2225fffb230358c220d81f15908
---
A asterix-active/pom.xml
A asterix-active/src/main/java/org/apache/asterix/active/ActiveActivity.java
R asterix-active/src/main/java/org/apache/asterix/active/ActiveJobManager.java
R
asterix-active/src/main/java/org/apache/asterix/active/api/IActiveJobManager.java
A
asterix-active/src/main/java/org/apache/asterix/active/channel/ChannelActivity.java
R
asterix-active/src/main/java/org/apache/asterix/active/operators/FeedCollectOperatorDescriptor.java
R
asterix-active/src/main/java/org/apache/asterix/active/operators/FeedCollectOperatorNodePushable.java
R
asterix-active/src/main/java/org/apache/asterix/active/operators/FeedIntakeOperatorDescriptor.java
R
asterix-active/src/main/java/org/apache/asterix/active/operators/FeedIntakeOperatorNodePushable.java
R
asterix-active/src/main/java/org/apache/asterix/active/operators/FeedMessageOperatorDescriptor.java
R
asterix-active/src/main/java/org/apache/asterix/active/operators/FeedMessageOperatorNodePushable.java
R
asterix-active/src/main/java/org/apache/asterix/active/operators/FeedMetaComputeNodePushable.java
R
asterix-active/src/main/java/org/apache/asterix/active/operators/FeedMetaNodePushable.java
R
asterix-active/src/main/java/org/apache/asterix/active/operators/FeedMetaOperatorDescriptor.java
R
asterix-active/src/main/java/org/apache/asterix/active/operators/FeedMetaStoreNodePushable.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IAdapterRuntimeManager.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/ICentralFeedManager.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IExceptionHandler.java
R asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeed.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedFrameHandler.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedJoint.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedLifecycleEventSubscriber.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedLifecycleIntakeEventSubscriber.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedLifecycleListener.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedLoadManager.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedManager.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedMemoryComponent.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedMemoryManager.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedMessage.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedMessageService.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedMetadataManager.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedMetricCollector.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedOperatorOutputSideHandler.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedProvider.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedRuntime.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedService.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedSubscriptionManager.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedTrackingManager.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedWork.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedWorkEventListener.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFeedWorkManager.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFrameEventCallback.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFramePostProcessor.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IFramePreprocessor.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IIntakeProgressTracker.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/IMessageReceiver.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/ISubscribableRuntime.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/ISubscriberRuntime.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/api/ISubscriptionProvider.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/CollectTransformFeedFrameWriter.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/DataBucket.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/DataBucketPool.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/DistributeFeedFrameWriter.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FeedCollectRuntimeInputHandler.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FeedExceptionHandler.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameCache.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameCollector.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameDiscarder.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameHandlers.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameSpiller.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameTupleAccessor.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameTupleDecorator.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FeedRuntimeInputHandler.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FrameCollection.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FrameDistributor.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/FrameEventCallback.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/dataflow/StorageFrameHandler.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/management/FeedCollectInfo.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionId.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionRequest.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/management/FeedId.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/management/FeedInfo.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/management/FeedJointKey.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/management/FeedLifecycleEventSubscriber.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/management/FeedManager.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/management/FeedMemoryManager.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/management/FeedMetadataManager.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/management/FeedRuntimeManager.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/management/FeedSubscriptionManager.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/management/FeedWorkManager.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/message/EndFeedMessage.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/message/FeedCongestionMessage.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/message/FeedMessage.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/message/FeedMessageService.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/message/FeedReportMessage.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/message/FeedTupleCommitAckMessage.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/message/FeedTupleCommitResponseMessage.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/message/MessageListener.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/message/MessageReceiver.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/message/NodeReportMessage.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/message/PrepareStallMessage.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/message/RemoteSocketMessageListener.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/message/ScaleInReportMessage.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/message/SocketMessageListener.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/message/StorageReportFeedMessage.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/message/TerminateDataFlowMessage.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/message/ThrottlingEnabledFeedMessage.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/message/XAQLFeedMessage.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/policy/FeedPolicy.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/policy/FeedPolicyAccessor.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/policy/FeedPolicyEnforcer.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/runtime/AdapterExecutor.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/runtime/AdapterRuntimeManager.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/runtime/CollectionRuntime.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/runtime/FeedRuntime.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/runtime/FeedRuntimeId.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/runtime/IngestionRuntime.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/runtime/SubscribableFeedRuntimeId.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/runtime/SubscribableRuntime.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/watch/BasicMonitoredBuffer.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/watch/ComputeSideMonitoredBuffer.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/watch/FeedActivity.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/watch/FeedConnectJobInfo.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/watch/FeedIntakeInfo.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/watch/FeedJobInfo.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/watch/FeedMetricCollector.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/watch/IntakePartitionStatistics.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/watch/IntakeSideMonitoredBuffer.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/watch/MonitoredBuffer.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/watch/MonitoredBufferTimerTasks.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/watch/NodeLoad.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/watch/NodeLoadReport.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/watch/NodeLoadReportService.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/watch/Series.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/watch/SeriesAvg.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/watch/SeriesRate.java
R
asterix-active/src/main/java/org/apache/asterix/external/feed/watch/StorageSideMonitoredBuffer.java
M
asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/UnnestToDataScanRule.java
M asterix-app/pom.xml
M asterix-app/src/main/java/org/apache/asterix/api/http/servlet/FeedServlet.java
M
asterix-app/src/main/java/org/apache/asterix/feed/FeedJobNotificationHandler.java
M asterix-app/src/main/java/org/apache/asterix/feed/FeedLifecycleListener.java
M asterix-app/src/main/java/org/apache/asterix/feed/FeedLoadManager.java
M asterix-app/src/main/java/org/apache/asterix/file/FeedOperations.java
M
asterix-lang-aql/src/main/java/org/apache/asterix/lang/aql/statement/SubscribeFeedStatement.java
M asterix-metadata/pom.xml
M
asterix-metadata/src/main/java/org/apache/asterix/metadata/declared/AqlMetadataProvider.java
M
asterix-metadata/src/main/java/org/apache/asterix/metadata/feeds/FeedMetadataUtil.java
M pom.xml
139 files changed, 312 insertions(+), 145 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/44/644/3
--
To view, visit https://asterix-gerrit.ics.uci.edu/644
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: newpatchset
Gerrit-Change-Id: I7ac820a08aa3c2225fffb230358c220d81f15908
Gerrit-PatchSet: 3
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: Steven Jacobs <[email protected]>
Gerrit-Reviewer: Jenkins <[email protected]>
