abdullah alamoudi has uploaded a new change for review. https://asterix-gerrit.ics.uci.edu/977
Change subject: Refactor General Active Classes ...................................................................... Refactor General Active Classes This change is the first of a series of changes aiming to refactor feed related classes into generic active and feed specific. In this change, we introduce asterix-active which will be one level below asterix-external-data. The ultimate goal is to have a very flexible framewrok for long running activities within asterix. Change-Id: I0a8f33ee5b45c5e090b08c24a102e369aae43c04 --- A asterixdb/asterix-active/pom.xml A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/ActiveEvent.java A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/ActiveJob.java A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/ActiveJobNotificationHandler.java A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/ActiveManager.java R asterixdb/asterix-active/src/main/java/org/apache/asterix/active/ActiveRuntime.java A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/ActiveRuntimeId.java A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/ActiveRuntimeManager.java A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/ActiveRuntimeRegistry.java A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/Activity.java C asterixdb/asterix-active/src/main/java/org/apache/asterix/active/ActivityState.java R asterixdb/asterix-active/src/main/java/org/apache/asterix/active/ConcurrentFramePool.java A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/EntityId.java R asterixdb/asterix-active/src/main/java/org/apache/asterix/active/FrameAction.java C asterixdb/asterix-active/src/main/java/org/apache/asterix/active/IActiveEntityEventsListener.java C asterixdb/asterix-active/src/main/java/org/apache/asterix/active/IActiveJobBuilder.java R asterixdb/asterix-active/src/main/java/org/apache/asterix/active/IActiveMessage.java C asterixdb/asterix-active/src/main/java/org/apache/asterix/active/IActiveRuntime.java A asterixdb/asterix-active/src/main/java/org/apache/asterix/active/IActiveRuntimeRegistry.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/translator/CompiledStatements.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/FeedServlet.java A asterixdb/asterix-app/src/main/java/org/apache/asterix/app/external/ActiveLifecycleListener.java M asterixdb/asterix-app/src/main/java/org/apache/asterix/app/external/FeedJoint.java D asterixdb/asterix-app/src/main/java/org/apache/asterix/app/external/FeedLifecycleListener.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/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/messaging/CCMessageBroker.java M asterixdb/asterix-common/src/main/java/org/apache/asterix/common/messaging/api/IApplicationMessage.java M asterixdb/asterix-external-data/pom.xml M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/FeedOperationCounter.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeed.java D asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedConnectionManager.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedJoint.java D asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedLifecycleListener.java D asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedRuntime.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/ISubscribableRuntime.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/DistributeFeedFrameWriter.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedRuntimeInputHandler.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedCollectInfo.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionId.java D asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionManager.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionRequest.java R 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/management/FeedId.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedJointKey.java D asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedManager.java D asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedRuntimeManager.java R asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/ActivePartitionMessage.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/EndFeedMessage.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedMessage.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/AdapterRuntimeManager.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/CollectionRuntime.java D asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/FeedRuntimeId.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/IngestionRuntime.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/SubscribableRuntime.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedConnectJobInfo.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedIntakeInfo.java D asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedJobInfo.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedCollectOperatorDescriptor.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedCollectOperatorNodePushable.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedIntakeOperatorDescriptor.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedIntakeOperatorNodePushable.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMessageOperatorDescriptor.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMessageOperatorNodePushable.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaComputeNodePushable.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaOperatorDescriptor.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaStoreNodePushable.java M asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedUtils.java M asterixdb/asterix-external-data/src/test/java/org/apache/asterix/external/feed/test/ConcurrentFramePoolUnitTest.java M asterixdb/asterix-external-data/src/test/java/org/apache/asterix/external/feed/test/InputHandlerTest.java M asterixdb/asterix-lang-aql/src/main/java/org/apache/asterix/lang/aql/statement/SubscribeFeedStatement.java M asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/declared/FeedDataSource.java M asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/Feed.java M asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/feeds/FeedMetadataUtil.java M asterixdb/pom.xml 80 files changed, 2,065 insertions(+), 1,932 deletions(-) git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb refs/changes/77/977/1 -- To view, visit https://asterix-gerrit.ics.uci.edu/977 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: newchange Gerrit-Change-Id: I0a8f33ee5b45c5e090b08c24a102e369aae43c04 Gerrit-PatchSet: 1 Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Owner: abdullah alamoudi <[email protected]>
