abdullah alamoudi has submitted this change and it was merged. Change subject: Feed Fixes and Cleanup ......................................................................
Feed Fixes and Cleanup 1. Introduce filesystem feed data source. 2. Fix the order of closing feed stages on disconnection. 3. Added Twitter feed to the compatibility utility to allow using it with its alias. 4. First part of the feed log space. 5. Fixed the handling of duplicate key exception. Change-Id: I4e8db26a810efd1fbaa52ceeb3efd0c8328ab070 Reviewed-on: https://asterix-gerrit.ics.uci.edu/574 Tested-by: Jenkins <[email protected]> Reviewed-by: Murtadha Hubail <[email protected]> --- M asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceRandomPartitioningFeedComputationRule.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/translator/AbstractLangTranslator.java M asterix-algebra/src/main/java/org/apache/asterix/translator/CompiledStatements.java M asterix-algebra/src/main/javacc/AQLPlus.jj M asterix-app/src/main/java/org/apache/asterix/api/common/AsterixAppRuntimeContext.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/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/aql/translator/QueryTranslator.java R asterix-app/src/main/java/org/apache/asterix/feed/CentralFeedManager.java R asterix-app/src/main/java/org/apache/asterix/feed/FeedJobNotificationHandler.java R asterix-app/src/main/java/org/apache/asterix/feed/FeedJoint.java R asterix-app/src/main/java/org/apache/asterix/feed/FeedLifecycleListener.java R asterix-app/src/main/java/org/apache/asterix/feed/FeedLoadManager.java R asterix-app/src/main/java/org/apache/asterix/feed/FeedMessageReceiver.java R asterix-app/src/main/java/org/apache/asterix/feed/FeedTrackingManager.java R asterix-app/src/main/java/org/apache/asterix/feed/FeedWorkCollection.java R asterix-app/src/main/java/org/apache/asterix/feed/FeedWorkRequestResponseHandler.java R 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 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/AsterixGlobalRecoveryManager.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/ExternalLibraryBootstrap.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/NCApplicationEntryPoint.java M asterix-app/src/test/java/org/apache/asterix/api/http/servlet/ConnectorAPIServletTest.java M asterix-app/src/test/resources/metadata/results/basic/meta15/meta15.1.adm M asterix-app/src/test/resources/runtimets/results/feeds/feeds_01/feeds_01.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/config/AsterixPropertiesAccessor.java R asterix-common/src/main/java/org/apache/asterix/common/config/MetadataConstants.java M asterix-common/src/main/java/org/apache/asterix/common/dataflow/AsterixLSMInsertDeleteOperatorNodePushable.java M asterix-common/src/main/java/org/apache/asterix/common/exceptions/FrameDataException.java D asterix-common/src/main/java/org/apache/asterix/common/feeds/FeedRuntimeReport.java D asterix-common/src/main/java/org/apache/asterix/common/feeds/api/ITupleTrackingFeedAdapter.java M asterix-common/src/main/java/org/apache/asterix/common/parse/ITupleForwarder.java A asterix-common/src/main/java/org/apache/asterix/common/utils/StoragePathUtil.java M asterix-external-data/src/main/java/org/apache/asterix/external/adapter/factory/GenericAdapterFactory.java M asterix-external-data/src/main/java/org/apache/asterix/external/api/IAdapterFactory.java R 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/IDataFlowController.java R asterix-external-data/src/main/java/org/apache/asterix/external/api/IDataSourceAdapter.java A asterix-external-data/src/main/java/org/apache/asterix/external/api/IFeedAdapter.java M asterix-external-data/src/main/java/org/apache/asterix/external/api/IStreamDataParser.java M asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/AbstractDataFlowController.java A asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/AbstractFeedDataFlowController.java A asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/FeedRecordDataFlowController.java A asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/FeedStreamDataFlowController.java A asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/FeedTupleForwarder.java M asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/RecordDataFlowController.java M asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/StreamDataFlowController.java R asterix-external-data/src/main/java/org/apache/asterix/external/dataset/adapter/AdapterIdentifier.java M 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/dataset/adapter/StreamBasedAdapter.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/ICentralFeedManager.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IExceptionHandler.java A asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeed.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedConnectionManager.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedFrameHandler.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedJoint.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedLifecycleEventSubscriber.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedLifecycleIntakeEventSubscriber.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedLifecycleListener.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedLoadManager.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedManager.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMemoryComponent.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMemoryManager.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMessage.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMessageService.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMetadataManager.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedMetricCollector.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedOperatorOutputSideHandler.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedProvider.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedRuntime.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedService.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedSubscriptionManager.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedTrackingManager.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedWork.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedWorkEventListener.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFeedWorkManager.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFrameEventCallback.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFramePostProcessor.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IFramePreprocessor.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IIntakeProgressTracker.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IMessageReceiver.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/ISubscribableRuntime.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/ISubscriberRuntime.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/ISubscriptionProvider.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/CollectTransformFeedFrameWriter.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/DataBucket.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/DataBucketPool.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/DistributeFeedFrameWriter.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedCollectRuntimeInputHandler.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedExceptionHandler.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameCache.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameCollector.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameDiscarder.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameHandlers.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameSpiller.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameTupleAccessor.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedFrameTupleDecorator.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedRuntimeInputHandler.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FrameCollection.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FrameDistributor.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FrameEventCallback.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/StorageFrameHandler.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedCollectInfo.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionId.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionManager.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedConnectionRequest.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedId.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedInfo.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedJointKey.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedLifecycleEventSubscriber.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedManager.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedMemoryManager.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedMetadataManager.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedRuntimeManager.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedSubscriptionManager.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/management/FeedWorkManager.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/EndFeedMessage.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedCongestionMessage.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedMessage.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedMessageService.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedReportMessage.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedTupleCommitAckMessage.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/FeedTupleCommitResponseMessage.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/MessageListener.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/MessageReceiver.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/NodeReportMessage.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/PrepareStallMessage.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/RemoteSocketMessageListener.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/ScaleInReportMessage.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/SocketMessageListener.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/StorageReportFeedMessage.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/TerminateDataFlowMessage.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/ThrottlingEnabledFeedMessage.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/message/XAQLFeedMessage.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/policy/FeedPolicy.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/policy/FeedPolicyAccessor.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/policy/FeedPolicyEnforcer.java A asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/AdapterExecutor.java A asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/AdapterRuntimeManager.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/CollectionRuntime.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/FeedRuntime.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/FeedRuntimeId.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/IngestionRuntime.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/SubscribableFeedRuntimeId.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/SubscribableRuntime.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/BasicMonitoredBuffer.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/ComputeSideMonitoredBuffer.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedActivity.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedConnectJobInfo.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedIntakeInfo.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedJobInfo.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FeedMetricCollector.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/IntakePartitionStatistics.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/IntakeSideMonitoredBuffer.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/MonitoredBuffer.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/MonitoredBufferTimerTasks.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/NodeLoad.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/NodeLoadReport.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/NodeLoadReportService.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/Series.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/SeriesAvg.java R asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/SeriesRate.java R 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/record/reader/AbstractStreamRecordReader.java M asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/LineRecordReader.java M asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/QuotedLineRecordReader.java M asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/SemiStructuredRecordReader.java M asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/TwitterPushRecordReader.java M asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/factory/TwitterRecordReaderFactory.java M asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/AInputStreamReader.java M asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/HDFSInputStreamProvider.java M asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/LocalFSInputStreamProvider.java A asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/LocalFileSystemInputStream.java M asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/TwitterFirehoseInputStreamProvider.java M asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/factory/LocalFSInputStreamProviderFactory.java M asterix-external-data/src/main/java/org/apache/asterix/external/library/ExternalFunction.java M asterix-external-data/src/main/java/org/apache/asterix/external/library/ResultCollector.java M asterix-external-data/src/main/java/org/apache/asterix/external/library/java/JObjectUtil.java R asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalDataScanOperatorDescriptor.java M asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalDatasetIndexesRecoverOperatorDescriptor.java R asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedCollectOperatorDescriptor.java R asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedCollectOperatorNodePushable.java R asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedIntakeOperatorDescriptor.java R asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedIntakeOperatorNodePushable.java R asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMessageOperatorDescriptor.java R asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMessageOperatorNodePushable.java R asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaComputeNodePushable.java R asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaNodePushable.java R asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaOperatorDescriptor.java R 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/ADMDataParser.java M asterix-external-data/src/main/java/org/apache/asterix/external/parser/DelimitedDataParser.java M asterix-external-data/src/main/java/org/apache/asterix/external/provider/AdapterFactoryProvider.java M asterix-external-data/src/main/java/org/apache/asterix/external/provider/DataflowControllerProvider.java M asterix-external-data/src/main/java/org/apache/asterix/external/provider/DatasourceFactoryProvider.java D asterix-external-data/src/main/java/org/apache/asterix/external/runtime/GenericSocketFeedAdapter.java D asterix-external-data/src/main/java/org/apache/asterix/external/runtime/GenericSocketFeedAdapterFactory.java D asterix-external-data/src/main/java/org/apache/asterix/external/runtime/SocketClientAdapter.java D asterix-external-data/src/main/java/org/apache/asterix/external/runtime/SocketClientAdapterFactory.java R asterix-external-data/src/main/java/org/apache/asterix/external/util/DataGenerator.java M asterix-external-data/src/main/java/org/apache/asterix/external/util/DataflowUtils.java M asterix-external-data/src/main/java/org/apache/asterix/external/util/Datatypes.java M asterix-external-data/src/main/java/org/apache/asterix/external/util/ExternalDataCompatibilityUtils.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/ExternalDataExceptionUtils.java M asterix-external-data/src/main/java/org/apache/asterix/external/util/ExternalDataUtils.java R asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedConstants.java R asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedFrameUtil.java A asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedLogManager.java A asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedUtils.java A asterix-external-data/src/main/java/org/apache/asterix/external/util/FileSystemWatcher.java A asterix-external-data/src/main/java/org/apache/asterix/external/util/LocalFileSystemUtils.java R asterix-external-data/src/main/java/org/apache/asterix/external/util/NodeResolverFactory.java R asterix-external-data/src/main/java/org/apache/asterix/external/util/TweetGenerator.java D asterix-external-data/src/main/java/org/apache/asterix/external/util/TweetProcessor.java M asterix-external-data/src/test/java/org/apache/asterix/external/library/UpperCaseFunction.java M asterix-external-data/src/test/java/org/apache/asterix/external/library/adapter/TestTypedAdapter.java M asterix-external-data/src/test/java/org/apache/asterix/external/library/adapter/TestTypedAdapterFactory.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/statement/DatasetDecl.java M asterix-lang-common/src/main/java/org/apache/asterix/lang/common/visitor/FormatPrintVisitor.java M asterix-lang-sqlpp/src/main/java/org/apache/asterix/lang/sqlpp/visitor/VariableCheckAndRewriteVisitor.java M asterix-lang-sqlpp/src/main/javacc/SQLPP.jj 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/IMetadataEntity.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/MetadataIndex.java M asterix-metadata/src/main/java/org/apache/asterix/metadata/bootstrap/MetadataIndexImmutableProperties.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/FeedDataSource.java M asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/CompactionPolicy.java M asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/Dataset.java M asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/DatasourceAdapter.java M asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/Datatype.java M asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/Dataverse.java M asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/Feed.java A asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/FeedPolicyEntity.java M asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/Function.java M asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/Index.java M asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/Library.java M asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/NodeGroup.java D asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/PrimaryFeed.java D asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/SecondaryFeed.java M asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/DatasourceAdapterTupleTranslator.java M asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/FeedPolicyTupleTranslator.java M asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/FeedTupleTranslator.java D asterix-metadata/src/main/java/org/apache/asterix/metadata/feeds/AbstractDatasourceAdapter.java D asterix-metadata/src/main/java/org/apache/asterix/metadata/feeds/AbstractFeedDatasourceAdapter.java D asterix-metadata/src/main/java/org/apache/asterix/metadata/feeds/AdapterExecutor.java D asterix-metadata/src/main/java/org/apache/asterix/metadata/feeds/AdapterRuntimeManager.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/FeedActivityIdFactory.java R asterix-metadata/src/main/java/org/apache/asterix/metadata/feeds/FeedMetadataUtil.java D asterix-metadata/src/main/java/org/apache/asterix/metadata/feeds/IAdapterExecutor.java D asterix-metadata/src/main/java/org/apache/asterix/metadata/feeds/IFeedMessage.java D asterix-metadata/src/main/java/org/apache/asterix/metadata/feeds/ITypedAdapterFactory.java D asterix-metadata/src/main/java/org/apache/asterix/metadata/feeds/MessageListener.java M asterix-metadata/src/main/java/org/apache/asterix/metadata/utils/DatasetUtils.java M asterix-metadata/src/main/java/org/apache/asterix/metadata/utils/SplitsAndConstraintsUtil.java M asterix-om/src/main/java/org/apache/asterix/om/util/AsterixClusterProperties.java 277 files changed, 3,320 insertions(+), 3,058 deletions(-) Approvals: Murtadha Hubail: Looks good to me, approved Jenkins: Verified -- To view, visit https://asterix-gerrit.ics.uci.edu/574 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: merged Gerrit-Change-Id: I4e8db26a810efd1fbaa52ceeb3efd0c8328ab070 Gerrit-PatchSet: 7 Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Owner: abdullah alamoudi <[email protected]> Gerrit-Reviewer: Jenkins <[email protected]> Gerrit-Reviewer: Murtadha Hubail <[email protected]> Gerrit-Reviewer: abdullah alamoudi <[email protected]>
