asterixdb-notifications mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "abdullah alamoudi (Code Review)" <do-not-re...@asterixdb.incubator.apache.org>
Subject Change in asterixdb[master]: Feed Fixes and Cleanup
Date Tue, 12 Jan 2016 06:53:01 GMT
Hello Jenkins,

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

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

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

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 but now we have
   a deadlock.

Change-Id: I4e8db26a810efd1fbaa52ceeb3efd0c8328ab070
---
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
C asterix-common/src/main/java/org/apache/asterix/common/api/INodeFeedManager.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/FeedExceptionHandler.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
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/IAdapterExecutor.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
C asterix-external-data/src/main/java/org/apache/asterix/external/feed/api/IPrimaryFeed.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
A 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/FeedActivityIdFactory.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/FeedRuntimeReport.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
A asterix-external-data/src/main/java/org/apache/asterix/external/feed/watch/FileSystemFeedProgressTracker.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
M asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/PrimaryFeed.java
M 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/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
R asterix-metadata/src/main/java/org/apache/asterix/metadata/feeds/MetadataFeedUtil.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
280 files changed, 3,536 insertions(+), 3,039 deletions(-)


  git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb refs/changes/74/574/5
-- 
To view, visit https://asterix-gerrit.ics.uci.edu/574
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings

Gerrit-MessageType: newpatchset
Gerrit-Change-Id: I4e8db26a810efd1fbaa52ceeb3efd0c8328ab070
Gerrit-PatchSet: 5
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: abdullah alamoudi <bamousaa@gmail.com>
Gerrit-Reviewer: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Mime
View raw message