merge with master
Project: http://git-wip-us.apache.org/repos/asf/asterixdb/repo Commit: http://git-wip-us.apache.org/repos/asf/asterixdb/commit/1f7ac985 Tree: http://git-wip-us.apache.org/repos/asf/asterixdb/tree/1f7ac985 Diff: http://git-wip-us.apache.org/repos/asf/asterixdb/diff/1f7ac985 Branch: refs/heads/ecarm002/interval_join_merge Commit: 1f7ac9850459eb2f4cfe003661ceaa5d5fabb1d7 Parents: ff7904d 81b1f21 Author: Preston Carman <prest...@apache.org> Authored: Mon Jul 11 15:22:49 2016 -0700 Committer: Preston Carman <prest...@apache.org> Committed: Mon Jul 11 15:22:49 2016 -0700 ---------------------------------------------------------------------- README.md | 6 +- asterixdb/asterix-algebra/pom.xml | 29 +- .../physical/ExternalDataLookupPOperator.java | 4 +- .../asterix/optimizer/base/RuleCollections.java | 4 +- ...IntroduceSecondaryIndexInsertDeleteRule.java | 84 +- .../optimizer/rules/ResolveVariableRule.java | 286 + .../rules/SetClosedRecordConstructorsRule.java | 35 +- .../optimizer/rules/UnnestToDataScanRule.java | 7 +- .../am/AbstractIntroduceAccessMethodRule.java | 186 +- .../LangExpressionToPlanTranslator.java | 415 +- .../SqlppExpressionToPlanTranslator.java | 163 +- .../asterix-algebra/src/main/javacc/AQLPlus.jj | 4 +- asterixdb/asterix-app/pom.xml | 16 +- asterixdb/asterix-app/scripts/idefix/startcc.sh | 4 +- .../api/common/AsterixAppRuntimeContext.java | 17 +- .../asterix/api/common/SessionConfig.java | 7 +- .../asterix/api/http/servlet/APIServlet.java | 38 +- .../asterix/api/http/servlet/JSONUtil.java | 136 - .../api/http/servlet/QueryResultAPIServlet.java | 2 +- .../api/http/servlet/QueryServiceServlet.java | 359 +- .../external/ExternalIndexingOperations.java | 58 +- .../external/ExternalLibraryClassLoader.java | 56 + .../app/external/ExternalLibraryUtils.java | 35 +- .../app/external/FeedWorkCollection.java | 2 +- .../asterix/aql/translator/QueryTranslator.java | 78 +- .../apache/asterix/file/DatasetOperations.java | 4 +- .../apache/asterix/file/IndexOperations.java | 42 +- .../file/SecondaryBTreeOperationsHelper.java | 33 +- .../file/SecondaryIndexOperationsHelper.java | 49 +- .../SecondaryInvertedIndexOperationsHelper.java | 30 +- .../file/SecondaryRTreeOperationsHelper.java | 4 +- .../bootstrap/CCApplicationEntryPoint.java | 10 +- .../bootstrap/NCApplicationEntryPoint.java | 8 +- .../org/apache/asterix/result/ResultUtils.java | 80 +- asterixdb/asterix-app/src/main/scripts/run.sh | 2 +- .../http/servlet/QueryServiceServletTest.java | 45 + .../asterix/app/external/TestLibrarian.java | 35 +- .../asterix/test/runtime/ExecutionTest.java | 12 +- .../asterix/test/runtime/ExecutionTestUtil.java | 20 +- .../asterix/test/runtime/RepeatedTest.java | 4 - .../asterix/test/sqlpp/ParserTestExecutor.java | 3 + .../asterix-app/src/test/resources/dapd/q2.aql | 12 +- .../src/test/resources/logging.properties | 4 +- .../dataset_with_meta-1.1.adm | 2 +- .../dataset_with_meta-2.1.adm | 2 +- .../dataset_with_meta-2.3.adm | 2 +- .../dataset_with_meta-4.3.adm | 2 +- .../dataset_with_meta-5.3.adm | 2 +- .../dataset_with_meta-6.3.adm | 4 +- .../dataset_with_meta-7.3.adm | 4 +- .../issue_251_dataset_hint_2.1.adm | 2 +- .../issue_251_dataset_hint_3.1.adm | 2 +- .../issue_251_dataset_hint_4.1.adm | 2 +- .../metadata/results/basic/meta01/meta01.1.adm | 4 +- .../metadata/results/basic/meta02/meta02.1.adm | 2 +- .../metadata/results/basic/meta05/meta05.1.adm | 4 +- .../metadata/results/basic/meta09/meta09.1.adm | 2 +- .../metadata/results/basic/meta12/meta12.1.adm | 2 +- .../metadata/results/basic/meta16/meta16.1.adm | 4 +- .../metadata/results/basic/meta17/meta17.1.adm | 4 +- .../metadata_dataset/metadata_dataset.1.adm | 26 +- .../metadata_dataverse/metadata_dataverse.1.adm | 6 +- .../basic/metadata_index/metadata_index.1.adm | 26 +- ...verify_failure_subsequent_no_execution.1.adm | 2 +- .../nontagged/custord/local/cust-load.aql | 10 +- ...rjoin-probe-pidx-with-join-btree-sidx_01.aql | 30 +- ...rjoin-probe-pidx-with-join-btree-sidx_02.aql | 30 +- .../queries/btree-index/btree-datetime-01.aql | 6 +- .../queries/btree-index/btree-datetime-02.aql | 8 +- .../queries/btree-index/btree-datetime-03.aql | 8 +- .../queries/btree-index/btree-datetime-04.aql | 6 +- .../optimizerts/queries/distinct_aggregate.aql | 52 +- .../insert-and-scan-dataset-with-index.aql | 14 +- .../queries/insert-and-scan-dataset.aql | 6 +- .../queries/insert-and-scan-joined-datasets.aql | 10 +- .../queries/inverted-index-join/issue741.aql | 12 +- ...idx-with-join-edit-distance-check-idx_01.aql | 30 +- ...robe-pidx-with-join-jaccard-check-idx_01.aql | 30 +- .../word-jaccard-check-after-btree-access.aql | 36 +- .../optimizerts/queries/limit-issue353.aql | 28 +- .../meta/secondary_index-lojoin_with_meta-1.aql | 51 + .../meta/secondary_index-nljoin_with_meta-1.aql | 40 + .../meta/secondary_index-nljoin_with_meta-2.aql | 46 + .../meta/secondary_index-nljoin_with_meta-3.aql | 40 + .../meta/secondary_index-nljoin_with_meta-4.aql | 43 + .../meta/secondary_index_with_meta-1.aql | 39 + .../meta/secondary_index_with_meta-2.aql | 39 + ...rjoin-probe-pidx-with-join-btree-sidx_01.aql | 24 +- ...rjoin-probe-pidx-with-join-btree-sidx_02.aql | 26 +- ...idx-with-join-edit-distance-check-idx_01.aql | 30 +- ...robe-pidx-with-join-jaccard-check-idx_01.aql | 30 +- .../word-jaccard-check-after-btree-access.aql | 34 +- ...rjoin-probe-pidx-with-join-rtree-sidx_01.aql | 26 +- ...rjoin-probe-pidx-with-join-rtree-sidx_02.aql | 26 +- ...oin-probe-pidx-with-join-btree-sidx_01_1.aql | 22 +- ...oin-probe-pidx-with-join-btree-sidx_01_2.aql | 20 +- ...oin-probe-pidx-with-join-btree-sidx_02_1.aql | 22 +- ...oin-probe-pidx-with-join-btree-sidx_02_2.aql | 20 +- ...idx-with-join-edit-distance-check-idx_01.aql | 28 +- .../word-jaccard-check-after-btree-access.aql | 32 +- ...rjoin-probe-pidx-with-join-rtree-sidx_01.aql | 24 +- ...rjoin-probe-pidx-with-join-rtree-sidx_02.aql | 24 +- ...oin-probe-pidx-with-join-btree-sidx_01_1.aql | 16 +- ...oin-probe-pidx-with-join-btree-sidx_01_2.aql | 16 +- ...oin-probe-pidx-with-join-btree-sidx_02_1.aql | 20 +- ...oin-probe-pidx-with-join-btree-sidx_02_2.aql | 18 +- .../secondary-composite-key-join_01.aql | 6 +- .../secondary-composite-key-join_02.aql | 6 +- .../secondary-composite-key-join_03.aql | 6 +- .../secondary-composite-key-prefix-join_01.aql | 6 +- .../secondary-composite-key-prefix-join_02.aql | 6 +- .../secondary-composite-key-prefix-join_03.aql | 6 +- .../secondary-composite-key-prefix-join_04.aql | 6 +- .../secondary-composite-key-prefix-join_05.aql | 6 +- .../secondary-composite-key-prefix-join_06.aql | 6 +- ...idx-with-join-edit-distance-check-idx_01.aql | 22 +- .../word-jaccard-check-after-btree-access.aql | 30 +- ...rjoin-probe-pidx-with-join-rtree-sidx_01.aql | 22 +- ...rjoin-probe-pidx-with-join-rtree-sidx_02.aql | 22 +- .../optimizerts/queries/q09_group_by.aql | 82 +- .../test/resources/optimizerts/queries/q2.aql | 4 +- ...rjoin-probe-pidx-with-join-rtree-sidx_01.aql | 30 +- ...rjoin-probe-pidx-with-join-rtree-sidx_02.aql | 30 +- .../queries/scan-insert-secondary-index.aql | 42 +- .../optimizerts/queries/scan-insert.aql | 40 +- .../optimizerts/queries/subquery/in.sqlpp | 44 + .../queries/subquery/in_correlated.sqlpp | 46 + .../btree-index/btree-datetime-01.sqlpp | 2 +- .../btree-index/btree-datetime-02.sqlpp | 2 +- .../btree-index/btree-datetime-03.sqlpp | 2 +- .../btree-index/btree-datetime-04.sqlpp | 2 +- .../disjunction-to-join-delete-1.sqlpp | 4 +- .../disjunction-to-join-delete-2.sqlpp | 4 +- .../disjunction-to-join-delete-3.sqlpp | 4 +- .../word-jaccard-check-after-btree-access.sqlpp | 4 +- .../queries_sqlpp/limit-issue353.sqlpp | 2 +- .../word-jaccard-check-after-btree-access.sqlpp | 4 +- .../word-jaccard-check-after-btree-access.sqlpp | 4 +- .../word-jaccard-check-after-btree-access.sqlpp | 4 +- .../queries_sqlpp/query-issue697.sqlpp | 2 +- .../queries_sqlpp/scan-delete-all.sqlpp | 3 +- .../scan-delete-rtree-secondary-index.sqlpp | 4 +- .../optimizerts/queries_sqlpp/scan-delete.sqlpp | 4 +- ...nt-skip-primary-index-search-in-delete.sqlpp | 4 +- .../skip-ngram-index-search-in-delete.sqlpp | 4 +- .../skip-rtree-index-search-in-delete.sqlpp | 4 +- ...secondary-btree-index-search-in-delete.sqlpp | 4 +- .../skip-word-index-search-in-delete.sqlpp | 4 +- .../results/aggregate/constant-gby-agg.plan | 6 +- .../results/disjunction-to-join-delete-3.plan | 8 +- .../resources/optimizerts/results/loj-core.plan | 10 +- .../optimizerts/results/loj-sugar.plan | 10 +- .../secondary_index-lojoin_with_meta-1.plan | 47 + .../secondary_index-nljoin_with_meta-1.plan | 23 + .../secondary_index-nljoin_with_meta-2.plan | 23 + .../secondary_index-nljoin_with_meta-3.plan | 23 + .../secondary_index-nljoin_with_meta-4.plan | 23 + .../meta/secondary_index_with_meta-1.plan | 16 + .../meta/secondary_index_with_meta-2.plan | 15 + .../results/scan-insert-secondary-index.plan | 4 +- .../optimizerts/results/scan-insert.plan | 4 +- .../optimizerts/results/subquery/in.plan | 35 + .../results/subquery/in_correlated.plan | 33 + .../results_parser_sqlpp/query-issue697.ast | 4 +- .../resources/parserts/queries/functionDecl.aql | 4 +- .../resources/parserts/queries/nestedFLWOGR.aql | 6 +- .../parserts/queries/nestedFLWOGR1.aql | 8 +- .../parserts/queries/nestedFLWOGR2.aql | 8 +- .../parserts/results_parser_sqlpp/2.ast | 8 +- .../results_parser_sqlpp/columnalias.ast | 10 +- .../results_parser_sqlpp/columnalias2.ast | 4 +- .../results_parser_sqlpp/columnalias3.ast | 10 +- .../results_parser_sqlpp/nestedFLWOGR3.ast | 8 +- .../queries/binary/insert/insert.2.update.aql | 12 +- .../custord/join_q_04/join_q_04.2.update.aql | 2 +- .../custord/join_q_04/join_q_04.3.query.aql | 16 +- .../runtimets/queries/dapd/q2/q2.1.ddl.aql | 2 +- .../query-issue443/query-issue443.3.query.aql | 2 +- .../delete-multi-statement.1.ddl.aql | 76 +- ...ataset-with-index-on-open-field.2.update.aql | 10 +- ...ert-and-scan-dataset-with-index.2.update.aql | 14 +- .../insert-and-scan-dataset.2.update.aql | 8 +- ...insert-and-scan-joined-datasets.2.update.aql | 12 +- ...t-into-empty-dataset-with-index.2.update.aql | 16 +- .../insert-into-empty-dataset.2.update.aql | 16 +- ...to-loaded-dataset-with-index_01.4.update.aql | 12 +- ...to-loaded-dataset-with-index_02.4.update.aql | 12 +- .../insert-into-loaded-dataset_01.2.update.aql | 14 +- .../insert-record-function.2.update.aql | 16 +- .../queries/dml/insert/insert.2.update.aql | 16 +- .../insert_less_nc/insert_less_nc.2.update.aql | 16 +- .../load-with-index-open.2.update.aql | 6 +- .../load-with-ngram-index-open.2.update.aql | 4 +- .../load-with-rtree-index-open.2.update.aql | 6 +- .../load-with-word-index-open.2.update.aql | 4 +- .../opentype-c2o-recursive.2.update.aql | 8 +- .../dml/opentype-c2o/opentype-c2o.1.ddl.aql | 4 +- .../dml/opentype-c2o/opentype-c2o.2.update.aql | 16 +- .../dml/opentype-c2o/opentype-c2o.3.query.aql | 6 +- .../opentype-insert2/opentype-insert2.1.ddl.aql | 2 +- .../opentype-insert2.2.update.aql | 4 +- .../opentype-insert2.3.query.aql | 4 +- .../opentype-noexpand.1.ddl.aql | 6 +- .../opentype-noexpand.2.update.aql | 4 +- .../opentype-noexpand.3.query.aql | 6 +- .../opentype-o2c-recursive.2.update.aql | 8 +- .../dml/opentype-o2c/opentype-o2c.1.ddl.aql | 6 +- .../dml/opentype-o2c/opentype-o2c.2.update.aql | 10 +- .../dml/opentype-o2c/opentype-o2c.3.query.aql | 6 +- .../dml/opentype-o2o/opentype-o2o.1.ddl.aql | 4 +- .../dml/opentype-o2o/opentype-o2o.2.update.aql | 10 +- .../dml/opentype-o2o/opentype-o2o.3.query.aql | 6 +- .../query-issue205/query-issue205.2.update.aql | 2 +- .../query-issue205/query-issue205.3.query.aql | 2 +- .../query-issue288/query-issue288.2.update.aql | 10 +- .../dml/query-issue288/query-issue288.3.ddl.aql | 2 +- .../query-issue288/query-issue288.4.update.aql | 18 +- .../query-issue288/query-issue288.5.query.aql | 8 +- .../query-issue433/query-issue433.2.update.aql | 2 +- .../query-issue433/query-issue433.3.query.aql | 2 +- ...lete-btree-secondary-index-open.2.update.aql | 18 +- ...ndex-ngram-secondary-index-open.2.update.aql | 4 +- ...index-word-secondary-index-open.2.update.aql | 4 +- ...lete-rtree-secondary-index-open.2.update.aql | 4 +- ...-btree-secondary-index-nullable.4.update.aql | 20 +- ...sert-btree-secondary-index-open.4.update.aql | 20 +- ...-ngram-secondary-index-nullable.4.update.aql | 18 +- ...ndex-ngram-secondary-index-open.4.update.aql | 12 +- ...ted-index-ngram-secondary-index.4.update.aql | 18 +- ...x-word-secondary-index-nullable.4.update.aql | 18 +- ...index-word-secondary-index-open.4.update.aql | 12 +- ...rted-index-word-secondary-index.4.update.aql | 18 +- ...-rtree-secondary-index-nullable.4.update.aql | 10 +- ...sert-rtree-secondary-index-open.4.update.aql | 10 +- ...an-insert-rtree-secondary-index.4.update.aql | 10 +- ...-feed-with-meta-open-index-in-meta.1.ddl.aql | 59 + ...-feed-with-meta-open-index-in-meta.2.ddl.aql | 26 + ...meta-pk-in-meta-index-after-ingest.1.ddl.aql | 57 + ...a-pk-in-meta-index-after-ingest.2.update.aql | 28 + ...meta-pk-in-meta-index-after-ingest.3.ddl.aql | 27 + ...ta-pk-in-meta-index-after-ingest.4.query.aql | 31 + ...meta-pk-in-meta-index-after-ingest.5.ddl.aql | 25 + ...with-meta-pk-in-meta-index-in-meta.1.ddl.aql | 59 + ...h-meta-pk-in-meta-index-in-meta.2.update.aql | 28 + ...th-meta-pk-in-meta-index-in-meta.3.query.aql | 31 + ...with-meta-pk-in-meta-index-in-meta.4.ddl.aql | 25 + ...ta-index-with-missing-after-ingest.1.ddl.aql | 57 + ...index-with-missing-after-ingest.2.update.aql | 28 + ...ta-index-with-missing-after-ingest.3.ddl.aql | 27 + ...-index-with-missing-after-ingest.4.query.aql | 31 + ...ta-index-with-missing-after-ingest.5.ddl.aql | 25 + ...eta-pk-in-meta-open-index-in-value.1.ddl.aql | 59 + ...-pk-in-meta-open-index-in-value.2.update.aql | 28 + ...a-pk-in-meta-open-index-in-value.3.query.aql | 29 + ...eta-pk-in-meta-open-index-in-value.4.ddl.aql | 25 + ...pk-in-meta-open-index-with-missing.1.ddl.aql | 59 + ...in-meta-open-index-with-missing.2.update.aql | 28 + ...-in-meta-open-index-with-missing.3.query.aql | 29 + ...pk-in-meta-open-index-with-missing.4.ddl.aql | 25 + .../change-feed-with-meta-pk-in-meta.1.ddl.aql | 2 - ...ge-feed-with-meta-with-mixed-index.1.ddl.aql | 60 + ...feed-with-meta-with-mixed-index.2.update.aql | 28 + ...-feed-with-meta-with-mixed-index.3.query.aql | 30 + ...ge-feed-with-meta-with-mixed-index.4.ddl.aql | 25 + .../drop-nonexistent-feed.1.ddl.aql | 28 + .../feed-with-external-function.6.ddl.aql | 19 - .../feed-with-external-function.6.lib.aql | 19 + .../feed-with-external-function.7.ddl.aql | 19 + .../feed-with-external-function.7.lib.aql | 19 - .../queries/feeds/feeds_01/feeds_01.1.ddl.aql | 4 +- .../queries/feeds/feeds_03/feeds_03.1.ddl.aql | 4 +- .../queries/feeds/feeds_05/feeds_05.1.ddl.aql | 28 +- .../insert-with-secondary-btree.4.update.aql | 2 +- ...t-with-secondary-inverted-ngram.4.update.aql | 2 +- ...rt-with-secondary-inverted-word.4.update.aql | 2 +- .../insert-with-secondary-rtree.4.update.aql | 2 +- .../queries/filters/insert/insert.4.update.aql | 2 +- .../equality-predicate.2.update.aql | 8 +- .../dblp-splits-3_1/dblp-splits-3_1.3.query.aql | 148 +- .../fuzzyjoin/opentype/opentype.3.query.aql | 6 +- .../btree-index-nested-loop-join.1.ddl.aql | 32 +- .../btree-index-nested-loop-join.3.query.aql | 2 +- ...robe-pidx-with-join-invidx-sidx1.3.query.aql | 6 +- ...robe-pidx-with-join-invidx-sidx2.3.query.aql | 6 +- ...ndex-composite-key-mixed-intervals.1.ddl.aql | 2 +- ...x-composite-key-mixed-intervals.2.update.aql | 2 +- ...ex-composite-key-mixed-intervals.3.query.aql | 4 +- .../query_issue285-2.3.query.aql | 8 +- .../query_issue285/query_issue285.3.query.aql | 8 +- .../query-issue428/query-issue428.3.query.aql | 2 +- ...compact-dataset-and-its-indexes.2.update.aql | 8 +- .../drop-index/drop-index.2.update.aql | 8 +- .../nested-uuid-load/nested-uuid-load.1.ddl.aql | 2 +- ...-btree-secondary-index-nullable.2.update.aql | 8 +- ...-ngram-secondary-index-nullable.2.update.aql | 8 +- ...ted-index-ngram-secondary-index.2.update.aql | 8 +- ...x-word-secondary-index-nullable.2.update.aql | 8 +- ...rted-index-word-secondary-index.2.update.aql | 8 +- ...-rtree-secondary-index-nullable.2.update.aql | 8 +- ...an-delete-rtree-secondary-index.2.update.aql | 8 +- ...-btree-secondary-index-nullable.4.update.aql | 28 +- ...-ngram-secondary-index-nullable.4.update.aql | 12 +- ...ted-index-ngram-secondary-index.4.update.aql | 12 +- ...x-word-secondary-index-nullable.4.update.aql | 12 +- ...rted-index-word-secondary-index.4.update.aql | 12 +- ...-rtree-secondary-index-nullable.4.update.aql | 10 +- ...an-insert-rtree-secondary-index.2.update.aql | 16 +- ...an-insert-rtree-secondary-index.4.update.aql | 10 +- .../leftouterjoin-rtree.1.ddl.aql | 26 +- .../leftouterjoin/leftouterjoin.1.ddl.aql | 26 +- .../btree-primary-equi-join.2.update.aql | 16 +- .../btree-secondary-equi-join.2.update.aql | 16 +- .../ngram-edit-distance-inline.2.update.aql | 16 +- .../ngram-edit-distance.2.update.aql | 16 +- .../ngram-jaccard-inline.2.update.aql | 16 +- .../ngram-jaccard/ngram-jaccard.2.update.aql | 16 +- .../rtree-spatial-intersect-point.2.update.aql | 16 +- .../word-jaccard-inline.2.update.aql | 16 +- .../word-jaccard/word-jaccard.2.update.aql | 16 +- .../probe-pidx-with-join-btree-sidx1.1.ddl.aql | 24 +- ...robe-pidx-with-join-btree-sidx1.2.update.aql | 8 +- .../probe-pidx-with-join-btree-sidx2.1.ddl.aql | 24 +- ...robe-pidx-with-join-btree-sidx2.2.update.aql | 8 +- .../probe-pidx-with-join-invidx-sidx1.1.ddl.aql | 24 +- ...obe-pidx-with-join-invidx-sidx1.2.update.aql | 8 +- ...robe-pidx-with-join-invidx-sidx1.3.query.aql | 2 +- .../probe-pidx-with-join-invidx-sidx2.1.ddl.aql | 24 +- ...obe-pidx-with-join-invidx-sidx2.2.update.aql | 8 +- ...robe-pidx-with-join-invidx-sidx2.3.query.aql | 2 +- .../probe-pidx-with-join-rtree-sidx1.1.ddl.aql | 24 +- ...robe-pidx-with-join-rtree-sidx1.2.update.aql | 8 +- .../probe-pidx-with-join-rtree-sidx2.1.ddl.aql | 24 +- ...robe-pidx-with-join-rtree-sidx2.2.update.aql | 8 +- ...ndex-composite-key-mixed-intervals.1.ddl.aql | 2 +- ...x-composite-key-mixed-intervals.2.update.aql | 20 +- ...ex-composite-key-mixed-intervals.4.query.aql | 2 +- .../btree-index-composite-key.2.update.aql | 18 +- .../btree-index-rewrite-multiple.2.update.aql | 8 +- .../cust-index-age-nullable.2.update.aql | 8 +- .../inverted-index-ngram-contains.2.update.aql | 8 +- ...ex-ngram-edit-distance-contains.2.update.aql | 8 +- ...index-ngram-edit-distance-panic.2.update.aql | 8 +- ...ngram-edit-distance-word-tokens.2.update.aql | 8 +- ...erted-index-ngram-edit-distance.2.update.aql | 8 +- .../inverted-index-ngram-jaccard.2.update.aql | 8 +- ...index-olist-edit-distance-panic.2.update.aql | 8 +- ...erted-index-olist-edit-distance.2.update.aql | 8 +- .../inverted-index-olist-jaccard.2.update.aql | 8 +- .../inverted-index-ulist-jaccard.2.update.aql | 8 +- .../inverted-index-word-contains.2.update.aql | 8 +- .../inverted-index-word-jaccard.2.update.aql | 8 +- ...-index-custkey-conjunctive-open.2.update.aql | 8 +- ...rders-index-custkey-conjunctive.2.update.aql | 8 +- .../orders-index-custkey-open.2.update.aql | 8 +- .../orders-index-custkey.2.update.aql | 8 +- .../range-search-open.2.update.aql | 8 +- .../range-search/range-search.2.update.aql | 8 +- .../rtree-secondary-index-nullable.2.update.aql | 8 +- .../rtree-secondary-index-open.2.update.aql | 8 +- .../rtree-secondary-index.2.update.aql | 8 +- .../leftouterjoin-rtree.1.ddl.aql | 20 +- .../leftouterjoin/leftouterjoin.1.ddl.aql | 20 +- .../bottom-closed-top-closed.1.ddl.aql | 50 +- .../bottom-closed-top-closed.2.update.aql | 106 +- .../bottom-closed-top-closed.3.query.aql | 6 +- .../bottom-closed-top-open.1.ddl.aql | 48 +- .../bottom-closed-top-open.2.update.aql | 106 +- .../bottom-closed-top-open.3.query.aql | 6 +- .../bottom-open-top-closed.1.ddl.aql | 48 +- .../bottom-open-top-closed.2.update.aql | 106 +- .../bottom-open-top-closed.3.query.aql | 6 +- .../bottom-open-top-open.1.ddl.aql | 46 +- .../bottom-open-top-open.2.update.aql | 106 +- .../bottom-open-top-open.3.query.aql | 6 +- .../btree-secondary-equi-join.2.update.aql | 38 +- .../ngram-edit-distance-inline.2.update.aql | 40 +- .../ngram-edit-distance.2.update.aql | 40 +- .../ngram-jaccard-inline.2.update.aql | 38 +- .../ngram-jaccard/ngram-jaccard.2.update.aql | 38 +- .../rtree-spatial-intersect-point.2.update.aql | 48 +- .../word-jaccard-inline.2.update.aql | 38 +- .../word-jaccard/word-jaccard.2.update.aql | 38 +- .../probe-pidx-with-join-btree-sidx1.1.ddl.aql | 22 +- ...robe-pidx-with-join-btree-sidx1.2.update.aql | 36 +- ...probe-pidx-with-join-btree-sidx1.3.query.aql | 8 +- .../probe-pidx-with-join-btree-sidx2.1.ddl.aql | 22 +- ...robe-pidx-with-join-btree-sidx2.2.update.aql | 36 +- .../probe-pidx-with-join-invidx-sidx2.1.ddl.aql | 26 +- ...obe-pidx-with-join-invidx-sidx2.2.update.aql | 36 +- ...robe-pidx-with-join-invidx-sidx2.3.query.aql | 2 +- .../probe-pidx-with-join-rtree-sidx1.1.ddl.aql | 24 +- ...robe-pidx-with-join-rtree-sidx1.2.update.aql | 36 +- .../probe-pidx-with-join-rtree-sidx2.1.ddl.aql | 24 +- ...robe-pidx-with-join-rtree-sidx2.2.update.aql | 36 +- ...ndex-composite-key-mixed-intervals.1.ddl.aql | 2 +- ...x-composite-key-mixed-intervals.2.update.aql | 38 +- ...ndex-composite-key-mixed-intervals.3.ddl.aql | 2 +- ...ex-composite-key-mixed-intervals.4.query.aql | 2 +- .../btree-index-composite-key.2.update.aql | 18 +- .../btree-index-rewrite-multiple.2.update.aql | 20 +- .../inverted-index-ngram-contains.2.update.aql | 30 +- ...ex-ngram-edit-distance-contains.2.update.aql | 30 +- ...index-ngram-edit-distance-panic.2.update.aql | 30 +- ...ngram-edit-distance-word-tokens.2.update.aql | 30 +- ...erted-index-ngram-edit-distance.2.update.aql | 30 +- .../inverted-index-ngram-jaccard.2.update.aql | 30 +- .../inverted-index-word-contains.2.update.aql | 30 +- .../inverted-index-word-jaccard.2.update.aql | 30 +- ...rders-index-custkey-conjunctive.2.update.aql | 8 +- .../orders-index-custkey.2.update.aql | 38 +- .../range-search/range-search.2.update.aql | 52 +- .../rtree-secondary-index.2.update.aql | 38 +- .../queries/numeric/abs0/abs0.3.query.aql | 2 +- .../queries/numeric/abs1/abs1.3.query.aql | 2 +- .../numeric/ceiling0/ceiling0.3.query.aql | 2 +- .../numeric/ceiling1/ceiling1.3.query.aql | 2 +- .../queries/numeric/floor0/floor0.3.query.aql | 2 +- .../queries/numeric/floor1/floor1.3.query.aql | 2 +- .../round-half-to-even0.3.query.aql | 2 +- .../round-half-to-even1.3.query.aql | 2 +- .../round-half-to-even20.3.query.aql | 2 +- .../round-half-to-even21.3.query.aql | 2 +- .../queries/numeric/round0/round0.3.query.aql | 2 +- .../queries/numeric/round1/round1.3.query.aql | 2 +- .../query-issue134/query-issue134.1.ddl.aql | 2 +- .../query-issue134/query-issue134.2.update.aql | 2 +- .../query-issue134/query-issue134.3.query.aql | 2 +- .../query-issue166/query-issue166.1.ddl.aql | 4 +- .../query-issue166/query-issue166.2.update.aql | 4 +- .../query-issue166/query-issue166.3.query.aql | 4 +- .../query-issue196/query-issue196.2.update.aql | 2 +- .../query-issue196/query-issue196.3.query.aql | 2 +- .../query-issue208/query-issue208.2.update.aql | 2 +- .../query-issue208/query-issue208.3.query.aql | 2 +- .../query-issue236/query-issue236.2.update.aql | 22 +- .../query-issue236/query-issue236.3.query.aql | 2 +- .../query-issue258/query-issue258.2.update.aql | 4 +- .../query-issue258/query-issue258.3.query.aql | 2 +- .../query-issue29/query-issue29.1.ddl.aql | 2 +- .../query-issue29/query-issue29.2.update.aql | 2 +- .../query-issue29/query-issue29.3.query.aql | 4 +- .../query-issue343-2.2.update.aql | 2 +- .../query-issue343-2.3.query.aql | 2 +- .../query-issue343/query-issue343.2.update.aql | 2 +- .../query-issue343/query-issue343.3.query.aql | 2 +- .../query-issue350-2/query-issue350-2.1.ddl.aql | 4 +- .../query-issue350-2.2.update.aql | 2 +- .../query-issue350-2.3.query.aql | 2 +- .../query-issue350/query-issue350.1.ddl.aql | 4 +- .../query-issue350/query-issue350.2.update.aql | 2 +- .../query-issue350/query-issue350.3.query.aql | 2 +- .../query-issue377/query-issue377.2.update.aql | 2 +- .../query-issue377/query-issue377.3.query.aql | 2 +- .../query-issue410/query-issue410.1.ddl.aql | 2 +- .../query-issue410/query-issue410.2.update.aql | 4 +- .../query-issue410/query-issue410.3.query.aql | 2 +- .../query-issue423-2/query-issue423-2.1.ddl.aql | 4 +- .../query-issue423-2.2.update.aql | 6 +- .../query-issue423-2.3.query.aql | 8 +- .../query-issue423/query-issue423.1.ddl.aql | 6 +- .../query-issue423/query-issue423.2.update.aql | 6 +- .../query-issue423/query-issue423.3.query.aql | 8 +- .../query-issue442/query-issue442.3.query.aql | 2 +- .../query-issue453-2.2.update.aql | 4 +- .../query-issue453-2.3.query.aql | 2 +- .../query-issue453/query-issue453.2.update.aql | 2 +- .../query-issue453/query-issue453.3.query.aql | 2 +- .../query-issue487/query-issue487.1.ddl.aql | 6 +- .../query-issue487/query-issue487.2.update.aql | 4 +- .../query-issue487/query-issue487.3.query.aql | 4 +- .../query-issue55-1/query-issue55-1.1.ddl.aql | 2 +- .../query-issue55-1.2.update.aql | 2 +- .../query-issue55-1/query-issue55-1.3.query.aql | 2 +- .../query-issue55/query-issue55.1.ddl.aql | 2 +- .../query-issue55/query-issue55.2.update.aql | 2 +- .../query-issue55/query-issue55.3.query.aql | 2 +- .../query-issue656/query-issue656.1.ddl.aql | 2 +- .../query-issue656/query-issue656.2.update.aql | 10 +- .../leftouterjoin-rtree.1.ddl.aql | 20 +- .../leftouterjoin/leftouterjoin.1.ddl.aql | 20 +- .../btree-secondary-equi-join.2.update.aql | 24 +- .../ngram-edit-distance-inline.2.update.aql | 24 +- .../ngram-edit-distance.2.update.aql | 24 +- .../ngram-jaccard-inline.2.update.aql | 22 +- .../ngram-jaccard/ngram-jaccard.2.update.aql | 22 +- .../rtree-spatial-intersect-point.2.update.aql | 30 +- .../word-jaccard-inline.2.update.aql | 22 +- .../word-jaccard/word-jaccard.2.update.aql | 22 +- .../probe-pidx-with-join-btree-sidx1.1.ddl.aql | 20 +- ...robe-pidx-with-join-btree-sidx1.2.update.aql | 28 +- .../probe-pidx-with-join-btree-sidx2.1.ddl.aql | 20 +- ...robe-pidx-with-join-btree-sidx2.2.update.aql | 28 +- .../probe-pidx-with-join-invidx-sidx2.1.ddl.aql | 20 +- ...obe-pidx-with-join-invidx-sidx2.2.update.aql | 28 +- ...robe-pidx-with-join-invidx-sidx2.3.query.aql | 2 +- .../probe-pidx-with-join-rtree-sidx1.1.ddl.aql | 22 +- ...robe-pidx-with-join-rtree-sidx1.2.update.aql | 28 +- .../probe-pidx-with-join-rtree-sidx2.1.ddl.aql | 22 +- ...robe-pidx-with-join-rtree-sidx2.2.update.aql | 28 +- ...ndex-composite-key-mixed-intervals.1.ddl.aql | 2 +- ...x-composite-key-mixed-intervals.2.update.aql | 22 +- ...ndex-composite-key-mixed-intervals.3.ddl.aql | 2 +- ...ex-composite-key-mixed-intervals.4.query.aql | 12 +- .../btree-index-composite-key.2.update.aql | 4 +- .../btree-index-composite-key.4.query.aql | 10 +- .../btree-index-rewrite-multiple.2.update.aql | 30 +- .../inverted-index-ngram-contains.2.update.aql | 22 +- ...ex-ngram-edit-distance-contains.2.update.aql | 22 +- ...index-ngram-edit-distance-panic.2.update.aql | 22 +- ...ngram-edit-distance-word-tokens.2.update.aql | 22 +- ...erted-index-ngram-edit-distance.2.update.aql | 22 +- .../inverted-index-ngram-jaccard.2.update.aql | 22 +- .../inverted-index-word-contains.2.update.aql | 22 +- .../inverted-index-word-jaccard.2.update.aql | 22 +- ...rders-index-custkey-conjunctive.2.update.aql | 4 +- .../orders-index-custkey.2.update.aql | 4 +- .../range-search/range-search.2.update.aql | 44 +- .../rtree-secondary-index.2.update.aql | 30 +- .../access-nested-fields.1.ddl.aql | 40 +- .../queries/scan/invalid-scan-syntax.aql | 2 +- .../invalid-scan-syntax.1.ddl.aql | 2 +- .../invalid-scan-syntax.2.update.aql | 2 +- .../invalid-scan-syntax.3.query.aql | 2 +- .../spatial_types_02/spatial_types_02.1.ddl.aql | 6 +- .../scan/temp_types_02/temp_types_02.1.ddl.aql | 4 +- ...y-jaccard-check_strings_issue628.3.query.aql | 8 +- .../cell-aggregation-with-filtering.3.query.aql | 8 +- ...ert-and-scan-dataset-with-index.2.update.aql | 12 +- .../insert-and-scan-dataset.2.update.aql | 8 +- .../scan-insert-persistent-to-temp.4.update.aql | 12 +- ...an-insert-rtree-secondary-index.4.update.aql | 12 +- .../scan-insert-temp-to-persistent.4.update.aql | 12 +- .../insert_from_ext_ds_2.1.ddl.aql | 8 +- .../q05_local_supplier_volume.1.ddl.aql | 78 +- .../q06_forecast_revenue_change.1.ddl.aql | 78 +- .../q07_volume_shipping.1.ddl.aql | 76 +- .../q08_national_market_share.1.ddl.aql | 76 +- .../q09_product_type_profit_nt.1.ddl.aql | 76 +- .../q10_returned_item.1.ddl.aql | 76 +- .../q10_returned_item_int64.1.ddl.aql | 76 +- .../tpch/q12_shipping/q12_shipping.1.ddl.aql | 76 +- .../q14_promotion_effect.1.ddl.aql | 76 +- .../q17_small_quantity_order_revenue.1.ddl.aql | 76 +- .../q19_discounted_revenue.1.ddl.aql | 76 +- .../q20_potential_part_promotion.1.ddl.aql | 76 +- .../q22_global_sales_opportunity.1.ddl.aql | 76 +- .../query-issue638/query-issue638.1.ddl.aql | 20 +- .../query-issue785/query-issue785.3.query.aql | 6 +- .../query-issue172/query-issue172.1.ddl.aql | 4 +- .../query-issue172/query-issue172.2.update.aql | 2 +- .../query-issue172/query-issue172.3.query.aql | 2 +- .../query-issue201/query-issue201.1.ddl.aql | 4 +- .../query-issue201/query-issue201.2.update.aql | 2 +- .../query-issue201/query-issue201.3.query.aql | 2 +- .../query-issue218-2/query-issue218-2.1.ddl.aql | 4 +- .../query-issue218-2.2.update.aql | 2 +- .../query-issue218-2.3.query.aql | 2 +- .../query-issue218/query-issue218.1.ddl.aql | 2 +- .../query-issue218/query-issue218.2.update.aql | 2 +- .../query-issue218/query-issue218.3.query.aql | 2 +- .../query-issue244/query-issue244.2.update.aql | 4 +- .../query-issue244/query-issue244.3.query.aql | 6 +- .../query-issue455/query-issue455.1.ddl.aql | 6 +- .../query-issue455/query-issue455.2.update.aql | 2 +- .../query-issue455/query-issue455.3.query.aql | 4 +- .../query-issue455/query-issue455.4.ddl.aql | 4 +- .../query-issue455/query-issue455.5.query.aql | 4 +- .../query-issue489/query-issue489.1.ddl.aql | 4 +- .../query-issue489/query-issue489.2.query.aql | 2 +- .../query-issue489/query-issue489.3.ddl.aql | 4 +- .../query-issue489/query-issue489.4.query.aql | 2 +- .../sum_null-with-pred.3.query.sqlpp | 5 +- .../sum_null-with-pred.3.query.sqlpp | 4 +- .../boolean/not_01/not_01.3.query.sqlpp | 4 +- .../queries_sqlpp/dapd/q2-2/q2-2.1.ddl.sqlpp | 55 + .../queries_sqlpp/dapd/q2-2/q2-2.2.update.sqlpp | 19 + .../queries_sqlpp/dapd/q2-2/q2-2.3.query.sqlpp | 40 + .../queries_sqlpp/dapd/q2-3/q2-3.1.ddl.sqlpp | 55 + .../queries_sqlpp/dapd/q2-3/q2-3.2.update.sqlpp | 19 + .../queries_sqlpp/dapd/q2-3/q2-3.3.query.sqlpp | 38 + .../queries_sqlpp/dapd/q2-4/q2-4.1.ddl.sqlpp | 55 + .../queries_sqlpp/dapd/q2-4/q2-4.2.update.sqlpp | 19 + .../queries_sqlpp/dapd/q2-4/q2-4.3.query.sqlpp | 39 + .../queries_sqlpp/dapd/q2-5/q2-5.1.ddl.sqlpp | 55 + .../queries_sqlpp/dapd/q2-5/q2-5.2.update.sqlpp | 19 + .../queries_sqlpp/dapd/q2-5/q2-5.3.query.sqlpp | 39 + ...mpact-dataset-and-its-indexes.4.update.sqlpp | 4 +- ...rom-loaded-dataset-with-index.4.update.sqlpp | 4 +- .../delete-from-loaded-dataset.2.update.sqlpp | 4 +- .../delete-multi-statement.2.update.sqlpp | 27 +- .../dml/delete-syntax-change.sqlpp | 5 +- .../delete-syntax-change.2.update.sqlpp | 4 +- .../query-issue205.2.update.sqlpp | 4 +- ...tree-secondary-index-nullable.4.update.sqlpp | 4 +- ...te-btree-secondary-index-open.4.update.sqlpp | 4 +- ...gram-secondary-index-nullable.4.update.sqlpp | 4 +- ...ex-ngram-secondary-index-open.4.update.sqlpp | 4 +- ...d-index-ngram-secondary-index.4.update.sqlpp | 4 +- ...word-secondary-index-nullable.4.update.sqlpp | 4 +- ...dex-word-secondary-index-open.4.update.sqlpp | 4 +- ...ed-index-word-secondary-index.4.update.sqlpp | 4 +- ...tree-secondary-index-nullable.4.update.sqlpp | 4 +- ...te-rtree-secondary-index-open.4.update.sqlpp | 4 +- ...-delete-rtree-secondary-index.4.update.sqlpp | 4 +- .../using-constant-merge-policy.4.update.sqlpp | 4 +- ...orrelated-prefix-merge-policy.4.update.sqlpp | 4 +- .../using-no-merge-policy.4.update.sqlpp | 4 +- .../using-prefix-merge-policy.4.update.sqlpp | 4 +- .../misc/is-null_01/is-null_01.3.query.sqlpp | 2 +- ...mpact-dataset-and-its-indexes.4.update.sqlpp | 4 +- ...rom-loaded-dataset-with-index.4.update.sqlpp | 4 +- ...tree-secondary-index-nullable.4.update.sqlpp | 4 +- ...gram-secondary-index-nullable.4.update.sqlpp | 4 +- ...d-index-ngram-secondary-index.4.update.sqlpp | 4 +- ...word-secondary-index-nullable.4.update.sqlpp | 4 +- ...ed-index-word-secondary-index.4.update.sqlpp | 4 +- ...tree-secondary-index-nullable.4.update.sqlpp | 4 +- ...-delete-rtree-secondary-index.4.update.sqlpp | 4 +- .../null-missing/is/is.1.query.sqlpp | 39 + .../everysat_04/everysat_04.3.query.sqlpp | 5 +- .../somesat_06/somesat_06.3.query.sqlpp | 2 +- .../queries_sqlpp/records/RecordsQueries.xml | 6 +- .../select-star/from/from.1.ddl.sqlpp | 76 + .../select-star/from/from.2.update.sqlpp | 28 + .../select-star/from/from.3.query.sqlpp | 32 + .../select-star/group_by/group_by.1.ddl.sqlpp | 34 + .../group_by/group_by.2.update.sqlpp | 24 + .../select-star/group_by/group_by.3.query.sqlpp | 27 + .../select-star/join/join.1.ddl.sqlpp | 76 + .../select-star/join/join.2.update.sqlpp | 28 + .../select-star/join/join.3.query.sqlpp | 32 + .../select-star/mixed/mixed.1.ddl.sqlpp | 76 + .../select-star/mixed/mixed.2.update.sqlpp | 28 + .../select-star/mixed/mixed.3.query.sqlpp | 32 + .../select-star/no_star/no_star.1.ddl.sqlpp | 76 + .../select-star/no_star/no_star.2.update.sqlpp | 28 + .../select-star/no_star/no_star.3.query.sqlpp | 32 + .../has-param1/has-param1.3.query.sqlpp | 2 +- .../string/like_01/like_01.3.query.sqlpp | 2 +- .../string/like_null/like_null.3.query.sqlpp | 2 +- .../varlen-encoding.3.query.sqlpp | 2 + .../queries_sqlpp/subquery/in/in.1.ddl.sqlpp | 55 + .../queries_sqlpp/subquery/in/in.2.update.sqlpp | 18 + .../queries_sqlpp/subquery/in/in.3.query.sqlpp | 28 + .../in_correlated/in_correlated.1.ddl.sqlpp | 55 + .../in_correlated/in_correlated.2.update.sqlpp | 18 + .../in_correlated/in_correlated.3.query.sqlpp | 29 + .../subquery/not_in/not_in.1.ddl.sqlpp | 55 + .../subquery/not_in/not_in.2.update.sqlpp | 18 + .../subquery/not_in/not_in.3.query.sqlpp | 28 + ...rom-loaded-dataset-with-index.4.update.sqlpp | 4 +- .../delete-from-loaded-dataset.2.update.sqlpp | 4 +- ...-delete-rtree-secondary-index.4.update.sqlpp | 4 +- .../tinysocial-suite.12.query.sqlpp | 2 +- .../tinysocial-suite.13.query.sqlpp | 2 +- .../tinysocial-suite.21.update.sqlpp | 4 +- .../tinysocial-suite.12.query.sqlpp | 2 +- .../tinysocial-suite.13.query.sqlpp | 2 +- .../tinysocial-suite.21.update.sqlpp | 4 +- .../q02_minimum_cost_supplier.3.query.sqlpp | 4 +- .../q13_customer_distribution.3.query.sqlpp | 2 +- .../q14_promotion_effect.3.query.sqlpp | 2 +- ...16_parts_supplier_relationship.3.query.sqlpp | 4 +- .../distinct_by/distinct_by.1.ddl.sqlpp | 47 + .../distinct_by/distinct_by.2.update.sqlpp | 24 + .../distinct_by/distinct_by.3.query.sqlpp | 26 + .../group_no_agg/group_no_agg.1.ddl.sqlpp | 34 + .../group_no_agg/group_no_agg.2.update.sqlpp | 24 + .../group_no_agg/group_no_agg.3.query.sqlpp | 27 + .../nest_aggregate/nest_aggregate.1.ddl.sqlpp | 94 + .../nest_aggregate.2.update.sqlpp | 40 + .../nest_aggregate/nest_aggregate.3.query.sqlpp | 44 + .../nest_aggregate2/nest_aggregate2.1.ddl.sqlpp | 94 + .../nest_aggregate2.2.update.sqlpp | 40 + .../nest_aggregate2.3.query.sqlpp | 45 + .../q01_pricing_summary_report_nt.1.ddl.sqlpp | 47 + ...q01_pricing_summary_report_nt.2.update.sqlpp | 24 + .../q01_pricing_summary_report_nt.3.query.sqlpp | 37 + .../q02_minimum_cost_supplier.1.ddl.sqlpp | 134 + .../q02_minimum_cost_supplier.2.update.sqlpp | 38 + .../q02_minimum_cost_supplier.3.query.sqlpp | 44 + .../q03_shipping_priority_nt.1.ddl.sqlpp | 134 + .../q03_shipping_priority_nt.2.update.sqlpp | 28 + .../q03_shipping_priority_nt.3.query.sqlpp | 35 + .../q04_order_priority.1.ddl.sqlpp | 134 + .../q04_order_priority.2.update.sqlpp | 38 + .../q04_order_priority.3.query.sqlpp | 37 + .../q05_local_supplier_volume.1.ddl.sqlpp | 134 + .../q05_local_supplier_volume.2.update.sqlpp | 38 + .../q05_local_supplier_volume.3.query.sqlpp | 42 + .../q06_forecast_revenue_change.1.ddl.sqlpp | 134 + .../q06_forecast_revenue_change.2.update.sqlpp | 38 + .../q06_forecast_revenue_change.3.query.sqlpp | 33 + .../q07_volume_shipping.1.ddl.sqlpp | 134 + .../q07_volume_shipping.2.update.sqlpp | 38 + .../q07_volume_shipping.3.query.sqlpp | 55 + .../q08_national_market_share.1.ddl.sqlpp | 134 + .../q08_national_market_share.2.update.sqlpp | 38 + .../q08_national_market_share.3.query.sqlpp | 67 + .../q09_product_type_profit_nt.1.ddl.sqlpp | 134 + .../q09_product_type_profit_nt.2.update.sqlpp | 38 + .../q09_product_type_profit_nt.3.query.sqlpp | 47 + .../q10_returned_item.1.ddl.sqlpp | 134 + .../q10_returned_item.2.update.sqlpp | 38 + .../q10_returned_item.3.query.sqlpp | 43 + .../q10_returned_item_int64.1.ddl.sqlpp | 134 + .../q10_returned_item_int64.2.update.sqlpp | 38 + .../q10_returned_item_int64.3.query.sqlpp | 44 + .../q11_important_stock.1.ddl.sqlpp | 134 + .../q11_important_stock.2.update.sqlpp | 38 + .../q11_important_stock.3.query.sqlpp | 51 + .../q12_shipping/q12_shipping.1.ddl.sqlpp | 134 + .../q12_shipping/q12_shipping.2.update.sqlpp | 38 + .../q12_shipping/q12_shipping.3.query.sqlpp | 33 + .../q13_customer_distribution.1.ddl.sqlpp | 134 + .../q13_customer_distribution.2.update.sqlpp | 38 + .../q13_customer_distribution.3.query.sqlpp | 40 + .../q14_promotion_effect.1.ddl.sqlpp | 134 + .../q14_promotion_effect.2.update.sqlpp | 38 + .../q14_promotion_effect.3.query.sqlpp | 29 + .../q15_top_supplier.1.ddl.sqlpp | 134 + .../q15_top_supplier.2.update.sqlpp | 38 + .../q15_top_supplier.3.query.sqlpp | 45 + .../q16_parts_supplier_relationship.1.ddl.sqlpp | 134 + ...6_parts_supplier_relationship.2.update.sqlpp | 38 + ...16_parts_supplier_relationship.3.query.sqlpp | 47 + .../q17_large_gby_variant.1.ddl.sqlpp | 134 + .../q17_large_gby_variant.2.update.sqlpp | 38 + .../q17_large_gby_variant.3.query.sqlpp | 38 + ...q17_small_quantity_order_revenue.1.ddl.sqlpp | 134 + ..._small_quantity_order_revenue.2.update.sqlpp | 38 + ...7_small_quantity_order_revenue.3.query.sqlpp | 36 + .../q18_large_volume_customer.1.ddl.sqlpp | 134 + .../q18_large_volume_customer.2.update.sqlpp | 38 + .../q18_large_volume_customer.3.query.sqlpp | 40 + .../q19_discounted_revenue.1.ddl.sqlpp | 134 + .../q19_discounted_revenue.2.update.sqlpp | 38 + .../q19_discounted_revenue.3.query.sqlpp | 55 + .../q20_potential_part_promotion.1.ddl.sqlpp | 134 + .../q20_potential_part_promotion.2.update.sqlpp | 38 + .../q20_potential_part_promotion.3.query.sqlpp | 59 + ...uppliers_who_kept_orders_waiting.1.ddl.sqlpp | 134 + ...liers_who_kept_orders_waiting.2.update.sqlpp | 38 + ...pliers_who_kept_orders_waiting.3.query.sqlpp | 70 + .../q22_global_sales_opportunity.1.ddl.sqlpp | 134 + .../q22_global_sales_opportunity.2.update.sqlpp | 38 + .../q22_global_sales_opportunity.3.query.sqlpp | 38 + .../query-issue562/query-issue562.1.ddl.sqlpp | 140 + .../query-issue562.2.update.sqlpp | 44 + .../query-issue562/query-issue562.3.query.sqlpp | 47 + .../query-issue601/query-issue601.1.ddl.sqlpp | 53 + .../query-issue601.2.update.sqlpp | 30 + .../query-issue601/query-issue601.3.query.sqlpp | 32 + .../query-issue638/query-issue638.1.ddl.sqlpp | 140 + .../query-issue638.2.update.sqlpp | 25 + .../query-issue638/query-issue638.3.query.sqlpp | 52 + .../query-issue785-2.1.ddl.sqlpp | 94 + .../query-issue785-2.2.update.sqlpp | 40 + .../query-issue785-2.3.query.sqlpp | 53 + .../query-issue785/query-issue785.1.ddl.sqlpp | 94 + .../query-issue785.2.update.sqlpp | 40 + .../query-issue785/query-issue785.3.query.sqlpp | 47 + .../query-issue786/query-issue786.1.ddl.sqlpp | 94 + .../query-issue786.2.update.sqlpp | 40 + .../query-issue786/query-issue786.3.query.sqlpp | 43 + .../query-issue810-2.1.ddl.sqlpp | 53 + .../query-issue810-2.2.update.sqlpp | 30 + .../query-issue810-2.3.query.sqlpp | 44 + .../query-issue810-3.1.ddl.sqlpp | 53 + .../query-issue810-3.2.update.sqlpp | 30 + .../query-issue810-3.3.query.sqlpp | 52 + .../query-issue810/query-issue810.1.ddl.sqlpp | 53 + .../query-issue810.2.update.sqlpp | 30 + .../query-issue810/query-issue810.3.query.sqlpp | 48 + .../q02_minimum_cost_supplier.3.query.sqlpp | 2 +- .../q13_customer_distribution.3.query.sqlpp | 2 +- .../q14_promotion_effect.3.query.sqlpp | 2 +- ...16_parts_supplier_relationship.3.query.sqlpp | 5 +- .../q02_minimum_cost_supplier.3.query.sqlpp | 4 +- .../q13_customer_distribution.3.query.sqlpp | 2 +- .../q14_promotion_effect.3.query.sqlpp | 2 +- ...16_parts_supplier_relationship.3.query.sqlpp | 4 +- .../q02_minimum_cost_supplier.3.query.sqlpp | 4 +- .../q13_customer_distribution.3.query.sqlpp | 2 +- .../q14_promotion_effect.3.query.sqlpp | 2 +- ...16_parts_supplier_relationship.3.query.sqlpp | 4 +- .../udf18/udf18.3.query.sqlpp | 5 +- .../udf30/udf30.1.query.sqlpp | 2 +- .../agg_null_rec/agg_null_rec.1.adm | 2 +- .../agg_null_rec_1/agg_null_rec.1.adm | 2 +- .../aggregate-sql/agg_number/agg_number.1.adm | 2 +- .../agg_number_rec/agg_number_rec.1.adm | 2 +- .../aggregate-sql/avg_double/avg_double.1.adm | 2 +- .../avg_double_null/avg_double_null.1.adm | 2 +- .../aggregate-sql/avg_float/avg_float.1.adm | 2 +- .../avg_float_null/avg_float_null.1.adm | 2 +- .../aggregate-sql/avg_int16/avg_int16.1.adm | 2 +- .../avg_int16_null/avg_int16_null.1.adm | 2 +- .../aggregate-sql/avg_int32/avg_int32.1.adm | 2 +- .../avg_int32_null/avg_int32_null.1.adm | 2 +- .../aggregate-sql/avg_int64/avg_int64.1.adm | 2 +- .../avg_int64_null/avg_int64_null.1.adm | 2 +- .../aggregate-sql/avg_int8/avg_int8.1.adm | 2 +- .../avg_int8_null/avg_int8_null.1.adm | 2 +- .../aggregate-sql/issue412_1/issue412_1.1.adm | 2 +- .../issue425_min_hetero_list_1.1.adm | 2 +- .../issue425_sum_hetero_list_1.1.adm | 2 +- .../aggregate-sql/scalar_max/scalar_max.1.adm | 10 +- .../scalar_max_null/scalar_max_null.1.adm | 10 +- .../aggregate-sql/scalar_min/scalar_min.1.adm | 10 +- .../scalar_min_null/scalar_min_null.1.adm | 10 +- .../aggregate-sql/scalar_sum/scalar_sum.1.adm | 10 +- .../scalar_sum_null/scalar_sum_null.1.adm | 10 +- .../aggregate-sql/sum_double/sum_double.1.adm | 2 +- .../sum_double_null/sum_double_null.1.adm | 2 +- .../aggregate-sql/sum_float/sum_float.1.adm | 2 +- .../sum_float_null/sum_float_null.1.adm | 2 +- .../aggregate-sql/sum_int16/sum_int16.1.adm | 2 +- .../sum_int16_null/sum_int16_null.1.adm | 2 +- .../aggregate-sql/sum_int32/sum_int32.1.adm | 2 +- .../sum_int32_null/sum_int32_null.1.adm | 2 +- .../aggregate-sql/sum_int8/sum_int8.1.adm | 2 +- .../sum_int8_null/sum_int8_null.1.adm | 2 +- .../aggregate/agg_null_rec_1/agg_null_rec.1.adm | 2 +- .../aggregate/agg_number/agg_number.1.adm | 2 +- .../agg_number_rec/agg_number_rec.1.adm | 2 +- .../aggregate/avg_double/avg_double.1.adm | 2 +- .../results/aggregate/avg_float/avg_float.1.adm | 2 +- .../results/aggregate/avg_int16/avg_int16.1.adm | 2 +- .../results/aggregate/avg_int32/avg_int32.1.adm | 2 +- .../results/aggregate/avg_int64/avg_int64.1.adm | 2 +- .../results/aggregate/avg_int8/avg_int8.1.adm | 2 +- .../aggregate/group_only/group_only.1.adm | 2 +- .../issue425_min_hetero_list_1.1.adm | 2 +- .../issue425_sum_hetero_list_1.1.adm | 2 +- .../query-ASTERIXDB-1216.1.adm | 4 +- .../query-ASTERIXDB-1230.1.adm | 2 +- .../aggregate/scalar_max/scalar_max.1.adm | 10 +- .../aggregate/scalar_min/scalar_min.1.adm | 10 +- .../aggregate/scalar_sum/scalar_sum.1.adm | 10 +- .../aggregate/sum_double/sum_double.1.adm | 2 +- .../results/aggregate/sum_float/sum_float.1.adm | 2 +- .../results/aggregate/sum_int16/sum_int16.1.adm | 2 +- .../results/aggregate/sum_int32/sum_int32.1.adm | 2 +- .../results/aggregate/sum_int8/sum_int8.1.adm | 2 +- .../big_object_groupby-2/groupby.1.adm | 12010 +++--- .../big-object/big_object_groupby/groupby.1.adm | 400 +- .../big-object/big_object_join/join.1.adm | 3000 +- .../big-object/big_object_load/load.1.adm | 3000 +- .../big-object/big_object_sort/sort.1.adm | 3000 +- .../documentation-example.1.adm | 2 +- .../documentation-example.2.adm | 2 +- .../documentation-example.3.adm | 2 +- .../documentation-example.4.adm | 2 +- .../documentation-example.5.adm | 2 +- .../open-records-example.3.adm | 2 +- .../double_gte_01/double_gte_01.1.adm | 4 +- .../interval_order/interval_order.3.adm | 2 +- .../interval_order/interval_order.4.adm | 2 +- .../results/comparison/uuid_1/uuid_1.1.adm | 2 +- .../constructor/double_01/double_01.1.adm | 2 +- .../results/constructor/float_01/float_01.1.adm | 2 +- .../results/constructor/int_01/int_01.1.adm | 2 +- .../constructor/primitive-01/primitive-01.1.adm | 2 +- .../constructor/primitive-02/primitive-02.1.adm | 2 +- .../constructor/primitive-03/primitive-03.1.adm | 2 +- .../cross-dataverse/cross-dv02/cross-dv02.1.adm | 8 +- .../cross-dataverse/cross-dv04/cross-dv04.1.adm | 8 +- .../cross-dataverse/cross-dv19/cross-dv19.1.adm | 14 +- .../insert_across_dataverses.1.adm | 10 +- .../join_across_dataverses.1.adm | 6 +- .../query-dataset-with-foreign-type.1.adm | 2 +- .../csv/basic-types-header/basic-types.1.csv | 3 +- .../custord/customer_q_01/customer_q_01.1.adm | 10 +- .../custord/customer_q_02/customer_q_02.1.adm | 10 +- .../custord/customer_q_03/customer_q_03.1.adm | 6 +- .../denorm-cust-order_02.1.adm | 20 +- .../results/custord/join_q_01/join_q_01.1.adm | 6 +- .../results/custord/join_q_02/join_q_02.1.adm | 6 +- .../results/custord/join_q_03/join_q_03.1.adm | 6 +- .../results/custord/load-test/load-test.1.adm | 20 +- .../results/custord/order_q_01/order_q_01.1.adm | 8 +- .../results/custord/order_q_02/order_q_02.1.adm | 8 +- .../results/custord/order_q_03/order_q_03.1.adm | 8 +- .../results/custord/order_q_04/order_q_04.1.adm | 8 +- .../results/custord/order_q_05/order_q_05.1.adm | 8 +- .../results/custord/order_q_06/order_q_06.1.adm | 6 +- .../compact-dataset-and-its-indexes.1.adm | 334 +- .../create-drop-cltype/create-drop-cltype.1.adm | 2 +- .../create-drop-opntype.1.adm | 2 +- .../delete-from-loaded-dataset-with-index.1.adm | 334 +- .../delete-from-loaded-dataset.1.adm | 50 +- .../delete-multi-statement.1.adm | 300 +- .../delete-syntax-change.1.adm | 50 +- .../empty-load-with-index.1.adm | 2 +- .../load-with-autogenerated-pk_csv_02.1.adm | 1 - .../load-with-index-open.1.adm | 82 +- .../dml/load-with-index/load-with-index.1.adm | 82 +- .../using-constant-merge-policy.1.adm | 334 +- .../using-correlated-prefix-merge-policy.1.adm | 334 +- .../using-no-merge-policy.1.adm | 334 +- .../using-prefix-merge-policy.1.adm | 334 +- .../runtimets/results/employee/q_01/q_01.1.adm | 8 +- .../classad-parser-new/classad-parser-new.1.adm | 200 +- .../classad-parser-old/classad-parser-old.1.adm | 10 +- ...ith-meta-pk-in-meta-index-after-ingest.4.adm | 1 + ...eed-with-meta-pk-in-meta-index-in-meta.4.adm | 1 + ...n-meta-index-with-missing-after-ingest.4.adm | 1 + ...th-meta-pk-in-meta-open-index-in-value.4.adm | 1 + ...eta-pk-in-meta-open-index-with-missing.4.adm | 1 + .../change-feed-with-meta-pk-in-meta.4.adm | 2 +- .../change-feed-with-meta-pk-in-meta.5.adm | 2 +- .../change-feed-with-meta-pk-in-meta.6.adm | 10 +- ...change-feed-with-meta-with-mixed-index.3.adm | 1 + .../results/feeds/change-feed/change-feed.1.adm | 2 +- .../feed-push-socket/feed-push-socket.1.adm | 20 +- .../feed-with-external-parser.1.adm | 200 +- .../feed-with-meta-pk-in-meta.4.adm | 2 +- .../feed-with-meta-pk-in-meta.5.adm | 2 +- .../feed-with-multiple-indexes.1.adm | 200 +- .../results/feeds/feeds_01/feeds_01.1.adm | 2 +- .../results/feeds/feeds_03/feeds_03.1.adm | 2 +- .../results/fuzzyjoin/dblp-1_1/dblp-1_1.1.adm | 604 +- .../fuzzyjoin/dblp-1_2.1.1/dblp-1_2.1.1.1.adm | 604 +- .../fuzzyjoin/dblp-1_2.1/dblp-1_2.1.1.adm | 604 +- .../results/fuzzyjoin/dblp-1_2/dblp-1_2.1.adm | 604 +- .../fuzzyjoin/dblp-3_1.1/dblp-3_1.1.1.adm | 26 +- .../fuzzyjoin/dblp-3_1.2/dblp-3_1.2.1.adm | 26 +- .../results/fuzzyjoin/dblp-3_1/dblp-3_1.1.adm | 26 +- .../fuzzyjoin/dblp-csx-2_1/dblp-csx-2_1.1.adm | 14 +- .../fuzzyjoin/dblp-csx-2_2/dblp-csx-2_2.1.adm | 14 +- .../fuzzyjoin/dblp-csx-2_3/dblp-csx-2_3.1.adm | 14 +- .../fuzzyjoin/dblp-csx-2_4/dblp-csx-2_4.1.adm | 14 +- .../dblp-csx-2_5.1/dblp-csx-2_5.1.1.adm | 14 +- .../dblp-csx-2_5.2/dblp-csx-2_5.2.1.adm | 14 +- .../dblp-csx-2_5.3.1/dblp-csx-2_5.3.1.1.adm | 14 +- .../dblp-csx-2_5.3/dblp-csx-2_5.3.1.adm | 14 +- .../fuzzyjoin/dblp-csx-2_5/dblp-csx-2_5.1.adm | 14 +- .../fuzzyjoin/dblp-csx-3_1/dblp-csx-3_1.1.adm | 14 +- .../fuzzyjoin/dblp-csx-3_2/dblp-csx-3_2.1.adm | 14 +- .../fuzzyjoin/dblp-csx-3_3/dblp-csx-3_3.1.adm | 14 +- .../fuzzyjoin/dblp-csx-3_4/dblp-csx-3_4.1.adm | 14 +- .../dblp-csx-3_5.1/dblp-csx-3_5.1.1.adm | 14 +- .../dblp-csx-3_5.2/dblp-csx-3_5.2.1.adm | 14 +- .../dblp-csx-3_5.3.1/dblp-csx-3_5.3.1.1.adm | 14 +- .../dblp-csx-3_5.3/dblp-csx-3_5.3.1.adm | 14 +- .../dblp-csx-3_5.4.1/dblp-csx-3_5.4.1.1.adm | 14 +- .../dblp-csx-3_5.4/dblp-csx-3_5.4.1.adm | 14 +- .../fuzzyjoin/dblp-csx-3_5/dblp-csx-3_5.1.adm | 14 +- .../results/group-by/core-01/core-01.1.adm | 2 +- .../results/group-by/core-03/core-03.1.adm | 2 +- .../results/group-by/core-05/core-05.1.adm | 2 +- .../runtimets/results/group-by/null/null.1.adm | 2 +- .../hdfs/large-record/large-record.1.adm | 2 +- .../range-search-open/range-search-open.1.adm | 5956 +-- .../range-search/range-search.1.adm | 5956 +-- .../ngram-jaccard-inline.1.adm | 16 +- .../olist-jaccard-inline.1.adm | 230 +- .../ulist-jaccard-inline.1.adm | 230 +- .../word-jaccard-inline.1.adm | 12 +- .../ngram-jaccard-inline.1.adm | 16 +- .../olist-jaccard-inline.1.adm | 230 +- .../ulist-jaccard-inline.1.adm | 230 +- .../word-jaccard-inline.1.adm | 12 +- .../ordered-list-constructor_04.1.adm | 2 +- .../runtimets/results/load/csv_01/csv_01.1.adm | 14 +- .../runtimets/results/load/csv_02/csv_02.1.adm | 14 +- .../runtimets/results/load/csv_03/csv_03.1.adm | 8 +- .../runtimets/results/load/csv_04/csv_04.1.adm | 8 +- .../runtimets/results/load/csv_05/csv_05.1.adm | 4 - .../runtimets/results/load/csv_06/csv_06.1.adm | 4 - .../runtimets/results/load/csv_07/csv_07.1.adm | 4 - .../runtimets/results/load/csv_08/csv_08.1.adm | 14 +- .../type_promotion_0/type_promotion_0.1.adm | 18 +- ...uery_dataset_with_meta_primary_index-1.1.adm | 2 +- ...uery_dataset_with_meta_primary_index-1.2.adm | 2 +- .../results/misc/float_01/float_01.1.adm | 12 +- .../query-ASTERIXDB-1203.1.adm | 4 +- .../results/misc/stable_sort/stable_sort.3.adm | 12010 +++--- .../compact-dataset-and-its-indexes.1.adm | 334 +- .../ngram-jaccard-inline.1.adm | 16 +- .../word-jaccard-inline.1.adm | 12 +- .../range-search-open/range-search-open.1.adm | 5956 +-- .../range-search/range-search.1.adm | 5956 +-- .../ngram-jaccard-inline.1.adm | 10 +- .../word-jaccard-inline.1.adm | 6 +- .../range-search/range-search.1.adm | 2986 +- .../group-by-from-dataset.1.adm | 2 +- .../null-missing/group-by/group-by.1.adm | 2 +- .../runtimets/results/null-missing/is/is.1.adm | 1 + .../order-by-from-dataset.1.adm | 2 +- .../null-missing/order-by/order-by.1.adm | 2 +- .../runtimets/results/numeric/abs0/abs0.1.adm | 2 +- .../runtimets/results/numeric/abs1/abs1.1.adm | 2 +- .../runtimets/results/numeric/abs2/abs2.1.adm | 2 +- .../runtimets/results/numeric/abs3/abs3.1.adm | 2 +- .../runtimets/results/numeric/abs4/abs4.1.adm | 2 +- .../results/numeric/add_double/add_double.1.adm | 2 +- .../results/numeric/add_float/add_float.1.adm | 2 +- .../results/numeric/add_int16/add_int16.1.adm | 2 +- .../results/numeric/add_int32/add_int32.1.adm | 2 +- .../results/numeric/add_int64/add_int64.1.adm | 2 +- .../results/numeric/add_int8/add_int8.1.adm | 2 +- .../results/numeric/caret0/caret0.1.adm | 2 +- .../results/numeric/ceiling0/ceiling0.1.adm | 2 +- .../results/numeric/ceiling1/ceiling1.1.adm | 2 +- .../results/numeric/ceiling2/ceiling2.1.adm | 2 +- .../results/numeric/ceiling3/ceiling3.1.adm | 2 +- .../results/numeric/ceiling4/ceiling4.1.adm | 2 +- .../numeric/divide_double/divide_double.1.adm | 2 +- .../numeric/divide_float/divide_float.1.adm | 2 +- .../numeric/divide_int16/divide_int16.1.adm | 2 +- .../numeric/divide_int32/divide_int32.1.adm | 2 +- .../numeric/divide_int64/divide_int64.1.adm | 2 +- .../numeric/divide_int8/divide_int8.1.adm | 2 +- .../results/numeric/floor0/floor0.1.adm | 2 +- .../results/numeric/floor1/floor1.1.adm | 2 +- .../results/numeric/floor2/floor2.1.adm | 2 +- .../results/numeric/floor3/floor3.1.adm | 2 +- .../results/numeric/floor4/floor4.1.adm | 2 +- .../results/numeric/issue_1166/issue_1166.1.adm | 4 +- .../multiply_double/multiply_double.1.adm | 2 +- .../numeric/multiply_float/multiply_float.1.adm | 2 +- .../numeric/multiply_int16/multiply_int16.1.adm | 2 +- .../numeric/multiply_int32/multiply_int32.1.adm | 2 +- .../numeric/multiply_int64/multiply_int64.1.adm | 2 +- .../numeric/multiply_int8/multiply_int8.1.adm | 2 +- .../round-half-to-even0.1.adm | 2 +- .../round-half-to-even1.1.adm | 2 +- .../round-half-to-even2.1.adm | 2 +- .../round-half-to-even20.1.adm | 2 +- .../round-half-to-even21.1.adm | 2 +- .../round-half-to-even22.1.adm | 2 +- .../round-half-to-even23.1.adm | 2 +- .../round-half-to-even24.1.adm | 2 +- .../round-half-to-even3.1.adm | 2 +- .../round-half-to-even4.1.adm | 2 +- .../round-half-to-even5.1.adm | 2 +- .../results/numeric/round0/round0.1.adm | 2 +- .../results/numeric/round1/round1.1.adm | 2 +- .../results/numeric/round2/round2.1.adm | 2 +- .../results/numeric/round3/round3.1.adm | 2 +- .../results/numeric/round4/round4.1.adm | 2 +- .../subtract_double/subtract_double.1.adm | 2 +- .../numeric/subtract_float/subtract_float.1.adm | 2 +- .../numeric/subtract_int16/subtract_int16.1.adm | 2 +- .../numeric/subtract_int32/subtract_int32.1.adm | 2 +- .../numeric/subtract_int64/subtract_int64.1.adm | 2 +- .../numeric/subtract_int8/subtract_int8.1.adm | 2 +- .../unary-minus_double_02.1.adm | 2 +- .../unary-minus_float_02.1.adm | 2 +- .../unary-minus_int_02/unary-minus_int_02.1.adm | 2 +- .../query-issue134/query-issue134.1.adm | 2 +- .../query-issue343-2/query-issue343-2.1.adm | 2 +- .../query-issue343/query-issue343.1.adm | 2 +- .../query-issue410/query-issue410.1.adm | 1 - .../query-issue487/query-issue487.1.adm | 1 - .../query-issue55-1/query-issue55-1.1.adm | 90 +- .../ngram-jaccard-inline.1.adm | 10 +- .../word-jaccard-inline.1.adm | 6 +- .../range-search/range-search.1.adm | 2986 +- .../query-ASTERIXDB-1005.1.adm | 2 +- .../documentation-example.2.adm | 2 +- .../documentation-example.3.adm | 2 +- .../highly-nested-open/highly-nested-open.3.adm | 8 +- .../documentation-example.1.adm | 2 +- .../documentation-example.2.adm | 2 +- .../documentation-example.3.adm | 2 +- .../highly-nested-open/highly-nested-open.3.adm | 2 +- .../documentation-example.2.adm | 2 +- .../documentation-example.3.adm | 2 +- .../highly-nested-open/highly-nested-open.3.adm | 2 +- .../scan/alltypes_01-wrapped/alltypes_01.1.adm | 2 +- .../results/scan/alltypes_01/alltypes_01.1.adm | 2 +- .../results/scan/alltypes_02/alltypes_02.1.adm | 2 +- .../numeric_types_01/numeric_types_01.1.adm | 2 +- .../results/select-star/from/from.1.adm | 3 + .../results/select-star/group_by/group_by.1.adm | 5 + .../results/select-star/join/join.1.adm | 3 + .../results/select-star/mixed/mixed.1.adm | 3 + .../results/select-star/no_star/no_star.1.adm | 3 + .../semistructured/has-param1/has-param1.1.adm | 4 +- .../prefix-len-jaccard/prefix-len-jaccard.1.adm | 2 +- .../similarity-jaccard-check_ints.1.adm | 24 +- .../similarity-jaccard-check_strings.1.adm | 32 +- ...ilarity-jaccard-check_strings_issue628.1.adm | 6 +- .../similarity-jaccard-prefix-check.1.adm | 2 +- .../similarity-jaccard-prefix.1.adm | 2 +- .../similarity-jaccard-sorted-check_ints.1.adm | 16 +- ...imilarity-jaccard-sorted-check_strings.1.adm | 24 +- .../similarity-jaccard-sorted_ints.1.adm | 8 +- .../similarity-jaccard-sorted_strings.1.adm | 12 +- .../similarity-jaccard_ints.1.adm | 12 +- .../similarity-jaccard_strings.1.adm | 16 +- .../circle_accessor/circle_accessor.1.adm | 2 +- .../distance-between-points.1.adm | 42 +- .../spatial/point_accessor/point_accessor.1.adm | 2 +- .../spatial/spatial-area/spatial-area.1.adm | 2 +- .../string/starts-with7/starts-with7.1.adm | 2 +- .../decorrelate_with_unique_id.1.adm | 300 +- .../subquery/gby_inline/gby_inline.1.adm | 300 +- .../runtimets/results/subquery/in/in.1.adm | 2 + .../results/subquery/not_in/not_in.1.adm | 4 + .../delete-from-loaded-dataset-with-index.1.adm | 334 +- .../delete-from-loaded-dataset.1.adm | 50 +- .../empty-load-with-index.1.adm | 2 +- .../q01_pricing_summary_report_nt.1.adm | 8 +- .../temp_primary_plus_ngram_flush.3.adm | 2 +- .../get_overlapping_interval.1.adm | 2 +- .../temporal/interval_bin/interval_bin.1.adm | 2 +- .../interval_bin_gby_1/interval_bin_gby_1.1.adm | 2 +- .../temporal/overlap_bins/overlap_bins.1.adm | 2 +- .../overlap_bins_gby_0/overlap_bins_gby_0.1.adm | 2 +- .../overlap_bins_gby_1/overlap_bins_gby_1.1.adm | 2 +- .../overlap_bins_gby_3/overlap_bins_gby_3.1.adm | 2 +- .../tinysocial-suite-open/aggregate.27.adm | 2 +- .../tinysocial-suite-open/group-by.26.adm | 6 +- .../query-ASTERIXDB-1331.25.adm | 2 +- .../tinysocial-suite/tinysocial-suite.25.adm | 2 +- .../counthashed-gram-tokens_01.1.adm | 42 +- .../counthashed-gram-tokens_02.1.adm | 50 +- .../counthashed-word-tokens_01.1.adm | 36 +- .../hashed-gram-tokens_01.1.adm | 42 +- .../hashed-gram-tokens_02.1.adm | 50 +- .../hashed-word-tokens_01.1.adm | 36 +- .../q01_pricing_summary_report_nt.1.adm | 8 +- .../q02_minimum_cost_supplier.1.adm | 26 +- .../q03_shipping_priority_nt.1.adm | 16 +- .../q05_local_supplier_volume.1.adm | 16 +- .../q06_forecast_revenue_change.1.adm | 2 +- .../q07_volume_shipping.1.adm | 74 +- .../q08_national_market_share.1.adm | 4 +- .../q09_product_type_profit_nt.1.adm | 118 +- .../q10_returned_item/q10_returned_ite.1.adm | 40 +- .../q10_returned_item_int64.1.adm | 40 +- .../q11_important_stock.1.adm | 400 +- .../q14_promotion_effect.1.adm | 2 +- .../q15_top_supplier/q15_top_supplier.1.adm | 2 +- .../q17_large_gby_variant.3.adm | 400 +- .../q17_small_quantity_order_revenue.1.adm | 2 +- .../q18_large_volume_customer.1.adm | 200 +- .../q19_discounted_revenue.1.adm | 2 +- .../q22_global_sales_opportunity.1.adm | 46 +- .../query-issue638/query-issue638.1.adm | 118 +- .../query-issue785-2/query-issue785-2.1.adm | 20 +- .../query-issue785/query-issue785.1.adm | 48 +- .../distinct_by/distinct_by.1.adm | 28 + .../group_no_agg/group_no_agg.1.adm | 5 + .../nest_aggregate/nest_aggregate.1.adm | 11 + .../nest_aggregate2/nest_aggregate2.1.adm | 11 + .../q01_pricing_summary_report_nt.1.adm | 4 + .../q02_minimum_cost_supplier.1.adm | 13 + .../q03_shipping_priority_nt.1.adm | 8 + .../q04_order_priority/q04_order_priority.1.adm | 5 + .../q05_local_supplier_volume.1.adm | 8 + .../q06_forecast_revenue_change.1.adm | 1 + .../q07_volume_shipping.1.adm | 37 + .../q08_national_market_share.1.adm | 2 + .../q09_product_type_profit_nt.1.adm | 59 + .../q10_returned_item/q10_returned_ite.1.adm | 20 + .../q10_returned_item_int64.1.adm | 20 + .../q11_important_stock.1.adm | 200 + .../q12_shipping/q12_shipping.1.adm | 2 + .../q13_customer_distribution.1.adm | 27 + .../q14_promotion_effect.1.adm | 1 + .../q15_top_supplier/q15_top_supplier.1.adm | 1 + .../q16_parts_supplier_relationship.1.adm | 34 + .../q17_large_gby_variant.3.adm | 200 + .../q17_small_quantity_order_revenue.1.adm | 1 + .../q18_large_volume_customer.1.adm | 100 + .../q19_discounted_revenue.1.adm | 1 + .../q20_potential_part_promotion.1.adm | 10 + .../q21_suppliers_who_kept_orders_waiting.1.adm | 10 + .../q22_global_sales_opportunity.1.adm | 23 + .../query-issue562/query-issue562.1.adm | 7 + .../query-issue601/query-issue601.1.adm | 7 + .../query-issue638/query-issue638.1.adm | 59 + .../query-issue785-2/query-issue785-2.1.adm | 10 + .../query-issue785/query-issue785.1.adm | 24 + .../query-issue786/query-issue786.1.adm | 0 .../query-issue810-2/query-issue810-2.1.adm | 4 + .../query-issue810-3/query-issue810-3.1.adm | 4 + .../query-issue810/query-issue810.1.adm | 4 + .../query-issue827-2/query-issue827-2.1.adm | 1 + .../query-issue827/query-issue827.1.adm | 1 + .../nest_aggregate/nest_aggregate.1.adm | 20 +- .../q01_pricing_summary_report_nt.1.adm | 8 +- .../q02_minimum_cost_supplier.1.adm | 26 +- .../q03_shipping_priority_nt.1.adm | 16 +- .../q05_local_supplier_volume.1.adm | 16 +- .../q06_forecast_revenue_change.1.adm | 2 +- .../q07_volume_shipping.1.adm | 74 +- .../q08_national_market_share.1.adm | 4 +- .../q09_product_type_profit_nt.1.adm | 118 +- .../q10_returned_item/q10_returned_ite.1.adm | 40 +- .../q10_returned_item_int64.1.adm | 40 +- .../q11_important_stock.1.adm | 400 +- .../q14_promotion_effect.1.adm | 2 +- .../q15_top_supplier/q15_top_supplier.1.adm | 2 +- .../q17_large_gby_variant.3.adm | 400 +- .../q17_small_quantity_order_revenue.1.adm | 2 +- .../q18_large_volume_customer.1.adm | 200 +- .../q19_discounted_revenue.1.adm | 2 +- .../q22_global_sales_opportunity.1.adm | 46 +- .../query-issue562/query-issue562.1.adm | 14 +- .../query-issue638/query-issue638.1.adm | 118 +- .../query-issue785-2/query-issue785-2.1.adm | 20 +- .../query-issue785/query-issue785.1.adm | 48 +- .../query-issue810-2/query-issue810-2.1.adm | 8 +- .../query-issue810-3/query-issue810-3.1.adm | 8 +- .../query-issue827-2/query-issue827-2.1.adm | 1 - .../query-issue827/query-issue827.1.adm | 1 - .../nest_aggregate/nest_aggregate.1.adm | 20 +- .../q01_pricing_summary_report_nt.1.adm | 8 +- .../q02_minimum_cost_supplier.1.adm | 26 +- .../q03_shipping_priority_nt.1.adm | 16 +- .../q05_local_supplier_volume.1.adm | 16 +- .../q06_forecast_revenue_change.1.adm | 2 +- .../q07_volume_shipping.1.adm | 74 +- .../q08_national_market_share.1.adm | 4 +- .../q09_product_type_profit_nt.1.adm | 118 +- .../q10_returned_item/q10_returned_ite.1.adm | 40 +- .../q10_returned_item_int64.1.adm | 40 +- .../q11_important_stock.1.adm | 400 +- .../q14_promotion_effect.1.adm | 2 +- .../q15_top_supplier/q15_top_supplier.1.adm | 2 +- .../q17_large_gby_variant.3.adm | 400 +- .../q17_small_quantity_order_revenue.1.adm | 2 +- .../q18_large_volume_customer.1.adm | 200 +- .../q19_discounted_revenue.1.adm | 2 +- .../q22_global_sales_opportunity.1.adm | 46 +- .../query-issue562/query-issue562.1.adm | 14 +- .../query-issue785-2/query-issue785-2.1.adm | 20 +- .../query-issue785/query-issue785.1.adm | 48 +- .../query-issue810-2/query-issue810-2.1.adm | 8 +- .../query-issue810-3/query-issue810-3.1.adm | 8 +- .../query-issue827-2/query-issue827-2.1.adm | 2 +- .../query-issue827/query-issue827.1.adm | 2 +- .../tpch/nest_aggregate/nest_aggregate.1.adm | 20 +- .../q01_pricing_summary_report_nt.1.adm | 8 +- .../q02_minimum_cost_supplier.1.adm | 26 +- .../q03_shipping_priority_nt.1.adm | 16 +- .../q05_local_supplier_volume.1.adm | 16 +- .../q06_forecast_revenue_change.1.adm | 2 +- .../q07_volume_shipping.1.adm | 74 +- .../q08_national_market_share.1.adm | 4 +- .../q09_product_type_profit_nt.1.adm | 118 +- .../q10_returned_item/q10_returned_ite.1.adm | 40 +- .../q10_returned_item_int64.1.adm | 40 +- .../q11_important_stock.1.adm | 400 +- .../q14_promotion_effect.1.adm | 2 +- .../q15_top_supplier/q15_top_supplier.1.adm | 2 +- .../q17_large_gby_variant.3.adm | 400 +- .../q17_small_quantity_order_revenue.1.adm | 2 +- .../q18_large_volume_customer.1.adm | 200 +- .../q19_discounted_revenue.1.adm | 2 +- .../q22_global_sales_opportunity.1.adm | 46 +- .../query-ASTERIXDB-1127.1.adm | 16 +- .../tpch/query-issue562/query-issue562.1.adm | 14 +- .../tpch/query-issue638/query-issue638.1.adm | 118 +- .../query-issue785-2/query-issue785-2.1.adm | 20 +- .../tpch/query-issue785/query-issue785.1.adm | 48 +- .../query-issue810-2/query-issue810-2.1.adm | 8 +- .../query-issue810-3/query-issue810-3.1.adm | 8 +- .../query-issue827-2/query-issue827-2.1.adm | 2 +- .../tpch/query-issue827/query-issue827.1.adm | 2 +- .../opentype_orderby_01.1.adm | 20 +- ...losedtype_field_vs_closedtype_field_04.1.adm | 112 +- ...losedtype_field_vs_closedtype_field_05.1.adm | 40 +- ..._closedtype_field_vs_opentype_field_01.1.adm | 112 +- ..._closedtype_field_vs_opentype_field_02.1.adm | 20 +- ..._closedtype_field_vs_opentype_field_03.1.adm | 20 +- ..._closedtype_field_vs_opentype_field_04.1.adm | 20 +- ...romotion_opentype_field_vs_constant_01.1.adm | 2 +- ...romotion_opentype_field_vs_constant_02.1.adm | 2 +- ...romotion_opentype_field_vs_constant_03.1.adm | 2 +- ...romotion_opentype_field_vs_constant_04.1.adm | 2 +- ...romotion_opentype_field_vs_constant_05.1.adm | 2 +- ...romotion_opentype_field_vs_constant_06.1.adm | 2 +- ...on_opentype_field_vs_opentype_field_01.1.adm | 20 +- ...on_opentype_field_vs_opentype_field_02.1.adm | 20 +- .../type_promotion_0/type_promotion_0.1.adm | 6 +- .../type_promotion_1/type_promotion_1.1.adm | 2 +- .../query-ASTERIXDB-1205-3.1.adm | 2 +- .../upsert/primary-index/primary-index.1.adm | 18 +- .../primary-secondary-btree.1.adm | 10 +- .../upsert-with-self-read.1.adm | 10 +- .../query-ASTERIXDB-1308-1.1.adm | 8 +- .../query-ASTERIXDB-1317.1.adm | 108 +- .../query-issue455/query-issue455.3.adm | 2 +- .../user-defined-functions/udf06/udf06.1.adm | 2 +- .../user-defined-functions/udf07/udf07.1.adm | 2 +- .../user-defined-functions/udf19/udf19.1.adm | 8 +- .../user-defined-functions/udf20/udf20.1.adm | 8 +- .../user-defined-functions/udf23/udf23.1.adm | 12 +- .../sum_null-with-pred/sum_null-with-pred.3.ast | 5 +- .../sum_null-with-pred/sum_null-with-pred.3.ast | 5 +- .../boolean/not_01/not_01.3.ast | 7 +- .../groupby-orderby-count.3.ast | 8 +- .../misc/is-null_01/is-null_01.3.ast | 4 +- .../quantifiers/everysat_04/everysat_04.3.ast | 9 +- .../quantifiers/somesat_06/somesat_06.3.ast | 8 +- .../semistructured/has-param1/has-param1.3.ast | 4 +- .../string/like_01/like_01.3.ast | 6 +- .../string/like_null/like_null.3.ast | 6 +- .../date_functions/date_functions.3.ast | 2 +- .../overlap_bins_gby_3/overlap_bins_gby_3.3.ast | 8 +- .../query-ASTERIXDB-1263.23.ast | 12 +- .../tinysocial-suite.12.ast | 2 +- .../tinysocial-suite.13.ast | 4 +- .../query-ASTERIXDB-1263.23.ast | 12 +- .../tinysocial-suite/tinysocial-suite.12.ast | 2 +- .../tinysocial-suite/tinysocial-suite.13.ast | 4 +- .../q02_minimum_cost_supplier.3.ast | 6 +- .../q13_customer_distribution.3.ast | 13 +- .../q14_promotion_effect.3.ast | 3 +- .../q16_parts_supplier_relationship.3.ast | 26 +- .../q02_minimum_cost_supplier.3.ast | 6 +- .../q13_customer_distribution.3.ast | 13 +- .../q14_promotion_effect.3.ast | 3 +- .../q16_parts_supplier_relationship.3.ast | 26 +- .../user-defined-functions/udf18/udf18.3.ast | 3 +- .../user-defined-functions/udf30/udf30.1.ast | 13 + .../src/test/resources/runtimets/testsuite.xml | 57 +- .../resources/runtimets/testsuite_sqlpp.xml | 306 +- .../q01_pricing_summary_report_nt.3.query.adm | 8 +- .../q02_minimum_cost_supplier.3.query.adm | 200 +- .../q03_shipping_priority_nt.3.query.adm | 20 +- .../tpc-h/results/q10_returned_item.3.query.adm | 40 +- .../results/q11_important_stock.3.query.adm | 1776 +- .../tpc-h/results/q15_top_supplier.3.query.adm | 2 +- ...q17_small_quantity_order_revenue.3.query.adm | 2 +- asterixdb/asterix-common/pom.xml | 7 +- .../common/api/IAsterixAppRuntimeContext.java | 3 + .../config/AsterixMetadataProperties.java | 2 +- .../config/AsterixPropertiesAccessor.java | 86 +- .../common/config/AsterixStorageProperties.java | 4 +- .../common/context/DatasetLifecycleManager.java | 17 + .../IAsterixApplicationContextInfo.java | 9 + .../asterix/common/library/ILibraryManager.java | 59 + .../apache/asterix/common/utils/JSONUtil.java | 149 + .../src/main/resources/schema/cluster.xsd | 242 +- .../src/main/resources/schema/yarn_cluster.xsd | 6 +- .../asterix/test/aql/ResultExtractor.java | 171 + .../apache/asterix/test/aql/TestExecutor.java | 88 +- .../asterix/test/base/AsterixTestHelper.java | 55 + asterixdb/asterix-doc/pom.xml | 4 +- .../src/site/markdown/aql/datamodel.md | 24 +- .../src/site/markdown/aql/functions.md | 107 +- .../asterix-doc/src/site/markdown/aql/manual.md | 24 +- .../src/site/markdown/aql/primer-sql-like.md | 2 +- .../asterix-doc/src/site/markdown/aql/primer.md | 51 +- .../asterix-doc/src/site/markdown/index.md | 12 +- .../asterix-doc/src/site/markdown/overview.md | 4 +- asterixdb/asterix-doc/src/site/markdown/udf.md | 2 +- asterixdb/asterix-doc/src/site/markdown/yarn.md | 2 +- asterixdb/asterix-experiments/pom.xml | 7 +- .../action/derived/RunSQLPPFileAction.java | 105 + .../builder/AbstractPerfLoadBuilder.java | 251 + .../experiment/builder/Experiment1EBuilder.java | 30 + .../experiment/builder/PerfTestAggBuilder.java | 40 + .../client/LSMExperimentConstants.java | 1 + .../client/LSMExperimentSetRunner.java | 175 +- .../experiment/client/LSMPerfConstants.java | 43 + .../aql/agg.sqlpp | 9 + .../aql/agg_bench/agg-3-months.sqlpp | 27 + .../aql/agg_bench/agg-6-months.sqlpp | 27 + .../aql/agg_bench/agg-day.sqlpp | 27 + .../aql/agg_bench/agg-hour.sqlpp | 27 + .../aql/agg_bench/agg-minute.sqlpp | 27 + .../aql/agg_bench/agg-month.sqlpp | 27 + .../aql/agg_bench/agg-week.sqlpp | 27 + .../aql/agg_bench/countjoin-3-months.sqlpp | 36 + .../aql/agg_bench/countjoin-6-months.sqlpp | 36 + .../aql/agg_bench/countjoin-day.sqlpp | 36 + .../aql/agg_bench/countjoin-hour.sqlpp | 36 + .../aql/agg_bench/countjoin-minute.sqlpp | 36 + .../aql/agg_bench/countjoin-month.sqlpp | 36 + .../aql/agg_bench/countjoin-week.sqlpp | 36 + .../agg_bench/countjoin_index-3-months.sqlpp | 36 + .../agg_bench/countjoin_index-6-months.sqlpp | 36 + .../aql/agg_bench/countjoin_index-day.sqlpp | 36 + .../aql/agg_bench/countjoin_index-hour.sqlpp | 36 + .../aql/agg_bench/countjoin_index-minute.sqlpp | 36 + .../aql/agg_bench/countjoin_index-month.sqlpp | 36 + .../aql/agg_bench/countjoin_index-week.sqlpp | 36 + .../aql/agg_bench/join-3-months.sqlpp | 32 + .../aql/agg_bench/join-6-months.sqlpp | 32 + .../aql/agg_bench/join-day.sqlpp | 32 + .../aql/agg_bench/join-hour.sqlpp | 32 + .../aql/agg_bench/join-minute.sqlpp | 32 + .../aql/agg_bench/join-month.sqlpp | 32 + .../aql/agg_bench/join-week.sqlpp | 32 + .../aql/agg_bench/join_indexnl-3-months.sqlpp | 32 + .../aql/agg_bench/join_indexnl-6-months.sqlpp | 32 + .../aql/agg_bench/join_indexnl-day.sqlpp | 32 + .../aql/agg_bench/join_indexnl-hour.sqlpp | 32 + .../aql/agg_bench/join_indexnl-minute.sqlpp | 32 + .../aql/agg_bench/join_indexnl-month.sqlpp | 32 + .../aql/agg_bench/join_indexnl-week.sqlpp | 32 + .../aql/agg_bench/joingby-3-months.sqlpp | 31 + .../aql/agg_bench/joingby-6-months.sqlpp | 31 + .../aql/agg_bench/joingby-day.sqlpp | 31 + .../aql/agg_bench/joingby-hour.sqlpp | 31 + .../aql/agg_bench/joingby-minute.sqlpp | 31 + .../aql/agg_bench/joingby-month.sqlpp | 31 + .../aql/agg_bench/joingby-week.sqlpp | 31 + .../aql/agg_bench/joingby_index-3-months.sqlpp | 31 + .../aql/agg_bench/joingby_index-6-months.sqlpp | 31 + .../aql/agg_bench/joingby_index-day.sqlpp | 31 + .../aql/agg_bench/joingby_index-hour.sqlpp | 31 + .../aql/agg_bench/joingby_index-minute.sqlpp | 31 + .../aql/agg_bench/joingby_index-month.sqlpp | 31 + .../aql/agg_bench/joingby_index-week.sqlpp | 31 + .../aql/base/asterix_base_4_ingest.aql | 2 + .../aql/base/nuclear_base_4_ingest.aql | 14 + .../aql/base/perf_types.aql | 45 + .../aql/bench_3.aql | 8 + .../aql/bench_3_load.aql | 8 + .../aql/bench_count.aql | 4 + .../configs/asterix-agg.xml | 55 + .../configs/asterix-configuration.xml | 2 +- .../configs/managix-conf.xml | 6 +- .../configs/nuclear.xml | 52 + .../dgen/asterix-4.dgen | 4 + .../dgen/nuc.dgen | 3 + .../logging.properties | 4 +- asterixdb/asterix-external-data/pom.xml | 9 +- .../adapter/factory/GenericAdapterFactory.java | 40 +- .../adapter/factory/LookupAdapterFactory.java | 6 +- .../asterix/external/api/IAdapterFactory.java | 23 +- .../external/api/IRecordWithMetaDataParser.java | 26 - .../external/api/IRecordWithMetadataParser.java | 30 + .../ChangeFeedWithMetaDataFlowController.java | 10 +- .../FeedWithMetaDataFlowController.java | 12 +- .../external/input/record/CharArrayRecord.java | 4 +- .../external/input/record/GenericRecord.java | 5 + .../input/record/RecordWithMetadataAndPK.java | 2 +- .../external/input/record/RecordWithPK.java | 2 +- .../record/converter/DCPConverterFactory.java | 2 +- .../converter/DCPMessageToRecordConverter.java | 127 + ...questToRecordWithMetadataAndPKConverter.java | 124 - .../external/library/ExternalFunction.java | 15 +- .../library/ExternalLibraryManager.java | 27 +- .../operators/FeedIntakeOperatorDescriptor.java | 28 +- .../parser/RecordWithMetadataParser.java | 9 +- .../parser/factory/RSSParserFactory.java | 1 + .../parser/factory/TweetParserFactory.java | 1 + .../provider/AdapterFactoryProvider.java | 28 +- .../provider/DataflowControllerProvider.java | 8 +- .../provider/DatasourceFactoryProvider.java | 22 +- .../provider/ParserFactoryProvider.java | 15 +- .../provider/StreamRecordReaderProvider.java | 2 +- .../external/util/ExternalDataConstants.java | 2 +- .../external/util/ExternalDataUtils.java | 45 +- .../src/main/resources/adm.grammar | 18 +- .../src/main/resources/schema/library.xsd | 106 +- .../apache/asterix/external/classad/Util.java | 89 +- .../external/classad/test/ClassAdToADMTest.java | 89 +- .../generator/test/DCPGeneratorTest.java | 4 +- .../input/record/reader/kv/KVTestReader.java | 17 +- .../asterix/external/library/ClassAdParser.java | 16 +- .../adapter/TestTypedAdapterFactory.java | 23 +- .../external/parser/TestRecordWithPKParser.java | 2 +- .../factory/TestRecordWithPKParserFactory.java | 3 +- .../parser/test/ByteBufUTF8DecodeTest.java | 99 + .../parser/test/RecordWithMetaTest.java | 2 +- .../src/test/resources/ICanEatGlass.txt | 149 + .../src/test/resources/escapes.txt | 4 + .../src/test/resources/jobads.txt | 34801 +++++++++++------ .../src/test/resources/record.json | 375 + .../src/test/resources/results/beer.txt | 14522 +++---- .../results/classad-with-temporals.adm | 2 +- asterixdb/asterix-fuzzyjoin/pom.xml | 1 + .../hadoop-0.20.2/bin/hadoop-config.sh | 12 +- .../installer/test/AbstractExecutionIT.java | 26 +- .../test/AsterixExternalLibraryIT.java | 11 + .../installer/test/AsterixLifecycleIT.java | 5 + .../installer/transaction/DmlRecoveryIT.java | 8 + .../installer/transaction/RecoveryIT.java | 12 +- .../insert-from-select/insert-from-select.1.adm | 2 +- .../results/library-functions/mysum/mysum.1.adm | 2 +- .../library-functions/toUpper/toUpper.1.adm | 2 +- .../dataverseDataset/dataverseDataset.1.adm | 4 +- .../libraryDataset/libraryDataset.1.adm | 2 +- .../record-parser/record-parser.1.adm | 200 +- .../backupRestore/backupRestore.1.adm | 2 +- .../big_object_20M/big_object_20M.1.script.aql | 1 + .../big_object_20M/big_object_20M.2.ddl.aql | 36 + .../big_object_20M/big_object_20M.3.update.aql | 30 + .../big_object_20M/big_object_20M.4.script.aql | 1 + .../big_object_20M/big_object_20M.5.query.aql | 23 + .../big_object_20M/big_object_20M.6.script.aql | 1 + .../dataset-with-meta-record.2.ddl.aql | 2 - .../dataset_recovery/dataset_recovery.2.ddl.aql | 12 +- .../datatype_recovery.2.ddl.aql | 12 +- .../secondary_index_recovery.2.ddl.aql | 12 +- .../dataset_recovery.2.ddl.aql | 12 +- .../secondary_index_recovery.2.ddl.aql | 12 +- .../big_object_20M.1.adm.template | 1 + .../scripts/dml_recovery/create_and_start.sh | 2 + .../big_object_20M/create_and_start.sh | 3 + .../big_object_20M/stop_and_delete.sh | 3 + .../big_object_20M/stop_and_start.sh | 2 + .../create_and_start.sh | 6 + .../external_index/create_and_start.sh | 2 + .../test/resources/transactionts/testsuite.xml | 5 + .../asterix-lang-aql/src/main/javacc/AQL.jj | 4 +- .../asterix/lang/common/base/Expression.java | 4 +- .../lang/common/expression/OperatorExpr.java | 53 +- .../common/rewrites/LangRewritingContext.java | 11 +- .../common/statement/CreateIndexStatement.java | 11 + .../lang/common/struct/OperatorType.java | 15 +- .../asterix/lang/sqlpp/clause/FromTerm.java | 7 +- .../sqlpp/expression/IndependentSubquery.java | 57 + .../lang/sqlpp/expression/SelectExpression.java | 2 +- .../rewrites/SqlppFunctionBodyRewriter.java | 6 + .../lang/sqlpp/rewrites/SqlppQueryRewriter.java | 59 +- .../visitor/InlineColumnAliasVisitor.java | 22 +- .../visitor/InlineWithExpressionVisitor.java | 72 + .../visitor/OperatorExpressionVisitor.java | 98 + .../SqlppBuiltinFunctionRewriteVisitor.java | 5 +- .../SqlppGlobalAggregationSugarVisitor.java | 4 +- .../visitor/SqlppGroupBySugarVisitor.java | 37 +- .../rewrites/visitor/SqlppGroupByVisitor.java | 37 +- .../visitor/SqlppInlineUdfsVisitor.java | 9 + .../visitor/VariableCheckAndRewriteVisitor.java | 71 +- .../sqlpp/util/ExpressionToVariableUtil.java | 53 + .../lang/sqlpp/util/SqlppRewriteUtil.java | 10 +- .../util/SqlppVariableSubstitutionUtil.java | 3 + .../lang/sqlpp/util/SqlppVariableUtil.java | 43 +- .../visitor/CheckSql92AggregateVisitor.java | 9 + .../lang/sqlpp/visitor/DeepCopyVisitor.java | 13 +- .../lang/sqlpp/visitor/FreeVariableVisitor.java | 7 + .../sqlpp/visitor/SqlppAstPrintVisitor.java | 7 + ...SqlppCloneAndSubstituteVariablesVisitor.java | 9 + .../visitor/SqlppDeleteRewriteVisitor.java | 2 +- .../sqlpp/visitor/SqlppFormatPrintVisitor.java | 7 + .../visitor/base/AbstractSqlppAstVisitor.java | 6 + .../AbstractSqlppExpressionScopingVisitor.java | 101 +- .../AbstractSqlppSimpleExpressionVisitor.java | 143 +- .../lang/sqlpp/visitor/base/ISqlppVisitor.java | 3 + .../src/main/javacc/SQLPP.html | 148 +- .../asterix-lang-sqlpp/src/main/javacc/SQLPP.jj | 196 +- .../lexer-generator-maven-plugin/pom.xml | 1 + asterixdb/asterix-metadata/pom.xml | 6 + .../apache/asterix/metadata/MetadataNode.java | 3 - .../metadata/declared/AqlDataSource.java | 13 +- .../metadata/declared/AqlMetadataProvider.java | 105 +- .../apache/asterix/metadata/entities/Index.java | 11 + .../metadata/feeds/FeedMetadataUtil.java | 153 +- .../asterix/metadata/utils/DatasetUtils.java | 8 +- .../metadata/utils/KeyFieldTypeUtils.java | 2 +- asterixdb/asterix-om/pom.xml | 5 + .../data/common/AqlExpressionTypeComputer.java | 7 +- .../printers/adm/ADoublePrinterFactory.java | 2 +- .../printers/adm/AFloatPrinterFactory.java | 2 +- .../printers/adm/AInt16PrinterFactory.java | 2 - .../printers/adm/AInt32PrinterFactory.java | 2 - .../printers/adm/AInt8PrinterFactory.java | 2 - .../om/functions/AsterixBuiltinFunctions.java | 541 +- .../impl/CollectionMemberResultType.java | 3 +- .../impl/OpenRecordConstructorResultType.java | 42 +- .../ScalarVersionOfAggregateResultType.java | 7 +- .../apache/asterix/om/types/ARecordType.java | 47 +- .../asterix/om/util/AsterixAppContextInfo.java | 14 +- .../APolygonConstructorDescriptor.java | 12 +- .../functions/CastRecordDescriptor.java | 3 + ...rixLSMPrimaryUpsertOperatorNodePushable.java | 28 +- asterixdb/asterix-server/pom.xml | 44 + .../server/test/NCServiceExecutionIT.java | 186 + .../test/resources/NCServiceExecutionIT/cc.conf | 25 + .../NCServiceExecutionIT/ncservice1.conf | 3 + .../NCServiceExecutionIT/ncservice2.conf | 4 + .../src/test/resources/logging.properties | 4 +- asterixdb/asterix-transactions/pom.xml | 6 + asterixdb/asterix-yarn/pom.xml | 1 - .../java/org/apache/asterix/aoya/Deleter.java | 2 +- .../insert-from-select/insert-from-select.1.adm | 2 +- .../results/library-functions/mysum/mysum.1.adm | 2 +- .../library-functions/toUpper/toUpper.1.adm | 2 +- .../dataverseDataset/dataverseDataset.1.adm | 4 +- asterixdb/pom.xml | 68 +- .../IndexInsertDeleteUpsertOperator.java | 9 +- .../logical/InsertDeleteUpsertOperator.java | 35 + .../operators/logical/SubplanOperator.java | 3 +- .../visitors/OperatorDeepCopyVisitor.java | 109 +- .../IndexInsertDeleteUpsertPOperator.java | 9 +- .../physical/InsertDeleteUpsertPOperator.java | 7 +- .../LogicalExpressionPrettyPrintVisitor.java | 70 +- .../LogicalOperatorPrettyPrintVisitor.java | 11 +- .../BroadcastPartitioningProperty.java | 5 +- .../properties/IPartitioningProperty.java | 6 +- .../properties/OrderedPartitionedProperty.java | 10 +- .../properties/RandomPartitioningProperty.java | 5 +- .../properties/StructuralPropertiesVector.java | 12 +- .../UnorderedPartitionedProperty.java | 9 +- .../algebra/typing/AbstractTypeEnvironment.java | 7 +- .../base/PhysicalOptimizationConfig.java | 4 +- .../data/IBinaryHashFunctionFamilyProvider.java | 4 +- .../algebricks-examples/piglet-example/pom.xml | 1 + .../SetAlgebricksPhysicalOperatorsRule.java | 3 +- .../algebricks/rewriter/util/JoinUtils.java | 42 +- .../operators/std/UnnestRuntimeFactory.java | 7 +- .../algebricks-tests/src/main/scripts/run.sh | 2 +- hyracks-fullstack/hyracks/hyracks-api/pom.xml | 1 + .../org/apache/hyracks/api/io/IIOManager.java | 2 + .../hyracks/hyracks-client/pom.xml | 5 + .../control/cc/ClusterControllerService.java | 2 +- .../cc/application/CCApplicationContext.java | 11 +- .../hyracks/control/cc/work/TriggerNCWork.java | 28 +- .../application/IniApplicationConfig.java | 18 +- .../control/common/controllers/CCConfig.java | 43 - .../control/common/controllers/IniUtils.java | 30 +- .../control/common/controllers/NCConfig.java | 60 - .../apache/hyracks/control/nc/io/IOManager.java | 40 +- .../resources/DefaultDeallocatableRegistry.java | 16 +- .../hyracks/control/nc/service/NCService.java | 25 +- hyracks-fullstack/hyracks/hyracks-data/pom.xml | 8 + .../hyracks/hyracks-dataflow-common/pom.xml | 5 + .../common/comm/io/ArrayTupleReference.java | 44 +- .../dataflow/hadoop/util/MRContextUtil.java | 2 +- .../hyracks/hyracks-dataflow-std/pom.xml | 5 + .../src/main/resources/bin/getip.sh | 14 +- .../src/main/resources/bin/startDebugNc.sh | 4 +- .../src/main/resources/bin/startnc.sh | 4 +- .../src/main/resources/bin/stopnc.sh | 2 +- .../hyracks-integration-tests/pom.xml | 8 +- .../hyracks-shutdown-test/pom.xml | 141 +- .../text-example/textserver/pom.xml | 151 +- hyracks-fullstack/hyracks/hyracks-ipc/pom.xml | 1 + hyracks-fullstack/hyracks/hyracks-net/pom.xml | 1 + .../net/protocols/muxdemux/ChannelSet.java | 2 +- .../hyracks/hyracks-server/pom.xml | 8 +- .../server/drivers/VirtualClusterDriver.java | 82 - .../server/process/HyracksCCProcess.java | 23 +- .../server/process/HyracksNCProcess.java | 42 - .../server/process/HyracksNCServiceProcess.java | 45 + .../server/process/HyracksServerProcess.java | 66 +- .../server/process/HyracksVirtualCluster.java | 84 + .../apache/hyracks/server/test/NCServiceIT.java | 59 +- .../src/test/resources/logging.properties | 4 +- .../hyracks/hyracks-storage-am-btree/pom.xml | 3 +- .../storage/am/btree/api/IBTreeFrame.java | 2 + .../storage/am/btree/api/IBTreeLeafFrame.java | 13 +- .../frames/BTreeFieldPrefixNSMLeafFrame.java | 27 +- .../BTreeFieldPrefixNSMLeafFrameFactory.java | 5 - .../am/btree/frames/BTreeLargeFrameHelper.java | 44 - .../am/btree/frames/BTreeNSMInteriorFrame.java | 7 +- .../frames/BTreeNSMInteriorFrameFactory.java | 5 - .../am/btree/frames/BTreeNSMLeafFrame.java | 115 +- .../btree/frames/BTreeNSMLeafFrameFactory.java | 7 +- .../hyracks/storage/am/btree/impls/BTree.java | 61 +- .../btree/impls/BTreeCountingSearchCursor.java | 4 +- .../storage/am/btree/impls/BTreeOpContext.java | 26 +- .../am/btree/impls/BTreeRangeSearchCursor.java | 4 +- .../storage/am/btree/util/BTreeUtils.java | 3 - .../am/common/api/IPrimitiveValueProvider.java | 2 +- .../api/IPrimitiveValueProviderFactory.java | 2 +- .../storage/am/common/api/ISplitKey.java | 20 +- .../am/common/api/ITreeIndexAccessor.java | 32 +- .../storage/am/common/api/ITreeIndexFrame.java | 6 +- .../am/common/api/ITreeIndexFrameFactory.java | 3 - .../api/ITreeIndexMetaDataFrameFactory.java | 2 +- .../api/ITreeIndexTupleWriterFactory.java | 2 +- .../storage/am/common/api/ITupleFilter.java | 2 +- .../storage/am/common/api/ITupleUpdater.java | 2 +- .../am/common/api/ITupleUpdaterFactory.java | 2 +- .../am/common/api/TreeIndexException.java | 28 +- .../am/common/api/UnsortedInputException.java | 10 +- .../dataflow/ITreeIndexOperatorDescriptor.java | 6 +- .../TreeIndexNonExistentKeyException.java | 14 +- .../am/common/frames/AbstractSlotManager.java | 64 +- .../common/frames/LIFOMetaDataFrameFactory.java | 8 +- .../am/common/frames/TreeIndexNSMFrame.java | 15 +- .../am/common/impls/AbstractTreeIndex.java | 29 +- .../impls/TreeIndexDiskOrderScanCursor.java | 9 +- .../am/common/ophelpers/FindTupleMode.java | 2 +- .../ophelpers/FindTupleNoExactMatchPolicy.java | 2 +- .../storage/am/common/ophelpers/IndexOp.java | 2 +- .../am/common/ophelpers/LongArrayList.java | 103 + .../am/common/ophelpers/SlotOffTupleOff.java | 32 +- .../am/common/tuples/SimpleTupleReference.java | 8 +- .../common/tuples/TypeAwareTupleReference.java | 5 +- .../tuples/TypeAwareTupleWriterFactory.java | 20 +- .../common/util/TreeIndexBufferCacheWarmup.java | 14 +- .../storage/am/common/util/TreeIndexStats.java | 270 +- .../am/common/util/TreeIndexStatsGatherer.java | 99 +- .../storage/am/common/util/TreeIndexUtils.java | 24 +- .../am/lsm/btree/impls/LSMBTreeFileManager.java | 2 +- .../LSMBTreeWithBuddyDiskComponentFactory.java | 56 +- .../impls/LSMBTreeWithBuddyMemoryComponent.java | 64 +- .../impls/LSMBTreeWithBuddyMergeOperation.java | 196 +- .../impls/LSMBTreeWithBuddySearchCursor.java | 4 +- .../impls/LSMBTreeWithBuddySortedCursor.java | 278 +- .../btree/impls/LSMBuddyBTreeMergeCursor.java | 78 +- .../btree/tuples/LSMBTreeCopyTupleWriter.java | 18 +- .../tuples/LSMBTreeCopyTupleWriterFactory.java | 24 +- .../LSMBTreeRefrencingTupleWriterFactory.java | 64 +- .../btree/tuples/LSMBTreeTupleReference.java | 34 +- .../tuples/LSMBTreeTupleWriterFactory.java | 24 +- .../impls/MultitenantVirtualBufferCache.java | 17 +- .../am/lsm/common/impls/VirtualBufferCache.java | 30 +- .../tokenizers/AbstractUTF8TokenFactory.java | 22 +- ...limitedUTF8StringBinaryTokenizerFactory.java | 32 +- .../tokenizers/HashedUTF8NGramTokenFactory.java | 22 +- .../tokenizers/HashedUTF8WordTokenFactory.java | 22 +- .../tokenizers/IBinaryTokenizerFactory.java | 2 +- .../invertedindex/tokenizers/INGramToken.java | 6 +- .../tokenizers/UTF8NGramTokenFactory.java | 22 +- .../tokenizers/UTF8WordTokenFactory.java | 22 +- .../tuples/LSMTypeAwareTupleWriterFactory.java | 32 +- ...IGenericPrimitiveSerializerDeserializer.java | 4 +- .../storage/am/rtree/frames/RTreeNSMFrame.java | 7 +- .../frames/RTreeNSMInteriorFrameFactory.java | 5 - .../rtree/frames/RTreeNSMLeafFrameFactory.java | 5 - .../storage/am/rtree/impls/EntriesOrder.java | 2 +- .../hyracks/storage/am/rtree/impls/RTree.java | 8 +- .../storage/am/rtree/impls/RTreeOpContext.java | 25 +- .../storage/am/rtree/impls/RTreeSplitKey.java | 260 +- .../storage/am/rtree/impls/TupleEntry.java | 62 +- .../am/rtree/impls/TupleEntryArrayList.java | 96 +- .../HilbertDoubleComparatorFactory.java | 2 +- .../ZCurveDoubleComparatorFactory.java | 2 +- .../linearize/ZCurveIntComparatorFactory.java | 2 +- .../buffercache/AsyncFIFOPageQueueManager.java | 24 +- .../storage/common/buffercache/BufferCache.java | 156 +- .../storage/common/buffercache/CachedPage.java | 41 +- .../ClockPageReplacementStrategy.java | 88 +- .../common/buffercache/DebugBufferCache.java | 17 +- .../common/buffercache/IBufferCache.java | 14 +- .../storage/common/buffercache/ICachedPage.java | 21 +- .../common/buffercache/ICachedPageInternal.java | 5 + .../buffercache/IExtraPageBlockHelper.java | 26 + .../common/buffercache/ILargePageHelper.java | 25 - .../buffercache/IPageReplacementStrategy.java | 8 +- .../hyracks/storage/am/common/CheckTuple.java | 80 +- .../am/common/IndexMultiThreadTestDriver.java | 10 +- .../am/rtree/AbstractRTreeDeleteTest.java | 2 +- .../am/rtree/AbstractRTreeInsertTest.java | 2 +- .../support/TestStorageManagerInterface.java | 9 +- .../storage/am/btree/FieldPrefixNSMTest.java | 4 +- .../storage/am/btree/StorageManagerTest.java | 4 +- .../storage/am/rtree/RTreeDeleteTest.java | 8 +- .../storage/am/rtree/RTreeInsertTest.java | 8 +- .../common/BufferCacheRegressionTest.java | 16 +- hyracks-fullstack/hyracks/hyracks-util/pom.xml | 1 + .../org/apache/hyracks/util/IntSerDeUtils.java | 10 +- hyracks-fullstack/pom.xml | 70 +- pom.xml | 10 +- 1750 files changed, 96658 insertions(+), 69511 deletions(-) ----------------------------------------------------------------------
