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/02/11 23:51:46 UTC
Change in asterixdb[master]: Test gerrit submit
Steven Jacobs has uploaded a new change for review.
https://asterix-gerrit.ics.uci.edu/627
Change subject: Test gerrit submit
......................................................................
Test gerrit submit
Change-Id: I97a78b371e4b96cfec9f5668767a53eefbbc3cfd
---
A asterix-active/pom.xml
A asterix-active/src/main/java/org/apache/asterix/active/ActiveActivity.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveConnectionManager.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveJobId.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveJobInfo.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveJobsActivator.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveLifecycleEventSubscriber.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveObjectId.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveRuntimeId.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveRuntimeInputHandler.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveRuntimeManager.java
A asterix-active/src/main/java/org/apache/asterix/active/adapter/AdapterFactoryProvider.java
A asterix-active/src/main/java/org/apache/asterix/active/adapter/DatasourceFactoryProvider.java
A asterix-active/src/main/java/org/apache/asterix/active/adapter/GenericAdapter.java
A asterix-active/src/main/java/org/apache/asterix/active/adapter/GenericAdapterFactory.java
A asterix-active/src/main/java/org/apache/asterix/active/api/IActiveConnectionManager.java
A asterix-active/src/main/java/org/apache/asterix/active/api/IActiveLifecycleEventSubscriber.java
A asterix-active/src/main/java/org/apache/asterix/active/api/IActiveLoadManager.java
A asterix-active/src/main/java/org/apache/asterix/active/api/IActiveManager.java
A asterix-active/src/main/java/org/apache/asterix/active/api/IActiveMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/api/IActiveRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/api/ICentralActiveManager.java
A asterix-active/src/main/java/org/apache/asterix/active/channel/ChannelActivity.java
A asterix-active/src/main/java/org/apache/asterix/active/channel/ChannelRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/channel/ProcedureJobInfo.java
A asterix-active/src/main/java/org/apache/asterix/active/channel/ProcedureRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/channel/ProcedureRuntimeId.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IAdapterRuntimeManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IExceptionHandler.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeed.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedAdapter.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedFrameHandler.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedJoint.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedLifecycleIntakeEventSubscriber.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedLifecycleListener.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedMemoryComponent.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedMemoryManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedMessageService.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedMetadataManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedMetricCollector.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedOperatorOutputSideHandler.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedProvider.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedService.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedSubscriptionManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedTrackingManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedWork.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedWorkEventListener.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedWorkManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFrameEventCallback.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFramePostProcessor.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFramePreprocessor.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IIntakeProgressTracker.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IMessageReceiver.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/ISubscribableRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/ISubscriberRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/ISubscriptionProvider.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/CollectTransformFeedFrameWriter.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/DataBucket.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/DataBucketPool.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/DistributeFeedFrameWriter.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedCollectRuntimeInputHandler.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedExceptionHandler.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedFrameCache.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedFrameCollector.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedFrameDiscarder.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedFrameHandlers.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedFrameSpiller.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedFrameTupleAccessor.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedFrameTupleDecorator.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FrameCollection.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FrameDistributor.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FrameEventCallback.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/StorageFrameHandler.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/filesystem/FileSystemWatcher.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/filesystem/LocalFSInputStreamProvider.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/filesystem/LocalFSInputStreamProviderFactory.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/filesystem/LocalFileSystemInputStream.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedCollectInfo.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedConnectionId.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedConnectionRequest.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedConstants.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedFrameUtil.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedJointKey.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedLogManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedMemoryManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedMetadataManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedSubscriptionManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedUtils.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedWorkManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/ActiveMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/DropChannelMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/EndFeedMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/ExecuteProcedureMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/FeedCongestionMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/FeedMessageService.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/FeedReportMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/FeedTupleCommitAckMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/FeedTupleCommitResponseMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/MessageListener.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/MessageReceiver.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/NodeReportMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/PrepareStallMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/RemoteSocketMessageListener.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/RepetitiveChannelXAQLMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/ScaleInReportMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/SocketMessageListener.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/StorageReportFeedMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/TerminateDataFlowMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/ThrottlingEnabledFeedMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/XAQLFeedMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/policy/FeedPolicy.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/policy/FeedPolicyAccessor.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/policy/FeedPolicyEnforcer.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/runtime/AdapterExecutor.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/runtime/AdapterRuntimeManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/runtime/CollectionRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/runtime/IngestionRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/runtime/SubscribableFeedRuntimeId.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/runtime/SubscribableRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/BasicMonitoredBuffer.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/ComputeSideMonitoredBuffer.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/FeedActivity.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/FeedConnectJobInfo.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/FeedIntakeInfo.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/FeedMetricCollector.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/IntakePartitionStatistics.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/IntakeSideMonitoredBuffer.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/MonitoredBuffer.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/MonitoredBufferTimerTasks.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/NodeLoad.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/NodeLoadReport.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/NodeLoadReportService.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/Series.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/SeriesAvg.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/SeriesRate.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/StorageSideMonitoredBuffer.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/ActiveMessageOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/ActiveMessageOperatorNodePushable.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/ActiveMetaNodePushable.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/ActiveMetaOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/ChannelMetaOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/ExternalDataScanOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/FeedCollectOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/FeedCollectOperatorNodePushable.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/FeedIntakeOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/FeedIntakeOperatorNodePushable.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/FeedMetaComputeNodePushable.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/FeedMetaStoreNodePushable.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/ProcedureMetaNodePushable.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/ProcedureMetaOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/RepetitiveChannelOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/RepetitiveChannelOperatorNodePushable.java
A asterix-active/src/test/java/org/apache/asterix/external/library/adapter/TestTypedAdapter.java
R asterix-active/src/test/java/org/apache/asterix/external/library/adapter/TestTypedAdapterFactory.java
A asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/ReplaceableSinkOperator.java
M asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/physical/CommitPOperator.java
M asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/physical/CommitRuntime.java
M asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/physical/CommitRuntimeFactory.java
M asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/physical/UpsertCommitRuntime.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/AsterixIntroduceGroupByCombinerRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/CheckFilterExpressionTypeRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/CountVarToCountOneRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/DisjunctivePredicateToJoinRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/ExtractDistinctByExpressionsRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/ExtractOrderExpressionsRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/InlineUnnestFunctionRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceDynamicTypeCastForExternalFunctionRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceEnforcedListTypeRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceInstantLockSearchCallbackRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceMaterializationForInsertWithSelfScanRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceRandomPartitioningFeedComputationRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceRapidFrameFlushProjectAssignRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceSecondaryIndexInsertDeleteRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceStaticTypeCastForInsertRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceTransactionCommitByAssignOpRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceUnionRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/LoadRecordFieldsRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/NestGroupByRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/PushAggFuncIntoStandaloneAggregateRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/PushAggregateIntoGroupbyRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/PushProperJoinThroughProduct.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/RemoveRedundantSelectRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/RemoveSortInFeedIngestionRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/ReplaceSinkOpWithCommitOpRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/SetAsterixPhysicalOperatorsRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/UnnestToDataScanRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/AbstractIntroduceAccessMethodRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/AccessMethodAnalysisContext.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/AccessMethodJobGenParams.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/BTreeJobGenParams.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/IntroduceJoinAccessMethodRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/InvertedIndexJobGenParams.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/RTreeJobGenParams.java
M asterix-algebra/src/main/java/org/apache/asterix/translator/AqlExpressionToPlanTranslator.java
M asterix-algebra/src/main/java/org/apache/asterix/translator/AqlPlusExpressionToPlanTranslator.java
M asterix-algebra/src/main/java/org/apache/asterix/translator/CompiledStatements.java
M asterix-algebra/src/main/java/org/apache/asterix/translator/LangExpressionToPlanTranslator.java
M asterix-app/data/csv/sample_01.csv
M asterix-app/pom.xml
A asterix-app/src/main/java/org/apache/asterix/active/ActiveJobLifecycleListener.java
A asterix-app/src/main/java/org/apache/asterix/active/ActiveJobNotificationHandler.java
A asterix-app/src/main/java/org/apache/asterix/active/ActiveLoadManager.java
A asterix-app/src/main/java/org/apache/asterix/active/ActiveManager.java
A asterix-app/src/main/java/org/apache/asterix/active/ActiveWorkRequestResponseHandler.java
A asterix-app/src/main/java/org/apache/asterix/active/CentralActiveManager.java
A asterix-app/src/main/java/org/apache/asterix/active/FeedJoint.java
A asterix-app/src/main/java/org/apache/asterix/active/FeedMessageReceiver.java
A asterix-app/src/main/java/org/apache/asterix/active/FeedTrackingManager.java
A asterix-app/src/main/java/org/apache/asterix/active/FeedWorkCollection.java
M asterix-app/src/main/java/org/apache/asterix/api/common/AsterixAppRuntimeContext.java
M asterix-app/src/main/java/org/apache/asterix/api/common/SessionConfig.java
M asterix-app/src/main/java/org/apache/asterix/api/http/servlet/ConnectorAPIServlet.java
M asterix-app/src/main/java/org/apache/asterix/api/http/servlet/DDLAPIServlet.java
M asterix-app/src/main/java/org/apache/asterix/api/http/servlet/FeedServlet.java
M asterix-app/src/main/java/org/apache/asterix/api/http/servlet/FeedServletUtil.java
M asterix-app/src/main/java/org/apache/asterix/api/http/servlet/QueryStatusAPIServlet.java
M asterix-app/src/main/java/org/apache/asterix/api/http/servlet/UpdateAPIServlet.java
M asterix-app/src/main/java/org/apache/asterix/aql/translator/QueryTranslator.java
D asterix-app/src/main/java/org/apache/asterix/feed/CentralFeedManager.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedJobNotificationHandler.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedJoint.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedLifecycleListener.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedLoadManager.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedMessageReceiver.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedTrackingManager.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedWorkCollection.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedWorkRequestResponseHandler.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedsActivator.java
M asterix-app/src/main/java/org/apache/asterix/file/ExternalIndexingOperations.java
M asterix-app/src/main/java/org/apache/asterix/file/FeedOperations.java
A asterix-app/src/main/java/org/apache/asterix/file/ProcedureOperations.java
M asterix-app/src/main/java/org/apache/asterix/file/SecondaryBTreeOperationsHelper.java
M asterix-app/src/main/java/org/apache/asterix/file/SecondaryIndexOperationsHelper.java
M asterix-app/src/main/java/org/apache/asterix/file/SecondaryRTreeOperationsHelper.java
M asterix-app/src/main/java/org/apache/asterix/hyracks/bootstrap/CCApplicationEntryPoint.java
M asterix-app/src/main/java/org/apache/asterix/hyracks/bootstrap/FeedBootstrap.java
M asterix-app/src/main/java/org/apache/asterix/hyracks/bootstrap/GlobalRecoveryManager.java
M asterix-app/src/test/java/org/apache/asterix/api/http/servlet/ConnectorAPIServletTest.java
M asterix-app/src/test/java/org/apache/asterix/test/aql/AQLTestSuite.java
M asterix-app/src/test/java/org/apache/asterix/test/runtime/RepeatedTest.java
M asterix-app/src/test/resources/metadata/results/basic/metadata_dataset/metadata_dataset.1.adm
M asterix-app/src/test/resources/metadata/results/basic/metadata_datatype/metadata_datatype.1.adm
M asterix-app/src/test/resources/metadata/results/basic/metadata_index/metadata_index.1.adm
A asterix-app/src/test/resources/optimizerts/queries/channels/channel-create.aql
A asterix-app/src/test/resources/optimizerts/queries/channels/channel-subscribe.aql
A asterix-app/src/test/resources/optimizerts/queries/channels/channel-unsubscribe.aql
A asterix-app/src/test/resources/optimizerts/results/channels/channel-create.plan
A asterix-app/src/test/resources/optimizerts/results/channels/channel-subscribe.plan
A asterix-app/src/test/resources/optimizerts/results/channels/channel-unsubscribe.plan
A asterix-app/src/test/resources/runtimets/queries/channels/create_channel_check_datasets/create_channel_check_datasets.1.ddl.aql
A asterix-app/src/test/resources/runtimets/queries/channels/create_channel_check_datasets/create_channel_check_datasets.2.update.aql
A asterix-app/src/test/resources/runtimets/queries/channels/create_channel_check_datasets/create_channel_check_datasets.3.query.aql
A asterix-app/src/test/resources/runtimets/queries/channels/create_channel_check_metadata/create_channel_check_metadata.1.ddl.aql
A asterix-app/src/test/resources/runtimets/queries/channels/create_channel_check_metadata/create_channel_check_metadata.2.update.aql
A asterix-app/src/test/resources/runtimets/queries/channels/create_channel_check_metadata/create_channel_check_metadata.3.query.aql
A asterix-app/src/test/resources/runtimets/queries/channels/drop_channel_check_datasets/drop_channel_check_datasets.1.ddl.aql
A asterix-app/src/test/resources/runtimets/queries/channels/drop_channel_check_datasets/drop_channel_check_datasets.2.update.aql
A asterix-app/src/test/resources/runtimets/queries/channels/drop_channel_check_datasets/drop_channel_check_datasets.3.query.aql
A asterix-app/src/test/resources/runtimets/queries/channels/drop_channel_check_metadata/drop_channel_check_metadata.1.ddl.aql
A asterix-app/src/test/resources/runtimets/queries/channels/drop_channel_check_metadata/drop_channel_check_metadata.2.update.aql
A asterix-app/src/test/resources/runtimets/queries/channels/drop_channel_check_metadata/drop_channel_check_metadata.3.query.aql
A asterix-app/src/test/resources/runtimets/queries/channels/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.1.ddl.aql
A asterix-app/src/test/resources/runtimets/queries/channels/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.2.update.aql
A asterix-app/src/test/resources/runtimets/queries/channels/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.3.query.aql
A asterix-app/src/test/resources/runtimets/queries/dml/insert-return-records/insert-return-records.1.ddl.aql
A asterix-app/src/test/resources/runtimets/queries/dml/insert-return-records/insert-return-records.2.update.aql
A asterix-app/src/test/resources/runtimets/queries/dml/insert-return-records/insert-return-records.3.query.aql
A asterix-app/src/test/resources/runtimets/queries/dml/insert-returning-fieldname/insert-returning-fieldname.1.ddl.aql
A asterix-app/src/test/resources/runtimets/queries/dml/insert-returning-fieldname/insert-returning-fieldname.2.update.aql
A asterix-app/src/test/resources/runtimets/queries/dml/insert-returning-fieldname/insert-returning-fieldname.3.query.aql
A asterix-app/src/test/resources/runtimets/results/channels/create_channel_check_datasets/create_channel_check_datasets.1.adm
A asterix-app/src/test/resources/runtimets/results/channels/create_channel_check_metadata/create_channel_check_metadata.1.adm
A asterix-app/src/test/resources/runtimets/results/channels/drop_channel_check_datasets/drop_channel_check_datasets.1.adm
A asterix-app/src/test/resources/runtimets/results/channels/drop_channel_check_metadata/drop_channel_check_metadata.1.adm
A asterix-app/src/test/resources/runtimets/results/channels/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.1.adm
A asterix-app/src/test/resources/runtimets/results/dml/insert-return-records/insert-return-records.1.adm
A asterix-app/src/test/resources/runtimets/results/dml/insert-returning-fieldname/insert-returning-fieldname.1.adm
M asterix-app/src/test/resources/runtimets/results/user-defined-functions/udf23/udf23.1.adm
M asterix-app/src/test/resources/runtimets/testsuite.xml
M asterix-common/src/main/java/org/apache/asterix/common/api/IAsterixAppRuntimeContext.java
M asterix-common/src/main/java/org/apache/asterix/common/messaging/api/ICCMessageBroker.java
D asterix-external-data/src/main/java/org/apache/asterix/external/adapter/factory/GenericAdapterFactory.java
D asterix-external-data/src/main/java/org/apache/asterix/external/api/IAdapterRuntimeManager.java
M asterix-external-data/src/main/java/org/apache/asterix/external/api/IDataParser.java
D asterix-external-data/src/main/java/org/apache/asterix/external/api/IFeedAdapter.java
D asterix-external-data/src/main/java/org/apache/asterix/external/dataset/adapter/GenericAdapter.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/ICentralFeedManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IExceptionHandler.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeed.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedConnectionManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedFrameHandler.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedJoint.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedLifecycleEventSubscriber.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedLifecycleIntakeEventSubscriber.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedLifecycleListener.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedLoadManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMemoryComponent.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMemoryManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMessageService.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMetadataManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMetricCollector.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedOperatorOutputSideHandler.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedProvider.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedRuntime.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedService.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedSubscriptionManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedTrackingManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedWork.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedWorkEventListener.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedWorkManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFrameEventCallback.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFramePostProcessor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFramePreprocessor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IIntakeProgressTracker.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IMessageReceiver.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/ISubscribableRuntime.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/ISubscriberRuntime.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/ISubscriptionProvider.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/CollectTransformFeedFrameWriter.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/DataBucket.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/DataBucketPool.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/DistributeFeedFrameWriter.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedCollectRuntimeInputHandler.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedExceptionHandler.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameCache.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameCollector.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameDiscarder.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameHandlers.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameSpiller.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameTupleAccessor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameTupleDecorator.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedRuntimeInputHandler.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FrameCollection.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FrameDistributor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FrameEventCallback.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/StorageFrameHandler.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedCollectInfo.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionId.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionRequest.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedId.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedInfo.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedJointKey.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedLifecycleEventSubscriber.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedMemoryManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedMetadataManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedRuntimeManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedSubscriptionManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedWorkManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/EndFeedMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedCongestionMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedMessageService.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedReportMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedTupleCommitAckMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedTupleCommitResponseMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/MessageListener.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/MessageReceiver.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/NodeReportMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/PrepareStallMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/RemoteSocketMessageListener.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/ScaleInReportMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/SocketMessageListener.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/StorageReportFeedMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/TerminateDataFlowMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/ThrottlingEnabledFeedMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/XAQLFeedMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/policy/FeedPolicy.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/policy/FeedPolicyAccessor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/policy/FeedPolicyEnforcer.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/AdapterExecutor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/AdapterRuntimeManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/CollectionRuntime.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/FeedRuntime.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/FeedRuntimeId.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/IngestionRuntime.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/SubscribableFeedRuntimeId.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/SubscribableRuntime.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/BasicMonitoredBuffer.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/ComputeSideMonitoredBuffer.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedActivity.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedConnectJobInfo.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedIntakeInfo.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedJobInfo.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedMetricCollector.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/IntakePartitionStatistics.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/IntakeSideMonitoredBuffer.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/MonitoredBuffer.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/MonitoredBufferTimerTasks.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/NodeLoad.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/NodeLoadReport.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/NodeLoadReportService.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/Series.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/SeriesAvg.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/SeriesRate.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/StorageSideMonitoredBuffer.java
M asterix-external-data/src/main/java/org/apache/asterix/external/input/HDFSDataSourceFactory.java
D asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/LocalFileSystemInputStream.java
D asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/factory/LocalFSInputStreamProviderFactory.java
D asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/provider/LocalFSInputStreamProvider.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalDataScanOperatorDescriptor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedCollectOperatorDescriptor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedCollectOperatorNodePushable.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedIntakeOperatorDescriptor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedIntakeOperatorNodePushable.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMessageOperatorDescriptor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMessageOperatorNodePushable.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaComputeNodePushable.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaNodePushable.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaOperatorDescriptor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaStoreNodePushable.java
M asterix-external-data/src/main/java/org/apache/asterix/external/parser/factory/HiveDataParserFactory.java
D asterix-external-data/src/main/java/org/apache/asterix/external/provider/AdapterFactoryProvider.java
D asterix-external-data/src/main/java/org/apache/asterix/external/provider/DatasourceFactoryProvider.java
M asterix-external-data/src/main/java/org/apache/asterix/external/util/ExternalDataConstants.java
M asterix-external-data/src/main/java/org/apache/asterix/external/util/ExternalDataUtils.java
D asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedConstants.java
D asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedFrameUtil.java
D asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedLogManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedUtils.java
D asterix-external-data/src/main/java/org/apache/asterix/external/util/FileSystemWatcher.java
M asterix-external-data/src/main/java/org/apache/asterix/external/util/TwitterUtil.java
M asterix-external-data/src/test/java/org/apache/asterix/external/library/AddHashTagsFunction.java
M asterix-external-data/src/test/java/org/apache/asterix/external/library/AddHashTagsInPlaceFunction.java
M asterix-external-data/src/test/java/org/apache/asterix/external/library/AllTypesFunction.java
M asterix-external-data/src/test/java/org/apache/asterix/external/library/CapitalFinderFunction.java
M asterix-external-data/src/test/java/org/apache/asterix/external/library/ParseTweetFunction.java
D asterix-external-data/src/test/java/org/apache/asterix/external/library/adapter/TestTypedAdapter.java
M asterix-lang-aql/src/main/java/org/apache/asterix/lang/aql/statement/SubscribeFeedStatement.java
M asterix-lang-aql/src/main/javacc/AQL.jj
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/base/Statement.java
A asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/BrokerDropStatement.java
A asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/ChannelDropStatement.java
A asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/ChannelSubscribeStatement.java
A asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/ChannelUnsubscribeStatement.java
A asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/CreateBrokerStatement.java
A asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/CreateChannelStatement.java
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/CreateFunctionStatement.java
A asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/ExecuteProcedureStatement.java
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/FunctionDropStatement.java
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/InsertStatement.java
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/UpsertStatement.java
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/visitor/FormatPrintVisitor.java
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/visitor/GatherFunctionCallsVisitor.java
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/visitor/base/AbstractQueryExpressionVisitor.java
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/visitor/base/ILangVisitor.java
M asterix-lang-sqlpp/src/main/javacc/SQLPP.jj
M asterix-metadata/pom.xml
M asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataCache.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataManager.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataNode.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataTransactionContext.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/api/IMetadataManager.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/api/IMetadataNode.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/bootstrap/MetadataBootstrap.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/bootstrap/MetadataIndexImmutableProperties.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/bootstrap/MetadataPrimaryIndexes.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/bootstrap/MetadataRecordTypes.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/declared/AqlMetadataProvider.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/declared/DatasetDataSource.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/declared/FeedDataSource.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/declared/LoadableDataSource.java
A asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/Broker.java
A asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/Channel.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/Feed.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/FeedPolicyEntity.java
A asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/BrokerTupleTranslator.java
A asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/ChannelTupleTranslator.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/FeedTupleTranslator.java
A asterix-metadata/src/main/java/org/apache/asterix/metadata/feeds/ActiveUtil.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/feeds/BuiltinFeedPolicies.java
D asterix-metadata/src/main/java/org/apache/asterix/metadata/feeds/FeedMetadataUtil.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/utils/MetadataLockManager.java
M asterix-runtime/src/main/java/org/apache/asterix/runtime/formats/NonTaggedDataFormat.java
M pom.xml
479 files changed, 23,424 insertions(+), 18,204 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb refs/changes/27/627/1
--
To view, visit https://asterix-gerrit.ics.uci.edu/627
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: I97a78b371e4b96cfec9f5668767a53eefbbc3cfd
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: Steven Jacobs <sj...@ucr.edu>
Change in asterixdb[master]: Added Channels to Asterix
Posted by "Jenkins (Code Review)" <do...@asterixdb.incubator.apache.org>.
Jenkins has posted comments on this change.
Change subject: Added Channels to Asterix
......................................................................
Patch Set 3: Verified-1
Build Unstable
https://asterix-jenkins.ics.uci.edu/job/asterix-gerrit-notopic/830/ : UNSTABLE
--
To view, visit https://asterix-gerrit.ics.uci.edu/627
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: comment
Gerrit-Change-Id: I97a78b371e4b96cfec9f5668767a53eefbbc3cfd
Gerrit-PatchSet: 3
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: Steven Jacobs <sj...@ucr.edu>
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>
Gerrit-HasComments: No
Change in asterixdb[master]: Added Channels to Asterix
Posted by "Steven Jacobs (Code Review)" <do...@asterixdb.incubator.apache.org>.
Hello Jenkins,
I'd like you to reexamine a change. Please visit
https://asterix-gerrit.ics.uci.edu/627
to look at the new patch set (#2).
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]
Instrumented Procedures
Made the syntax for procedures available
1. create procedure (same as create function)
2. execute procedure()
3. drop procedure (same as drop function)
Only works for insert procedures
Not optimized
Currently saves the jobspec and runs the spec on execute
Change-Id: I97a78b371e4b96cfec9f5668767a53eefbbc3cfd
---
A asterix-active/pom.xml
A asterix-active/src/main/java/org/apache/asterix/active/ActiveActivity.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveConnectionManager.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveJobId.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveJobInfo.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveJobsActivator.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveLifecycleEventSubscriber.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveObjectId.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveRuntimeId.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveRuntimeInputHandler.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveRuntimeManager.java
A asterix-active/src/main/java/org/apache/asterix/active/adapter/AdapterFactoryProvider.java
A asterix-active/src/main/java/org/apache/asterix/active/adapter/DatasourceFactoryProvider.java
A asterix-active/src/main/java/org/apache/asterix/active/adapter/GenericAdapter.java
A asterix-active/src/main/java/org/apache/asterix/active/adapter/GenericAdapterFactory.java
A asterix-active/src/main/java/org/apache/asterix/active/api/IActiveConnectionManager.java
A asterix-active/src/main/java/org/apache/asterix/active/api/IActiveLifecycleEventSubscriber.java
A asterix-active/src/main/java/org/apache/asterix/active/api/IActiveLoadManager.java
A asterix-active/src/main/java/org/apache/asterix/active/api/IActiveManager.java
A asterix-active/src/main/java/org/apache/asterix/active/api/IActiveMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/api/IActiveRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/api/ICentralActiveManager.java
A asterix-active/src/main/java/org/apache/asterix/active/channel/ChannelActivity.java
A asterix-active/src/main/java/org/apache/asterix/active/channel/ChannelRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/channel/ProcedureJobInfo.java
A asterix-active/src/main/java/org/apache/asterix/active/channel/StoredJobRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IAdapterRuntimeManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IExceptionHandler.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeed.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedAdapter.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedFrameHandler.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedJoint.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedLifecycleIntakeEventSubscriber.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedLifecycleListener.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedMemoryComponent.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedMemoryManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedMessageService.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedMetadataManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedMetricCollector.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedOperatorOutputSideHandler.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedProvider.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedService.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedSubscriptionManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedTrackingManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedWork.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedWorkEventListener.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedWorkManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFrameEventCallback.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFramePostProcessor.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFramePreprocessor.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IIntakeProgressTracker.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IMessageReceiver.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/ISubscribableRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/ISubscriberRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/ISubscriptionProvider.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/CollectTransformFeedFrameWriter.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/DataBucket.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/DataBucketPool.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/DistributeFeedFrameWriter.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedCollectRuntimeInputHandler.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedExceptionHandler.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedFrameCache.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedFrameCollector.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedFrameDiscarder.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedFrameHandlers.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedFrameSpiller.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedFrameTupleAccessor.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedFrameTupleDecorator.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FrameCollection.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FrameDistributor.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FrameEventCallback.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/StorageFrameHandler.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/filesystem/FileSystemWatcher.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/filesystem/LocalFSInputStreamProvider.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/filesystem/LocalFSInputStreamProviderFactory.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/filesystem/LocalFileSystemInputStream.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedCollectInfo.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedConnectionId.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedConnectionRequest.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedConstants.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedFrameUtil.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedJointKey.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedLogManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedMemoryManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedMetadataManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedSubscriptionManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedUtils.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedWorkManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/ActiveMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/DropStoredJobOperatorMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/EndFeedMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/ExecuteProcedureMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/FeedCongestionMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/FeedMessageService.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/FeedReportMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/FeedTupleCommitAckMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/FeedTupleCommitResponseMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/MessageListener.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/MessageReceiver.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/NodeReportMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/PrepareStallMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/RemoteSocketMessageListener.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/RepetitiveChannelXAQLMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/ScaleInReportMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/SocketMessageListener.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/StorageReportFeedMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/TerminateDataFlowMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/ThrottlingEnabledFeedMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/XAQLFeedMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/policy/FeedPolicy.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/policy/FeedPolicyAccessor.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/policy/FeedPolicyEnforcer.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/runtime/AdapterExecutor.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/runtime/AdapterRuntimeManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/runtime/CollectionRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/runtime/IngestionRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/runtime/SubscribableFeedRuntimeId.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/runtime/SubscribableRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/BasicMonitoredBuffer.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/ComputeSideMonitoredBuffer.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/FeedActivity.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/FeedConnectJobInfo.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/FeedIntakeInfo.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/FeedMetricCollector.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/IntakePartitionStatistics.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/IntakeSideMonitoredBuffer.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/MonitoredBuffer.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/MonitoredBufferTimerTasks.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/NodeLoad.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/NodeLoadReport.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/NodeLoadReportService.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/Series.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/SeriesAvg.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/SeriesRate.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/StorageSideMonitoredBuffer.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/ActiveMessageOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/ActiveMessageOperatorNodePushable.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/ActiveMetaNodePushable.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/ActiveMetaOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/ChannelMetaOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/ExternalDataScanOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/FeedCollectOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/FeedCollectOperatorNodePushable.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/FeedIntakeOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/FeedIntakeOperatorNodePushable.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/FeedMetaComputeNodePushable.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/FeedMetaOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/FeedMetaStoreNodePushable.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/ProcedureMetaOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/RepetitiveChannelOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/RepetitiveChannelOperatorNodePushable.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/StoredJobOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/StoredJobOperatorNodePushable.java
A asterix-active/src/test/java/org/apache/asterix/external/library/adapter/TestTypedAdapter.java
R asterix-active/src/test/java/org/apache/asterix/external/library/adapter/TestTypedAdapterFactory.java
A asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/ReplaceableSinkOperator.java
M asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/physical/CommitPOperator.java
M asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/physical/CommitRuntime.java
M asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/physical/CommitRuntimeFactory.java
M asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/physical/UpsertCommitRuntime.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/AsterixIntroduceGroupByCombinerRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/CheckFilterExpressionTypeRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/CountVarToCountOneRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/DisjunctivePredicateToJoinRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/ExtractDistinctByExpressionsRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/ExtractOrderExpressionsRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/InlineUnnestFunctionRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceDynamicTypeCastForExternalFunctionRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceEnforcedListTypeRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceInstantLockSearchCallbackRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceMaterializationForInsertWithSelfScanRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceRandomPartitioningFeedComputationRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceRapidFrameFlushProjectAssignRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceSecondaryIndexInsertDeleteRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceStaticTypeCastForInsertRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceTransactionCommitByAssignOpRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceUnionRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/LoadRecordFieldsRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/NestGroupByRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/PushAggFuncIntoStandaloneAggregateRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/PushAggregateIntoGroupbyRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/PushProperJoinThroughProduct.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/RemoveRedundantSelectRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/RemoveSortInFeedIngestionRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/ReplaceSinkOpWithCommitOpRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/SetAsterixPhysicalOperatorsRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/UnnestToDataScanRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/AbstractIntroduceAccessMethodRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/AccessMethodAnalysisContext.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/AccessMethodJobGenParams.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/BTreeJobGenParams.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/IntroduceJoinAccessMethodRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/InvertedIndexJobGenParams.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/RTreeJobGenParams.java
M asterix-algebra/src/main/java/org/apache/asterix/translator/AqlExpressionToPlanTranslator.java
M asterix-algebra/src/main/java/org/apache/asterix/translator/AqlPlusExpressionToPlanTranslator.java
M asterix-algebra/src/main/java/org/apache/asterix/translator/CompiledStatements.java
M asterix-algebra/src/main/java/org/apache/asterix/translator/LangExpressionToPlanTranslator.java
M asterix-app/data/csv/sample_01.csv
M asterix-app/pom.xml
A asterix-app/src/main/java/org/apache/asterix/active/ActiveJobLifecycleListener.java
A asterix-app/src/main/java/org/apache/asterix/active/ActiveJobNotificationHandler.java
A asterix-app/src/main/java/org/apache/asterix/active/ActiveLoadManager.java
A asterix-app/src/main/java/org/apache/asterix/active/ActiveManager.java
A asterix-app/src/main/java/org/apache/asterix/active/ActiveWorkRequestResponseHandler.java
A asterix-app/src/main/java/org/apache/asterix/active/CentralActiveManager.java
A asterix-app/src/main/java/org/apache/asterix/active/FeedJoint.java
A asterix-app/src/main/java/org/apache/asterix/active/FeedMessageReceiver.java
A asterix-app/src/main/java/org/apache/asterix/active/FeedTrackingManager.java
A asterix-app/src/main/java/org/apache/asterix/active/FeedWorkCollection.java
M asterix-app/src/main/java/org/apache/asterix/api/common/AsterixAppRuntimeContext.java
M asterix-app/src/main/java/org/apache/asterix/api/common/SessionConfig.java
M asterix-app/src/main/java/org/apache/asterix/api/http/servlet/ConnectorAPIServlet.java
M asterix-app/src/main/java/org/apache/asterix/api/http/servlet/DDLAPIServlet.java
M asterix-app/src/main/java/org/apache/asterix/api/http/servlet/FeedServlet.java
M asterix-app/src/main/java/org/apache/asterix/api/http/servlet/FeedServletUtil.java
M asterix-app/src/main/java/org/apache/asterix/api/http/servlet/QueryStatusAPIServlet.java
M asterix-app/src/main/java/org/apache/asterix/api/http/servlet/UpdateAPIServlet.java
M asterix-app/src/main/java/org/apache/asterix/aql/translator/QueryTranslator.java
D asterix-app/src/main/java/org/apache/asterix/feed/CentralFeedManager.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedJobNotificationHandler.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedJoint.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedLifecycleListener.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedLoadManager.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedMessageReceiver.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedTrackingManager.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedWorkCollection.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedWorkRequestResponseHandler.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedsActivator.java
M asterix-app/src/main/java/org/apache/asterix/file/ExternalIndexingOperations.java
M asterix-app/src/main/java/org/apache/asterix/file/FeedOperations.java
A asterix-app/src/main/java/org/apache/asterix/file/ProcedureOperations.java
M asterix-app/src/main/java/org/apache/asterix/file/SecondaryBTreeOperationsHelper.java
M asterix-app/src/main/java/org/apache/asterix/file/SecondaryIndexOperationsHelper.java
M asterix-app/src/main/java/org/apache/asterix/file/SecondaryRTreeOperationsHelper.java
M asterix-app/src/main/java/org/apache/asterix/hyracks/bootstrap/CCApplicationEntryPoint.java
M asterix-app/src/main/java/org/apache/asterix/hyracks/bootstrap/FeedBootstrap.java
M asterix-app/src/main/java/org/apache/asterix/hyracks/bootstrap/GlobalRecoveryManager.java
M asterix-app/src/test/java/org/apache/asterix/api/http/servlet/ConnectorAPIServletTest.java
M asterix-app/src/test/java/org/apache/asterix/test/aql/AQLTestSuite.java
M asterix-app/src/test/java/org/apache/asterix/test/runtime/RepeatedTest.java
M asterix-app/src/test/resources/metadata/results/basic/meta15/meta15.1.adm
M asterix-app/src/test/resources/metadata/results/basic/metadata_dataset/metadata_dataset.1.adm
M asterix-app/src/test/resources/metadata/results/basic/metadata_datatype/metadata_datatype.1.adm
M asterix-app/src/test/resources/metadata/results/basic/metadata_index/metadata_index.1.adm
A asterix-app/src/test/resources/optimizerts/queries/channels/channel-create.aql
A asterix-app/src/test/resources/optimizerts/queries/channels/channel-subscribe.aql
A asterix-app/src/test/resources/optimizerts/queries/channels/channel-unsubscribe.aql
A asterix-app/src/test/resources/optimizerts/results/channels/channel-create.plan
A asterix-app/src/test/resources/optimizerts/results/channels/channel-subscribe.plan
A asterix-app/src/test/resources/optimizerts/results/channels/channel-unsubscribe.plan
A asterix-app/src/test/resources/runtimets/queries/channels/create_channel_check_datasets/create_channel_check_datasets.1.ddl.aql
A asterix-app/src/test/resources/runtimets/queries/channels/create_channel_check_datasets/create_channel_check_datasets.2.update.aql
A asterix-app/src/test/resources/runtimets/queries/channels/create_channel_check_datasets/create_channel_check_datasets.3.query.aql
A asterix-app/src/test/resources/runtimets/queries/channels/create_channel_check_metadata/create_channel_check_metadata.1.ddl.aql
A asterix-app/src/test/resources/runtimets/queries/channels/create_channel_check_metadata/create_channel_check_metadata.2.update.aql
A asterix-app/src/test/resources/runtimets/queries/channels/create_channel_check_metadata/create_channel_check_metadata.3.query.aql
A asterix-app/src/test/resources/runtimets/queries/channels/drop_channel_check_datasets/drop_channel_check_datasets.1.ddl.aql
A asterix-app/src/test/resources/runtimets/queries/channels/drop_channel_check_datasets/drop_channel_check_datasets.2.update.aql
A asterix-app/src/test/resources/runtimets/queries/channels/drop_channel_check_datasets/drop_channel_check_datasets.3.query.aql
A asterix-app/src/test/resources/runtimets/queries/channels/drop_channel_check_metadata/drop_channel_check_metadata.1.ddl.aql
A asterix-app/src/test/resources/runtimets/queries/channels/drop_channel_check_metadata/drop_channel_check_metadata.2.update.aql
A asterix-app/src/test/resources/runtimets/queries/channels/drop_channel_check_metadata/drop_channel_check_metadata.3.query.aql
A asterix-app/src/test/resources/runtimets/queries/channels/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.1.ddl.aql
A asterix-app/src/test/resources/runtimets/queries/channels/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.2.update.aql
A asterix-app/src/test/resources/runtimets/queries/channels/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.3.query.aql
A asterix-app/src/test/resources/runtimets/queries/dml/insert-return-records/insert-return-records.1.ddl.aql
A asterix-app/src/test/resources/runtimets/queries/dml/insert-return-records/insert-return-records.2.update.aql
A asterix-app/src/test/resources/runtimets/queries/dml/insert-return-records/insert-return-records.3.query.aql
A asterix-app/src/test/resources/runtimets/queries/dml/insert-returning-fieldname/insert-returning-fieldname.1.ddl.aql
A asterix-app/src/test/resources/runtimets/queries/dml/insert-returning-fieldname/insert-returning-fieldname.2.update.aql
A asterix-app/src/test/resources/runtimets/queries/dml/insert-returning-fieldname/insert-returning-fieldname.3.query.aql
A asterix-app/src/test/resources/runtimets/results/channels/create_channel_check_datasets/create_channel_check_datasets.1.adm
A asterix-app/src/test/resources/runtimets/results/channels/create_channel_check_metadata/create_channel_check_metadata.1.adm
A asterix-app/src/test/resources/runtimets/results/channels/drop_channel_check_datasets/drop_channel_check_datasets.1.adm
A asterix-app/src/test/resources/runtimets/results/channels/drop_channel_check_metadata/drop_channel_check_metadata.1.adm
A asterix-app/src/test/resources/runtimets/results/channels/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.1.adm
A asterix-app/src/test/resources/runtimets/results/dml/insert-return-records/insert-return-records.1.adm
A asterix-app/src/test/resources/runtimets/results/dml/insert-returning-fieldname/insert-returning-fieldname.1.adm
M asterix-app/src/test/resources/runtimets/results/user-defined-functions/udf23/udf23.1.adm
M asterix-app/src/test/resources/runtimets/testsuite.xml
M asterix-common/src/main/java/org/apache/asterix/common/api/IAsterixAppRuntimeContext.java
M asterix-common/src/main/java/org/apache/asterix/common/messaging/api/ICCMessageBroker.java
D asterix-external-data/src/main/java/org/apache/asterix/external/adapter/factory/GenericAdapterFactory.java
D asterix-external-data/src/main/java/org/apache/asterix/external/api/IAdapterRuntimeManager.java
M asterix-external-data/src/main/java/org/apache/asterix/external/api/IDataParser.java
D asterix-external-data/src/main/java/org/apache/asterix/external/api/IFeedAdapter.java
D asterix-external-data/src/main/java/org/apache/asterix/external/dataset/adapter/GenericAdapter.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/ICentralFeedManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IExceptionHandler.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeed.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedConnectionManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedFrameHandler.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedJoint.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedLifecycleEventSubscriber.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedLifecycleIntakeEventSubscriber.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedLifecycleListener.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedLoadManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMemoryComponent.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMemoryManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMessageService.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMetadataManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMetricCollector.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedOperatorOutputSideHandler.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedProvider.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedRuntime.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedService.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedSubscriptionManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedTrackingManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedWork.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedWorkEventListener.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedWorkManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFrameEventCallback.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFramePostProcessor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFramePreprocessor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IIntakeProgressTracker.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IMessageReceiver.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/ISubscribableRuntime.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/ISubscriberRuntime.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/ISubscriptionProvider.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/CollectTransformFeedFrameWriter.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/DataBucket.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/DataBucketPool.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/DistributeFeedFrameWriter.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedCollectRuntimeInputHandler.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedExceptionHandler.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameCache.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameCollector.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameDiscarder.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameHandlers.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameSpiller.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameTupleAccessor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameTupleDecorator.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedRuntimeInputHandler.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FrameCollection.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FrameDistributor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FrameEventCallback.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/StorageFrameHandler.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedCollectInfo.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionId.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionRequest.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedId.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedInfo.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedJointKey.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedLifecycleEventSubscriber.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedMemoryManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedMetadataManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedRuntimeManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedSubscriptionManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedWorkManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/EndFeedMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedCongestionMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedMessageService.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedReportMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedTupleCommitAckMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedTupleCommitResponseMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/MessageListener.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/MessageReceiver.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/NodeReportMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/PrepareStallMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/RemoteSocketMessageListener.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/ScaleInReportMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/SocketMessageListener.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/StorageReportFeedMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/TerminateDataFlowMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/ThrottlingEnabledFeedMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/XAQLFeedMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/policy/FeedPolicy.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/policy/FeedPolicyAccessor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/policy/FeedPolicyEnforcer.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/AdapterExecutor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/AdapterRuntimeManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/CollectionRuntime.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/FeedRuntime.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/FeedRuntimeId.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/IngestionRuntime.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/SubscribableFeedRuntimeId.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/SubscribableRuntime.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/BasicMonitoredBuffer.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/ComputeSideMonitoredBuffer.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedActivity.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedConnectJobInfo.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedIntakeInfo.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedJobInfo.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedMetricCollector.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/IntakePartitionStatistics.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/IntakeSideMonitoredBuffer.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/MonitoredBuffer.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/MonitoredBufferTimerTasks.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/NodeLoad.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/NodeLoadReport.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/NodeLoadReportService.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/Series.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/SeriesAvg.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/SeriesRate.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/StorageSideMonitoredBuffer.java
M asterix-external-data/src/main/java/org/apache/asterix/external/input/HDFSDataSourceFactory.java
D asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/LocalFileSystemInputStream.java
D asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/factory/LocalFSInputStreamProviderFactory.java
D asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/provider/LocalFSInputStreamProvider.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalDataScanOperatorDescriptor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedCollectOperatorDescriptor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedCollectOperatorNodePushable.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedIntakeOperatorDescriptor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedIntakeOperatorNodePushable.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMessageOperatorDescriptor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMessageOperatorNodePushable.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaComputeNodePushable.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaNodePushable.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaOperatorDescriptor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaStoreNodePushable.java
M asterix-external-data/src/main/java/org/apache/asterix/external/parser/factory/HiveDataParserFactory.java
D asterix-external-data/src/main/java/org/apache/asterix/external/provider/AdapterFactoryProvider.java
D asterix-external-data/src/main/java/org/apache/asterix/external/provider/DatasourceFactoryProvider.java
M asterix-external-data/src/main/java/org/apache/asterix/external/util/ExternalDataConstants.java
M asterix-external-data/src/main/java/org/apache/asterix/external/util/ExternalDataUtils.java
D asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedConstants.java
D asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedFrameUtil.java
D asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedLogManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedUtils.java
D asterix-external-data/src/main/java/org/apache/asterix/external/util/FileSystemWatcher.java
M asterix-external-data/src/main/java/org/apache/asterix/external/util/TwitterUtil.java
M asterix-external-data/src/test/java/org/apache/asterix/external/library/AddHashTagsFunction.java
M asterix-external-data/src/test/java/org/apache/asterix/external/library/AddHashTagsInPlaceFunction.java
M asterix-external-data/src/test/java/org/apache/asterix/external/library/AllTypesFunction.java
M asterix-external-data/src/test/java/org/apache/asterix/external/library/CapitalFinderFunction.java
M asterix-external-data/src/test/java/org/apache/asterix/external/library/ParseTweetFunction.java
D asterix-external-data/src/test/java/org/apache/asterix/external/library/adapter/TestTypedAdapter.java
M asterix-lang-aql/src/main/java/org/apache/asterix/lang/aql/statement/SubscribeFeedStatement.java
M asterix-lang-aql/src/main/javacc/AQL.jj
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/base/Statement.java
A asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/BrokerDropStatement.java
A asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/ChannelDropStatement.java
A asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/ChannelSubscribeStatement.java
A asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/ChannelUnsubscribeStatement.java
A asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/CreateBrokerStatement.java
A asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/CreateChannelStatement.java
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/CreateFunctionStatement.java
A asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/ExecuteProcedureStatement.java
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/FunctionDropStatement.java
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/InsertStatement.java
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/UpsertStatement.java
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/visitor/FormatPrintVisitor.java
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/visitor/GatherFunctionCallsVisitor.java
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/visitor/base/AbstractQueryExpressionVisitor.java
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/visitor/base/ILangVisitor.java
M asterix-lang-sqlpp/src/main/javacc/SQLPP.jj
M asterix-metadata/pom.xml
M asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataCache.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataManager.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataNode.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataTransactionContext.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/api/IMetadataManager.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/api/IMetadataNode.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/bootstrap/MetadataBootstrap.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/bootstrap/MetadataIndexImmutableProperties.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/bootstrap/MetadataPrimaryIndexes.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/bootstrap/MetadataRecordTypes.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/declared/AqlMetadataProvider.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/declared/DatasetDataSource.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/declared/FeedDataSource.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/declared/LoadableDataSource.java
A asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/Broker.java
A asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/Channel.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/Feed.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/FeedPolicyEntity.java
A asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/BrokerTupleTranslator.java
A asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/ChannelTupleTranslator.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/FeedTupleTranslator.java
A asterix-metadata/src/main/java/org/apache/asterix/metadata/feeds/ActiveUtil.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/feeds/BuiltinFeedPolicies.java
D asterix-metadata/src/main/java/org/apache/asterix/metadata/feeds/FeedMetadataUtil.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/utils/MetadataLockManager.java
M asterix-runtime/src/main/java/org/apache/asterix/runtime/formats/NonTaggedDataFormat.java
M pom.xml
481 files changed, 23,116 insertions(+), 18,202 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb refs/changes/27/627/2
--
To view, visit https://asterix-gerrit.ics.uci.edu/627
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: newpatchset
Gerrit-Change-Id: I97a78b371e4b96cfec9f5668767a53eefbbc3cfd
Gerrit-PatchSet: 2
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: Steven Jacobs <sj...@ucr.edu>
Gerrit-Reviewer: Jenkins <je...@fulliautomatix.ics.uci.edu>
Change in asterixdb[master]: Added Channels to Asterix
Posted by "Jenkins (Code Review)" <do...@asterixdb.incubator.apache.org>.
Jenkins has posted comments on this change.
Change subject: Added Channels to Asterix
......................................................................
Patch Set 2:
Build Started https://asterix-jenkins.ics.uci.edu/job/asterix-gerrit-notopic/825/
--
To view, visit https://asterix-gerrit.ics.uci.edu/627
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: comment
Gerrit-Change-Id: I97a78b371e4b96cfec9f5668767a53eefbbc3cfd
Gerrit-PatchSet: 2
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: Steven Jacobs <sj...@ucr.edu>
Gerrit-Reviewer: Jenkins <je...@fulliautomatix.ics.uci.edu>
Gerrit-HasComments: No
Change in asterixdb[master]: Added Channels to Asterix
Posted by "Steven Jacobs (Code Review)" <do...@asterixdb.incubator.apache.org>.
Steven Jacobs has abandoned this change.
Change subject: Added Channels to Asterix
......................................................................
Abandoned
--
To view, visit https://asterix-gerrit.ics.uci.edu/627
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: abandon
Gerrit-Change-Id: I97a78b371e4b96cfec9f5668767a53eefbbc3cfd
Gerrit-PatchSet: 3
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: Steven Jacobs <sj...@ucr.edu>
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>
Change in asterixdb[master]: Added Channels to Asterix
Posted by "Steven Jacobs (Code Review)" <do...@asterixdb.incubator.apache.org>.
Hello Jenkins,
I'd like you to reexamine a change. Please visit
https://asterix-gerrit.ics.uci.edu/627
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]
Instrumented Procedures
Made the syntax for procedures available
1. create procedure (same as create function)
2. execute procedure()
3. drop procedure (same as drop function)
Only works for insert procedures
Not optimized
Currently saves the jobspec and runs the spec on execute
Change-Id: I97a78b371e4b96cfec9f5668767a53eefbbc3cfd
---
A asterix-active/pom.xml
A asterix-active/src/main/java/org/apache/asterix/active/ActiveActivity.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveConnectionManager.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveJobId.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveJobInfo.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveJobsActivator.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveLifecycleEventSubscriber.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveObjectId.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveRuntimeId.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveRuntimeInputHandler.java
A asterix-active/src/main/java/org/apache/asterix/active/ActiveRuntimeManager.java
A asterix-active/src/main/java/org/apache/asterix/active/adapter/AdapterFactoryProvider.java
A asterix-active/src/main/java/org/apache/asterix/active/adapter/DatasourceFactoryProvider.java
A asterix-active/src/main/java/org/apache/asterix/active/adapter/GenericAdapter.java
A asterix-active/src/main/java/org/apache/asterix/active/adapter/GenericAdapterFactory.java
A asterix-active/src/main/java/org/apache/asterix/active/api/IActiveConnectionManager.java
A asterix-active/src/main/java/org/apache/asterix/active/api/IActiveLifecycleEventSubscriber.java
A asterix-active/src/main/java/org/apache/asterix/active/api/IActiveLoadManager.java
A asterix-active/src/main/java/org/apache/asterix/active/api/IActiveManager.java
A asterix-active/src/main/java/org/apache/asterix/active/api/IActiveMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/api/IActiveRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/api/ICentralActiveManager.java
A asterix-active/src/main/java/org/apache/asterix/active/channel/ChannelActivity.java
A asterix-active/src/main/java/org/apache/asterix/active/channel/ChannelRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/channel/ProcedureJobInfo.java
A asterix-active/src/main/java/org/apache/asterix/active/channel/StoredJobRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/channel/api/IChannelJobService.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IAdapterRuntimeManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IExceptionHandler.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeed.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedAdapter.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedFrameHandler.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedJoint.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedLifecycleIntakeEventSubscriber.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedLifecycleListener.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedMemoryComponent.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedMemoryManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedMessageService.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedMetadataManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedMetricCollector.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedOperatorOutputSideHandler.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedProvider.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedService.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedSubscriptionManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedTrackingManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedWork.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedWorkEventListener.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFeedWorkManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFrameEventCallback.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFramePostProcessor.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IFramePreprocessor.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IIntakeProgressTracker.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/IMessageReceiver.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/ISubscribableRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/ISubscriberRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/api/ISubscriptionProvider.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/CollectTransformFeedFrameWriter.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/DataBucket.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/DataBucketPool.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/DistributeFeedFrameWriter.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedCollectRuntimeInputHandler.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedExceptionHandler.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedFrameCache.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedFrameCollector.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedFrameDiscarder.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedFrameHandlers.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedFrameSpiller.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedFrameTupleAccessor.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FeedFrameTupleDecorator.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FrameCollection.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FrameDistributor.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/FrameEventCallback.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/dataflow/StorageFrameHandler.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/filesystem/FileSystemWatcher.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/filesystem/LocalFSInputStreamProvider.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/filesystem/LocalFSInputStreamProviderFactory.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/filesystem/LocalFileSystemInputStream.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedCollectInfo.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedConnectionId.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedConnectionRequest.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedConstants.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedFrameUtil.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedJointKey.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedLogManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedMemoryManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedMetadataManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedSubscriptionManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedUtils.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/management/FeedWorkManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/ActiveMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/DropStoredJobOperatorMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/EndFeedMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/ExecuteProcedureMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/FeedCongestionMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/FeedMessageService.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/FeedReportMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/FeedTupleCommitAckMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/FeedTupleCommitResponseMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/MessageListener.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/MessageReceiver.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/NodeReportMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/PrepareStallMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/RemoteSocketMessageListener.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/RepetitiveChannelXAQLMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/ScaleInReportMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/SocketMessageListener.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/StorageReportFeedMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/TerminateDataFlowMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/ThrottlingEnabledFeedMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/message/XAQLFeedMessage.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/policy/FeedPolicy.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/policy/FeedPolicyAccessor.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/policy/FeedPolicyEnforcer.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/runtime/AdapterExecutor.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/runtime/AdapterRuntimeManager.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/runtime/CollectionRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/runtime/IngestionRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/runtime/SubscribableFeedRuntimeId.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/runtime/SubscribableRuntime.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/BasicMonitoredBuffer.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/ComputeSideMonitoredBuffer.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/FeedActivity.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/FeedConnectJobInfo.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/FeedIntakeInfo.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/FeedMetricCollector.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/IntakePartitionStatistics.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/IntakeSideMonitoredBuffer.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/MonitoredBuffer.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/MonitoredBufferTimerTasks.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/NodeLoad.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/NodeLoadReport.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/NodeLoadReportService.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/Series.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/SeriesAvg.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/SeriesRate.java
A asterix-active/src/main/java/org/apache/asterix/active/feed/watch/StorageSideMonitoredBuffer.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/ActiveMessageOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/ActiveMessageOperatorNodePushable.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/ActiveMetaNodePushable.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/ActiveMetaOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/ChannelMetaOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/ExternalDataScanOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/FeedCollectOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/FeedCollectOperatorNodePushable.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/FeedIntakeOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/FeedIntakeOperatorNodePushable.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/FeedMetaComputeNodePushable.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/FeedMetaOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/FeedMetaStoreNodePushable.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/ProcedureMetaOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/RepetitiveChannelOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/RepetitiveChannelOperatorNodePushable.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/StoredJobOperatorDescriptor.java
A asterix-active/src/main/java/org/apache/asterix/active/operators/StoredJobOperatorNodePushable.java
A asterix-active/src/test/java/org/apache/asterix/external/library/adapter/TestTypedAdapter.java
R asterix-active/src/test/java/org/apache/asterix/external/library/adapter/TestTypedAdapterFactory.java
A asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/ReplaceableSinkOperator.java
M asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/physical/CommitPOperator.java
M asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/physical/CommitRuntime.java
M asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/physical/CommitRuntimeFactory.java
M asterix-algebra/src/main/java/org/apache/asterix/algebra/operators/physical/UpsertCommitRuntime.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/AsterixIntroduceGroupByCombinerRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/CheckFilterExpressionTypeRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/CountVarToCountOneRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/DisjunctivePredicateToJoinRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/ExtractDistinctByExpressionsRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/ExtractOrderExpressionsRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/InlineUnnestFunctionRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceDynamicTypeCastForExternalFunctionRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceEnforcedListTypeRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceMaterializationForInsertWithSelfScanRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceRandomPartitioningFeedComputationRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceRapidFrameFlushProjectAssignRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceSecondaryIndexInsertDeleteRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceStaticTypeCastForInsertRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceTransactionCommitByAssignOpRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceUnionRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/LoadRecordFieldsRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/NestGroupByRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/PushAggFuncIntoStandaloneAggregateRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/PushAggregateIntoGroupbyRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/PushProperJoinThroughProduct.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/RemoveRedundantSelectRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/RemoveSortInFeedIngestionRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/ReplaceSinkOpWithCommitOpRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/SetAsterixPhysicalOperatorsRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/UnnestToDataScanRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/AbstractIntroduceAccessMethodRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/AccessMethodAnalysisContext.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/AccessMethodJobGenParams.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/BTreeJobGenParams.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/IntroduceJoinAccessMethodRule.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/InvertedIndexJobGenParams.java
M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/RTreeJobGenParams.java
M asterix-algebra/src/main/java/org/apache/asterix/translator/AqlExpressionToPlanTranslator.java
M asterix-algebra/src/main/java/org/apache/asterix/translator/AqlPlusExpressionToPlanTranslator.java
M asterix-algebra/src/main/java/org/apache/asterix/translator/CompiledStatements.java
M asterix-algebra/src/main/java/org/apache/asterix/translator/LangExpressionToPlanTranslator.java
M asterix-app/data/csv/sample_01.csv
M asterix-app/pom.xml
A asterix-app/src/main/java/org/apache/asterix/active/ActiveJobLifecycleListener.java
A asterix-app/src/main/java/org/apache/asterix/active/ActiveJobNotificationHandler.java
A asterix-app/src/main/java/org/apache/asterix/active/ActiveLoadManager.java
A asterix-app/src/main/java/org/apache/asterix/active/ActiveManager.java
A asterix-app/src/main/java/org/apache/asterix/active/ActiveWorkRequestResponseHandler.java
A asterix-app/src/main/java/org/apache/asterix/active/CentralActiveManager.java
A asterix-app/src/main/java/org/apache/asterix/active/ChannelJobService.java
A asterix-app/src/main/java/org/apache/asterix/active/FeedJoint.java
A asterix-app/src/main/java/org/apache/asterix/active/FeedMessageReceiver.java
A asterix-app/src/main/java/org/apache/asterix/active/FeedTrackingManager.java
A asterix-app/src/main/java/org/apache/asterix/active/FeedWorkCollection.java
M asterix-app/src/main/java/org/apache/asterix/api/common/AsterixAppRuntimeContext.java
M asterix-app/src/main/java/org/apache/asterix/api/common/SessionConfig.java
M asterix-app/src/main/java/org/apache/asterix/api/http/servlet/ConnectorAPIServlet.java
M asterix-app/src/main/java/org/apache/asterix/api/http/servlet/DDLAPIServlet.java
M asterix-app/src/main/java/org/apache/asterix/api/http/servlet/FeedServlet.java
M asterix-app/src/main/java/org/apache/asterix/api/http/servlet/FeedServletUtil.java
M asterix-app/src/main/java/org/apache/asterix/api/http/servlet/QueryStatusAPIServlet.java
M asterix-app/src/main/java/org/apache/asterix/api/http/servlet/UpdateAPIServlet.java
M asterix-app/src/main/java/org/apache/asterix/aql/translator/QueryTranslator.java
D asterix-app/src/main/java/org/apache/asterix/feed/CentralFeedManager.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedJobNotificationHandler.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedJoint.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedLifecycleListener.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedLoadManager.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedMessageReceiver.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedTrackingManager.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedWorkCollection.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedWorkRequestResponseHandler.java
D asterix-app/src/main/java/org/apache/asterix/feed/FeedsActivator.java
M asterix-app/src/main/java/org/apache/asterix/file/ExternalIndexingOperations.java
M asterix-app/src/main/java/org/apache/asterix/file/FeedOperations.java
A asterix-app/src/main/java/org/apache/asterix/file/ProcedureOperations.java
M asterix-app/src/main/java/org/apache/asterix/file/SecondaryBTreeOperationsHelper.java
M asterix-app/src/main/java/org/apache/asterix/file/SecondaryIndexOperationsHelper.java
M asterix-app/src/main/java/org/apache/asterix/file/SecondaryRTreeOperationsHelper.java
M asterix-app/src/main/java/org/apache/asterix/hyracks/bootstrap/CCApplicationEntryPoint.java
M asterix-app/src/main/java/org/apache/asterix/hyracks/bootstrap/FeedBootstrap.java
M asterix-app/src/main/java/org/apache/asterix/hyracks/bootstrap/GlobalRecoveryManager.java
M asterix-app/src/test/java/org/apache/asterix/api/http/servlet/ConnectorAPIServletTest.java
M asterix-app/src/test/java/org/apache/asterix/test/aql/AQLTestSuite.java
M asterix-app/src/test/java/org/apache/asterix/test/runtime/RepeatedTest.java
M asterix-app/src/test/resources/metadata/results/basic/meta15/meta15.1.adm
M asterix-app/src/test/resources/metadata/results/basic/metadata_dataset/metadata_dataset.1.adm
M asterix-app/src/test/resources/metadata/results/basic/metadata_datatype/metadata_datatype.1.adm
M asterix-app/src/test/resources/metadata/results/basic/metadata_index/metadata_index.1.adm
A asterix-app/src/test/resources/optimizerts/queries/channels/channel-create.aql
A asterix-app/src/test/resources/optimizerts/queries/channels/channel-subscribe.aql
A asterix-app/src/test/resources/optimizerts/queries/channels/channel-unsubscribe.aql
A asterix-app/src/test/resources/optimizerts/results/channels/channel-create.plan
A asterix-app/src/test/resources/optimizerts/results/channels/channel-subscribe.plan
A asterix-app/src/test/resources/optimizerts/results/channels/channel-unsubscribe.plan
A asterix-app/src/test/resources/runtimets/queries/channels/create_channel_check_datasets/create_channel_check_datasets.1.ddl.aql
A asterix-app/src/test/resources/runtimets/queries/channels/create_channel_check_datasets/create_channel_check_datasets.2.update.aql
A asterix-app/src/test/resources/runtimets/queries/channels/create_channel_check_datasets/create_channel_check_datasets.3.query.aql
A asterix-app/src/test/resources/runtimets/queries/channels/create_channel_check_metadata/create_channel_check_metadata.1.ddl.aql
A asterix-app/src/test/resources/runtimets/queries/channels/create_channel_check_metadata/create_channel_check_metadata.2.update.aql
A asterix-app/src/test/resources/runtimets/queries/channels/create_channel_check_metadata/create_channel_check_metadata.3.query.aql
A asterix-app/src/test/resources/runtimets/queries/channels/drop_channel_check_datasets/drop_channel_check_datasets.1.ddl.aql
A asterix-app/src/test/resources/runtimets/queries/channels/drop_channel_check_datasets/drop_channel_check_datasets.2.update.aql
A asterix-app/src/test/resources/runtimets/queries/channels/drop_channel_check_datasets/drop_channel_check_datasets.3.query.aql
A asterix-app/src/test/resources/runtimets/queries/channels/drop_channel_check_metadata/drop_channel_check_metadata.1.ddl.aql
A asterix-app/src/test/resources/runtimets/queries/channels/drop_channel_check_metadata/drop_channel_check_metadata.2.update.aql
A asterix-app/src/test/resources/runtimets/queries/channels/drop_channel_check_metadata/drop_channel_check_metadata.3.query.aql
A asterix-app/src/test/resources/runtimets/queries/channels/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.1.ddl.aql
A asterix-app/src/test/resources/runtimets/queries/channels/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.2.update.aql
A asterix-app/src/test/resources/runtimets/queries/channels/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.3.query.aql
A asterix-app/src/test/resources/runtimets/queries/dml/insert-return-records/insert-return-records.1.ddl.aql
A asterix-app/src/test/resources/runtimets/queries/dml/insert-return-records/insert-return-records.2.update.aql
A asterix-app/src/test/resources/runtimets/queries/dml/insert-return-records/insert-return-records.3.query.aql
A asterix-app/src/test/resources/runtimets/queries/dml/insert-returning-fieldname/insert-returning-fieldname.1.ddl.aql
A asterix-app/src/test/resources/runtimets/queries/dml/insert-returning-fieldname/insert-returning-fieldname.2.update.aql
A asterix-app/src/test/resources/runtimets/queries/dml/insert-returning-fieldname/insert-returning-fieldname.3.query.aql
A asterix-app/src/test/resources/runtimets/results/channels/create_channel_check_datasets/create_channel_check_datasets.1.adm
A asterix-app/src/test/resources/runtimets/results/channels/create_channel_check_metadata/create_channel_check_metadata.1.adm
A asterix-app/src/test/resources/runtimets/results/channels/drop_channel_check_datasets/drop_channel_check_datasets.1.adm
A asterix-app/src/test/resources/runtimets/results/channels/drop_channel_check_metadata/drop_channel_check_metadata.1.adm
A asterix-app/src/test/resources/runtimets/results/channels/subscribe_channel_check_subscriptions/subscribe_channel_check_subscriptions.1.adm
A asterix-app/src/test/resources/runtimets/results/dml/insert-return-records/insert-return-records.1.adm
A asterix-app/src/test/resources/runtimets/results/dml/insert-returning-fieldname/insert-returning-fieldname.1.adm
M asterix-app/src/test/resources/runtimets/results/user-defined-functions/udf23/udf23.1.adm
M asterix-app/src/test/resources/runtimets/testsuite.xml
M asterix-common/src/main/java/org/apache/asterix/common/api/IAsterixAppRuntimeContext.java
M asterix-common/src/main/java/org/apache/asterix/common/messaging/api/ICCMessageBroker.java
D asterix-external-data/src/main/java/org/apache/asterix/external/adapter/factory/GenericAdapterFactory.java
D asterix-external-data/src/main/java/org/apache/asterix/external/api/IAdapterRuntimeManager.java
M asterix-external-data/src/main/java/org/apache/asterix/external/api/IDataParser.java
D asterix-external-data/src/main/java/org/apache/asterix/external/api/IFeedAdapter.java
D asterix-external-data/src/main/java/org/apache/asterix/external/dataset/adapter/GenericAdapter.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/ICentralFeedManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IExceptionHandler.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeed.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedConnectionManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedFrameHandler.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedJoint.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedLifecycleEventSubscriber.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedLifecycleIntakeEventSubscriber.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedLifecycleListener.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedLoadManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMemoryComponent.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMemoryManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMessageService.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMetadataManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMetricCollector.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedOperatorOutputSideHandler.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedProvider.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedRuntime.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedService.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedSubscriptionManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedTrackingManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedWork.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedWorkEventListener.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedWorkManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFrameEventCallback.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFramePostProcessor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFramePreprocessor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IIntakeProgressTracker.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IMessageReceiver.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/ISubscribableRuntime.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/ISubscriberRuntime.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/ISubscriptionProvider.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/CollectTransformFeedFrameWriter.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/DataBucket.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/DataBucketPool.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/DistributeFeedFrameWriter.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedCollectRuntimeInputHandler.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedExceptionHandler.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameCache.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameCollector.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameDiscarder.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameHandlers.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameSpiller.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameTupleAccessor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameTupleDecorator.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedRuntimeInputHandler.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FrameCollection.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FrameDistributor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FrameEventCallback.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/StorageFrameHandler.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedCollectInfo.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionId.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionRequest.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedId.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedInfo.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedJointKey.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedLifecycleEventSubscriber.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedMemoryManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedMetadataManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedRuntimeManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedSubscriptionManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedWorkManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/EndFeedMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedCongestionMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedMessageService.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedReportMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedTupleCommitAckMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedTupleCommitResponseMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/MessageListener.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/MessageReceiver.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/NodeReportMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/PrepareStallMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/RemoteSocketMessageListener.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/ScaleInReportMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/SocketMessageListener.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/StorageReportFeedMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/TerminateDataFlowMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/ThrottlingEnabledFeedMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/XAQLFeedMessage.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/policy/FeedPolicy.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/policy/FeedPolicyAccessor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/policy/FeedPolicyEnforcer.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/AdapterExecutor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/AdapterRuntimeManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/CollectionRuntime.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/FeedRuntime.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/FeedRuntimeId.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/IngestionRuntime.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/SubscribableFeedRuntimeId.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/SubscribableRuntime.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/BasicMonitoredBuffer.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/ComputeSideMonitoredBuffer.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedActivity.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedConnectJobInfo.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedIntakeInfo.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedJobInfo.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedMetricCollector.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/IntakePartitionStatistics.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/IntakeSideMonitoredBuffer.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/MonitoredBuffer.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/MonitoredBufferTimerTasks.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/NodeLoad.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/NodeLoadReport.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/NodeLoadReportService.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/Series.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/SeriesAvg.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/SeriesRate.java
D asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/StorageSideMonitoredBuffer.java
M asterix-external-data/src/main/java/org/apache/asterix/external/input/HDFSDataSourceFactory.java
D asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/LocalFileSystemInputStream.java
D asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/factory/LocalFSInputStreamProviderFactory.java
D asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/provider/LocalFSInputStreamProvider.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalDataScanOperatorDescriptor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedCollectOperatorDescriptor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedCollectOperatorNodePushable.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedIntakeOperatorDescriptor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedIntakeOperatorNodePushable.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMessageOperatorDescriptor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMessageOperatorNodePushable.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaComputeNodePushable.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaNodePushable.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaOperatorDescriptor.java
D asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaStoreNodePushable.java
M asterix-external-data/src/main/java/org/apache/asterix/external/parser/factory/HiveDataParserFactory.java
D asterix-external-data/src/main/java/org/apache/asterix/external/provider/AdapterFactoryProvider.java
D asterix-external-data/src/main/java/org/apache/asterix/external/provider/DatasourceFactoryProvider.java
M asterix-external-data/src/main/java/org/apache/asterix/external/util/ExternalDataConstants.java
M asterix-external-data/src/main/java/org/apache/asterix/external/util/ExternalDataUtils.java
D asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedConstants.java
D asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedFrameUtil.java
D asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedLogManager.java
D asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedUtils.java
D asterix-external-data/src/main/java/org/apache/asterix/external/util/FileSystemWatcher.java
M asterix-external-data/src/main/java/org/apache/asterix/external/util/TwitterUtil.java
M asterix-external-data/src/test/java/org/apache/asterix/external/library/AddHashTagsFunction.java
M asterix-external-data/src/test/java/org/apache/asterix/external/library/AddHashTagsInPlaceFunction.java
M asterix-external-data/src/test/java/org/apache/asterix/external/library/AllTypesFunction.java
M asterix-external-data/src/test/java/org/apache/asterix/external/library/CapitalFinderFunction.java
M asterix-external-data/src/test/java/org/apache/asterix/external/library/ParseTweetFunction.java
D asterix-external-data/src/test/java/org/apache/asterix/external/library/adapter/TestTypedAdapter.java
M asterix-lang-aql/src/main/java/org/apache/asterix/lang/aql/statement/SubscribeFeedStatement.java
M asterix-lang-aql/src/main/javacc/AQL.jj
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/base/Statement.java
A asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/BrokerDropStatement.java
A asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/ChannelDropStatement.java
A asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/ChannelSubscribeStatement.java
A asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/ChannelUnsubscribeStatement.java
A asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/CreateBrokerStatement.java
A asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/CreateChannelStatement.java
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/CreateFunctionStatement.java
A asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/ExecuteProcedureStatement.java
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/FunctionDropStatement.java
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/InsertStatement.java
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/statement/UpsertStatement.java
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/visitor/FormatPrintVisitor.java
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/visitor/GatherFunctionCallsVisitor.java
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/visitor/base/AbstractQueryExpressionVisitor.java
M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/visitor/base/ILangVisitor.java
M asterix-lang-sqlpp/src/main/javacc/SQLPP.jj
M asterix-metadata/pom.xml
M asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataCache.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataManager.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataNode.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/MetadataTransactionContext.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/api/IMetadataManager.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/api/IMetadataNode.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/bootstrap/MetadataBootstrap.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/bootstrap/MetadataIndexImmutableProperties.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/bootstrap/MetadataPrimaryIndexes.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/bootstrap/MetadataRecordTypes.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/declared/AqlMetadataProvider.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/declared/DatasetDataSource.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/declared/FeedDataSource.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/declared/LoadableDataSource.java
A asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/Broker.java
A asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/Channel.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/Feed.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/FeedPolicyEntity.java
A asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/BrokerTupleTranslator.java
A asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/ChannelTupleTranslator.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/FeedTupleTranslator.java
A asterix-metadata/src/main/java/org/apache/asterix/metadata/feeds/ActiveUtil.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/feeds/BuiltinFeedPolicies.java
D asterix-metadata/src/main/java/org/apache/asterix/metadata/feeds/FeedMetadataUtil.java
M asterix-metadata/src/main/java/org/apache/asterix/metadata/utils/MetadataLockManager.java
M asterix-runtime/src/main/java/org/apache/asterix/runtime/formats/NonTaggedDataFormat.java
M pom.xml
482 files changed, 23,204 insertions(+), 18,199 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb refs/changes/27/627/3
--
To view, visit https://asterix-gerrit.ics.uci.edu/627
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: newpatchset
Gerrit-Change-Id: I97a78b371e4b96cfec9f5668767a53eefbbc3cfd
Gerrit-PatchSet: 3
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: Steven Jacobs <sj...@ucr.edu>
Gerrit-Reviewer: Jenkins <je...@fulliautomatix.ics.uci.edu>
Gerrit-Reviewer: Till Westmann <ti...@apache.org>
Change in asterixdb[master]: Added Channels to Asterix
Posted by "Jenkins (Code Review)" <do...@asterixdb.incubator.apache.org>.
Jenkins has posted comments on this change.
Change subject: Added Channels to Asterix
......................................................................
Patch Set 2: Verified-1
Build Unstable
https://asterix-jenkins.ics.uci.edu/job/asterix-gerrit-notopic/825/ : UNSTABLE
--
To view, visit https://asterix-gerrit.ics.uci.edu/627
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: comment
Gerrit-Change-Id: I97a78b371e4b96cfec9f5668767a53eefbbc3cfd
Gerrit-PatchSet: 2
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: Steven Jacobs <sj...@ucr.edu>
Gerrit-Reviewer: Jenkins <je...@fulliautomatix.ics.uci.edu>
Gerrit-HasComments: No
Change in asterixdb[master]: Added Channels to Asterix
Posted by "Jenkins (Code Review)" <do...@asterixdb.incubator.apache.org>.
Jenkins has posted comments on this change.
Change subject: Added Channels to Asterix
......................................................................
Patch Set 3:
Build Started https://asterix-jenkins.ics.uci.edu/job/asterix-gerrit-notopic/830/
--
To view, visit https://asterix-gerrit.ics.uci.edu/627
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: comment
Gerrit-Change-Id: I97a78b371e4b96cfec9f5668767a53eefbbc3cfd
Gerrit-PatchSet: 3
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: Steven Jacobs <sj...@ucr.edu>
Gerrit-Reviewer: Jenkins <je...@fulliautomatix.ics.uci.edu>
Gerrit-Reviewer: Till Westmann <ti...@apache.org>
Gerrit-HasComments: No
Change in asterixdb[master]: Test gerrit submit
Posted by "Jenkins (Code Review)" <do...@asterixdb.incubator.apache.org>.
Jenkins has posted comments on this change.
Change subject: Test gerrit submit
......................................................................
Patch Set 1: Verified-1
Build Unstable
https://asterix-jenkins.ics.uci.edu/job/asterix-gerrit-notopic/811/ : UNSTABLE
--
To view, visit https://asterix-gerrit.ics.uci.edu/627
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: comment
Gerrit-Change-Id: I97a78b371e4b96cfec9f5668767a53eefbbc3cfd
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: Steven Jacobs <sj...@ucr.edu>
Gerrit-Reviewer: Jenkins <je...@fulliautomatix.ics.uci.edu>
Gerrit-HasComments: No
Change in asterixdb[master]: Added Channels to Asterix
Posted by "Steven Jacobs (Code Review)" <do...@asterixdb.incubator.apache.org>.
Steven Jacobs has posted comments on this change.
Change subject: Added Channels to Asterix
......................................................................
Patch Set 3:
@Till: I just uploaded a new patch set which is the first one ready for review. This review is very ugly since multiple refactorings have led to most changes being a delete and add rather than a move/update. If you would like to join, I am going to have a review meeting with Abdullah (Probably Friday morning at 9).
--
To view, visit https://asterix-gerrit.ics.uci.edu/627
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: comment
Gerrit-Change-Id: I97a78b371e4b96cfec9f5668767a53eefbbc3cfd
Gerrit-PatchSet: 3
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: Steven Jacobs <sj...@ucr.edu>
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>
Gerrit-HasComments: No
Change in asterixdb[master]: Test gerrit submit
Posted by "Jenkins (Code Review)" <do...@asterixdb.incubator.apache.org>.
Jenkins has posted comments on this change.
Change subject: Test gerrit submit
......................................................................
Patch Set 1:
Build Started https://asterix-jenkins.ics.uci.edu/job/asterix-gerrit-notopic/811/
--
To view, visit https://asterix-gerrit.ics.uci.edu/627
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: comment
Gerrit-Change-Id: I97a78b371e4b96cfec9f5668767a53eefbbc3cfd
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: Steven Jacobs <sj...@ucr.edu>
Gerrit-Reviewer: Jenkins <je...@fulliautomatix.ics.uci.edu>
Gerrit-HasComments: No
Change in asterixdb[master]: Added Channels to Asterix
Posted by "Steven Jacobs (Code Review)" <do...@asterixdb.incubator.apache.org>.
Steven Jacobs has posted comments on this change.
Change subject: Added Channels to Asterix
......................................................................
Patch Set 3: Code-Review-2
(1 comment)
https://asterix-gerrit.ics.uci.edu/#/c/627/3/asterix-app/src/main/java/org/apache/asterix/active/ActiveJobNotificationHandler.java
File asterix-app/src/main/java/org/apache/asterix/active/ActiveJobNotificationHandler.java:
Line 20:
This file still needs a lot of work
--
To view, visit https://asterix-gerrit.ics.uci.edu/627
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: comment
Gerrit-Change-Id: I97a78b371e4b96cfec9f5668767a53eefbbc3cfd
Gerrit-PatchSet: 3
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: Steven Jacobs <sj...@ucr.edu>
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>
Gerrit-HasComments: Yes