Hello Jenkins,
I'd like you to reexamine a change. Please visit
https://asterix-gerrit.ics.uci.edu/621
to look at the new patch set (#9).
Change subject: Support Change Feeds and Ingestion of Records with MetaData
......................................................................
Support Change Feeds and Ingestion of Records with MetaData
This change allows feeds to perform upserts and deletes
in order to perform replication of an external data source.
The change does so by performing the following:
1. The adapter produces [PK][Record]. (Record == null --> delete)
2. The insert is replaced by an upsert operator.
Change-Id: If136a03d424970132dfb09f0dda56e160d4c0078
---
M
asterix-algebra/src/main/java/org/apache/asterix/optimizer/base/RuleCollections.java
A
asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/FunctionToVariableRule.java
M
asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceDynamicTypeCastRule.java
M
asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/IntroduceStaticTypeCastForInsertRule.java
D
asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/MetaFunctionToMetaVariableRule.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/SetClosedRecordConstructorsRule.java
M
asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/UnnestToDataScanRule.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
A asterix-app/data/csv/beer.csv
M
asterix-app/src/main/java/org/apache/asterix/app/external/ExternalIndexingOperations.java
M asterix-app/src/main/java/org/apache/asterix/file/DatasetOperations.java
M asterix-app/src/test/java/org/apache/asterix/test/optimizer/OptimizerTest.java
M
asterix-app/src/test/resources/optimizerts/results/disjunction-to-join-delete-3.plan
M
asterix-app/src/test/resources/runtimets/queries/external-library/classad-parser/classad-parser.3.ddl.aql
M
asterix-app/src/test/resources/runtimets/queries/external-library/classad-parser2/classad-parser2.3.ddl.aql
A
asterix-app/src/test/resources/runtimets/queries/feeds/change-feed-with-meta-pk-in-meta/change-feed-with-meta-pk-in-meta.1.ddl.aql
C
asterix-app/src/test/resources/runtimets/queries/feeds/change-feed-with-meta-pk-in-meta/change-feed-with-meta-pk-in-meta.2.update.aql
C
asterix-app/src/test/resources/runtimets/queries/feeds/change-feed-with-meta-pk-in-meta/change-feed-with-meta-pk-in-meta.3.sleep.aql
C
asterix-app/src/test/resources/runtimets/queries/feeds/change-feed-with-meta-pk-in-meta/change-feed-with-meta-pk-in-meta.4.ddl.aql
A
asterix-app/src/test/resources/runtimets/queries/feeds/change-feed/change-feed.1.ddl.aql
C
asterix-app/src/test/resources/runtimets/queries/feeds/change-feed/change-feed.2.update.aql
C
asterix-app/src/test/resources/runtimets/queries/feeds/change-feed/change-feed.3.query.aql
C
asterix-app/src/test/resources/runtimets/queries/feeds/change-feed/change-feed.4.ddl.aql
M
asterix-app/src/test/resources/runtimets/queries/feeds/feed-with-external-parser/feed-with-external-parser.3.ddl.aql
A
asterix-app/src/test/resources/runtimets/queries/feeds/feed-with-meta-pk-in-meta/feed-with-meta-pk-in-meta.1.ddl.aql
C
asterix-app/src/test/resources/runtimets/queries/feeds/feed-with-meta-pk-in-meta/feed-with-meta-pk-in-meta.2.update.aql
C
asterix-app/src/test/resources/runtimets/queries/feeds/feed-with-meta-pk-in-meta/feed-with-meta-pk-in-meta.3.sleep.aql
C
asterix-app/src/test/resources/runtimets/queries/feeds/feed-with-meta-pk-in-meta/feed-with-meta-pk-in-meta.4.ddl.aql
M
asterix-app/src/test/resources/runtimets/queries/feeds/feeds_02/feeds_02.1.ddl.aql
M
asterix-app/src/test/resources/runtimets/queries/feeds/feeds_07/feeds_07.1.ddl.aql
M
asterix-app/src/test/resources/runtimets/queries/feeds/feeds_08/feeds_08.1.ddl.aql
M
asterix-app/src/test/resources/runtimets/queries/feeds/feeds_09/feeds_09.1.ddl.aql
M
asterix-app/src/test/resources/runtimets/queries/feeds/feeds_10/feeds_10.1.ddl.aql
M
asterix-app/src/test/resources/runtimets/queries/feeds/feeds_11/feeds_11.1.ddl.aql
M
asterix-app/src/test/resources/runtimets/queries/feeds/feeds_12/feeds_12.1.ddl.aql
M
asterix-app/src/test/resources/runtimets/queries/feeds/issue_230_feeds/issue_230_feeds.1.ddl.aql
M
asterix-app/src/test/resources/runtimets/queries/hdfs/large-record/large-record.1.ddl.aql
M
asterix-app/src/test/resources/runtimets/queries/hints/issue_251_dataset_hint_7/issue_251_dataset_hint_7.1.ddl.aql
M
asterix-app/src/test/resources/runtimets/queries/open-index-enforced/external-indexing/adm-format/adm-format.1.ddl.aql
M
asterix-app/src/test/resources/runtimets/queries/upsert/nested-index/nested-index.2.update.aql
M
asterix-app/src/test/resources/runtimets/queries_sqlpp/hints/issue_251_dataset_hint_7/issue_251_dataset_hint_7.1.ddl.sqlpp
M
asterix-app/src/test/resources/runtimets/results/external-library/classad-parser/classad-parser.1.adm
A
asterix-app/src/test/resources/runtimets/results/feeds/change-feed/change-feed.1.adm
M
asterix-app/src/test/resources/runtimets/results/feeds/feed-with-external-parser/feed-with-external-parser.1.adm
A
asterix-app/src/test/resources/runtimets/results/feeds/feed-with-meta-pk-in-meta/feed-with-meta-pk-in-meta.1.adm
M asterix-app/src/test/resources/runtimets/testsuite.xml
M asterix-app/src/test/resources/runtimets/testsuite_sqlpp.xml
M
asterix-common/src/main/java/org/apache/asterix/common/config/AsterixPropertiesAccessor.java
M
asterix-common/src/test/java/org/apache/asterix/test/server/FileTestServer.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/adapter/factory/LookupAdapterFactory.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/api/IAdapterFactory.java
M
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
M
asterix-external-data/src/main/java/org/apache/asterix/external/api/IDataParser.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/api/IDataParserFactory.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/api/IExternalDataSourceFactory.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/api/IExternalIndexer.java
D
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/IIndexibleExternalDataSource.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/api/IIndexingDatasource.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/api/IInputStreamProvider.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/api/IInputStreamProviderFactory.java
R
asterix-external-data/src/main/java/org/apache/asterix/external/api/IRecordConverter.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/api/IRecordDataParser.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/api/IRecordDataParserFactory.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/api/IRecordReader.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/api/IRecordReaderFactory.java
C
asterix-external-data/src/main/java/org/apache/asterix/external/api/IRecordWithMetaDataAndPKParser.java
C
asterix-external-data/src/main/java/org/apache/asterix/external/api/IRecordWithMetaDataParser.java
C
asterix-external-data/src/main/java/org/apache/asterix/external/api/IRecordWithPKDataParser.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/api/IStreamDataParserFactory.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/api/ITupleForwarder.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/AbstractDataFlowController.java
M
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/ChangeFeedDataFlowController.java
A
asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/ChangeFeedWithMetaDataFlowController.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/CounterTimerTupleForwarder.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/FeedRecordDataFlowController.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/FeedStreamDataFlowController.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/FeedTupleForwarder.java
A
asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/FeedWithMetaDataFlowController.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/FrameFullTupleForwarder.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/IndexingDataFlowController.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/dataflow/RateControlledTupleForwarder.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
A
asterix-external-data/src/main/java/org/apache/asterix/external/dataset/adapter/FeedAdapter.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/dataset/adapter/GenericAdapter.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedExceptionHandler.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FeedRuntimeInputHandler.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/feed/dataflow/FrameDistributor.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/AdapterExecutor.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/feed/runtime/AdapterRuntimeManager.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/indexing/FileOffsetIndexer.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/indexing/RecordColumnarIndexer.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/HDFSDataSourceFactory.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/CharArrayRecord.java
D
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/RecordWithMetadata.java
A
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/RecordWithMetadataAndPK.java
A
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/RecordWithPK.java
A
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/converter/CSVToRecordWithMetadataAndPKConverter.java
A
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/converter/CSVWithRecordConverterFactory.java
A
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/converter/DCPConverterFactory.java
A
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/converter/DCPRequestToRecordWithMetadataAndPKConverter.java
A
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/converter/IRecordConverterFactory.java
C
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/converter/IRecordToRecordWithMetadataAndPKConverter.java
A
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/RecordWithPKTestReaderFactory.java
A
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/TestAsterixMembersReader.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/couchbase/CouchbaseReader.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/couchbase/CouchbaseReaderFactory.java
A
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/couchbase/CouchbaseTestReader.java
A
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/couchbase/CouchbaseTestReaderFactory.java
R
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/hdfs/EmptyRecordReader.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/hdfs/HDFSLookupReaderFactory.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/hdfs/HDFSRecordReader.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/rss/RSSRecordReader.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/rss/RSSRecordReaderFactory.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/stream/AbstractStreamRecordReader.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/stream/AbstractStreamRecordReaderFactory.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/stream/EmptyLineSeparatedRecordReader.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/stream/EmptyLineSeparatedRecordReaderFactory.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/stream/LineRecordReader.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/stream/LineRecordReaderFactory.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/stream/QuotedLineRecordReader.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/stream/SemiStructuredRecordReader.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/stream/SemiStructuredRecordReaderFactory.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/twitter/TwitterPullRecordReader.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/twitter/TwitterPushRecordReader.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/twitter/TwitterRecordReaderFactory.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/AInputStream.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/BasicInputStream.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/LocalFileSystemInputStream.java
R
asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/SocketServerInputStream.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/factory/LocalFSInputStreamProviderFactory.java
A
asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/factory/SocketClientInputStreamProviderFactory.java
D
asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/factory/SocketInputStreamProviderFactory.java
A
asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/factory/SocketServerInputStreamProviderFactory.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/factory/TwitterFirehoseStreamProviderFactory.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/provider/HDFSInputStreamProvider.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/provider/LocalFSInputStreamProvider.java
A
asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/provider/SocketClientInputStreamProvider.java
R
asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/provider/SocketServerInputStreamProvider.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/provider/TwitterFirehoseInputStreamProvider.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/operators/ExternalDatasetIndexesCommitOperatorDescriptor.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedIntakeOperatorDescriptor.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedIntakeOperatorNodePushable.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/operators/FeedMetaOperatorDescriptor.java
M
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/parser/HiveRecordParser.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/parser/RSSParser.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/parser/RecordWithMetadataParser.java
A
asterix-external-data/src/main/java/org/apache/asterix/external/parser/RecordWithPKDataParser.java
A
asterix-external-data/src/main/java/org/apache/asterix/external/parser/TestRecordWithPKParser.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/parser/TweetParser.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/parser/factory/ADMDataParserFactory.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/parser/factory/AbstractRecordStreamParserFactory.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/parser/factory/DelimitedDataParserFactory.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/parser/factory/HiveDataParserFactory.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/parser/factory/RSSParserFactory.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/parser/factory/RecordWithMetadataParserFactory.java
A
asterix-external-data/src/main/java/org/apache/asterix/external/parser/factory/TestRecordWithPKParserFactory.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/parser/factory/TweetParserFactory.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
M
asterix-external-data/src/main/java/org/apache/asterix/external/provider/LookupReaderFactoryProvider.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/provider/ParserFactoryProvider.java
A
asterix-external-data/src/main/java/org/apache/asterix/external/provider/RecordConverterFactoryProvider.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/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/ExternalDataUtils.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedLogManager.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/util/FeedUtils.java
M
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/HDFSUtils.java
M
asterix-external-data/src/main/java/org/apache/asterix/external/util/TweetGenerator.java
M
asterix-external-data/src/test/java/org/apache/asterix/external/classad/BuiltinClassAdFunctions.java
M
asterix-external-data/src/test/java/org/apache/asterix/external/classad/ClassAd.java
M
asterix-external-data/src/test/java/org/apache/asterix/external/classad/test/ClassAdParserTest.java
M
asterix-external-data/src/test/java/org/apache/asterix/external/classad/test/ClassAdToADMTest.java
M
asterix-external-data/src/test/java/org/apache/asterix/external/classad/test/ClassAdUnitTest.java
M
asterix-external-data/src/test/java/org/apache/asterix/external/classad/test/ClassAdUnitTester.java
M
asterix-external-data/src/test/java/org/apache/asterix/external/classad/test/FunctionalTester.java
A
asterix-external-data/src/test/java/org/apache/asterix/external/generator/test/DCPGeneratorTest.java
M
asterix-external-data/src/test/java/org/apache/asterix/external/library/ClassAdParser.java
M
asterix-external-data/src/test/java/org/apache/asterix/external/library/ClassAdParserFactory.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-external-data/src/test/java/org/apache/asterix/external/parser/test/ADMDataParserTest.java
A
asterix-external-data/src/test/java/org/apache/asterix/external/parser/test/RecordWithMetaTest.java
A asterix-external-data/src/test/resources/beer.csv
A asterix-external-data/src/test/resources/results/beer.txt
M
asterix-installer/src/test/java/org/apache/asterix/installer/test/AbstractExecutionIT.java
M
asterix-installer/src/test/java/org/apache/asterix/installer/test/ClusterExecutionIT.java
M
asterix-installer/src/test/resources/integrationts/library/queries/library-adapters/typed_adapter/typed_adapter.1.ddl.aql
M
asterix-installer/src/test/resources/integrationts/library/queries/library-feeds/feed_ingest/feed_ingest.1.ddl.aql
M
asterix-installer/src/test/resources/integrationts/library/queries/library-parsers/record-parser/record-parser.1.ddl.aql
A
asterix-installer/src/test/resources/integrationts/library/results/library-parsers/record-parser/record-parser.1.adm
M
asterix-installer/src/test/resources/integrationts/lifecycle/results/asterix-lifecycle/backupRestore/backupRestore.1.adm
M
asterix-installer/src/test/resources/integrationts/replication/queries/failback/node_failback/node_failback.2.update.aql
M
asterix-lang-aql/src/main/java/org/apache/asterix/lang/aql/statement/SubscribeFeedStatement.java
M
asterix-metadata/src/main/java/org/apache/asterix/metadata/declared/AqlDataSource.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/feeds/FeedMetadataUtil.java
M
asterix-metadata/src/main/java/org/apache/asterix/metadata/utils/DatasetUtils.java
M asterix-om/src/main/java/org/apache/asterix/om/types/ARecordType.java
M
asterix-runtime/src/main/java/org/apache/asterix/runtime/operators/AsterixLSMPrimaryUpsertOperatorNodePushable.java
M
asterix-runtime/src/main/java/org/apache/asterix/runtime/operators/AsterixLSMSecondaryUpsertOperatorNodePushable.java
217 files changed, 31,077 insertions(+), 3,033 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/21/621/9
--
To view, visit https://asterix-gerrit.ics.uci.edu/621
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: newpatchset
Gerrit-Change-Id: If136a03d424970132dfb09f0dda56e160d4c0078
Gerrit-PatchSet: 9
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: abdullah alamoudi <[email protected]>
Gerrit-Reviewer: Ildar Absalyamov <[email protected]>
Gerrit-Reviewer: Jenkins <[email protected]>
Gerrit-Reviewer: Steven Jacobs <[email protected]>
Gerrit-Reviewer: Till Westmann <[email protected]>
Gerrit-Reviewer: Yingyi Bu <[email protected]>
Gerrit-Reviewer: abdullah alamoudi <[email protected]>
