This is an automated email from the ASF dual-hosted git repository. mblow pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/asterixdb.git
commit aa2b6eac28d4b4917b7286ce828db364c4b07329 Merge: 1727c56 73d6780 Author: Apache AsterixDB Gerrit <[email protected]> AuthorDate: Thu May 14 20:14:51 2020 +0000 Merge "Merge commit 'aa7ff7b' from 'gerrit/mad-hatter'" asterixdb/asterix-app/data/csv/empty.csv | 5 - .../data/csv/{empty.csv => empty_lines.csv} | 0 asterixdb/asterix-app/data/csv/error1_line_num.csv | 3 + asterixdb/asterix-app/data/csv/error2_line_num.csv | 5 + .../data/csv/header/h_invalid_values.csv | 13 + .../asterix-app/data/csv/header/h_mul_rec.csv | 4 + .../data/csv/header/h_mul_rec_with_ln.csv | 4 + .../asterix-app/data/csv/header/h_one_rec.csv | 2 + .../data/csv/header/h_one_rec_with_ln.csv | 2 + asterixdb/asterix-app/data/csv/header/h_only.csv | 1 + .../asterix-app/data/csv/header/h_only_with_ln.csv | 1 + .../data/csv/no_header/no_h_missing_fields.csv | 3 + .../data/csv/no_header/no_h_mul_rec.csv | 3 + .../data/csv/no_header/no_h_mul_rec_with_ln.csv | 3 + .../data/csv/no_header/no_h_no_closing_q.csv | 1 + .../data/csv/no_header/no_h_one_rec.csv | 1 + .../data/csv/no_header/no_h_one_rec_with_ln.csv | 1 + .../data/json/malformed-json-no-closing.json | 2 + .../json/multi-lines-with-arrays/5-records.json | 19 + .../multi-lines-with-nested-objects/5-records.json | 32 ++ .../data/json/multi-lines/20-records.json | 34 ++ .../data/json/single-line/20-records.json | 20 + .../jsonl/multi-lines-with-arrays/5-records.json | 20 + .../multi-lines-with-nested-objects/5-records.json | 33 ++ .../data/jsonl/multi-lines/20-records.json | 33 ++ .../data/jsonl/single-line/20-records.json | 20 + .../csv_07/csv_07.1.adm => data/tsv/empty.tsv} | 0 .../data/{csv/empty.csv => tsv/empty_lines.tsv} | 0 .../asterix-app/data/tsv/header/h_mul_rec.tsv | 4 + .../data/tsv/header/h_mul_rec_with_ln.tsv | 4 + .../asterix-app/data/tsv/header/h_one_rec.tsv | 2 + .../data/tsv/header/h_one_rec_with_ln.tsv | 2 + asterixdb/asterix-app/data/tsv/header/h_only.tsv | 1 + .../asterix-app/data/tsv/header/h_only_with_ln.tsv | 1 + .../data/tsv/no_header/no_h_missing_fields.tsv | 3 + .../data/tsv/no_header/no_h_mul_rec.tsv | 3 + .../data/tsv/no_header/no_h_mul_rec_with_ln.tsv | 3 + .../data/tsv/no_header/no_h_one_rec.tsv | 1 + .../data/tsv/no_header/no_h_one_rec_with_ln.tsv | 1 + .../apache/asterix/api/http/server/ApiServlet.java | 3 +- .../api/http/server/QueryServiceServlet.java | 13 +- .../api/http/server/RebalanceApiServlet.java | 3 +- .../asterix/app/translator/QueryTranslator.java | 38 +- .../test/common/CancellationTestExecutor.java | 4 +- .../org/apache/asterix/test/common/IPollTask.java | 5 +- .../asterix/test/common/ResultExtractor.java | 4 + .../apache/asterix/test/common/TestExecutor.java | 84 +++-- .../aws/AwsS3ExternalDatasetOnePartitionTest.java | 56 +++ .../aws/AwsS3ExternalDatasetTest.java | 413 ++++++++++++++++----- .../queries/group-by/gby-case-01.3.sqlpp} | 12 +- .../queries/group-by/gby-case-01.4.sqlpp} | 17 +- .../results/group-by/gby-case-01.3.plan | 24 ++ .../results/group-by/gby-case-01.4.plan | 24 ++ .../src/test/resources/runtimets/metrics.xml | 5 + .../get-non-query/get-non-query.1.get.http} | 8 +- .../get-non-query/get-non-query.2.get.http} | 10 +- .../get-non-query/get-non-query.3.get.http} | 10 +- .../get-query/get-query.1.get.http} | 17 +- .../get-query/get-query.2.get.http} | 17 +- .../get-query/get-query.3.get.http} | 17 +- .../post-non-query/post-non-query.1.post.http} | 10 +- .../post-non-query/post-non-query.2.post.http} | 17 +- .../csv-parser-001/csv-parser-001.1.ddl.sqlpp | 4 +- .../query-dataset.000.s3bucket.sqlpp} | 4 +- .../query-dataset.001.ddl.sqlpp} | 18 +- .../query-dataset.002.query.sqlpp | 5 +- .../query-dataset.003.s3bucket.sqlpp} | 2 +- .../query-dataset.005.query.sqlpp} | 5 +- .../query-dataset.006.s3bucket.sqlpp} | 2 +- .../query-dataset.008.query.sqlpp} | 5 +- .../query-dataset.009.s3bucket.sqlpp} | 2 +- .../query-dataset.011.query.sqlpp} | 5 +- .../query-dataset.099.ddl.sqlpp} | 2 +- .../query-dataset.000.s3bucket.sqlpp} | 4 +- .../query-dataset.001.ddl.sqlpp} | 16 +- .../query-dataset.002.query.sqlpp | 5 +- .../query-dataset.003.s3bucket.sqlpp} | 2 +- .../query-dataset.005.query.sqlpp} | 5 +- .../query-dataset.006.s3bucket.sqlpp} | 2 +- .../query-dataset.008.query.sqlpp} | 5 +- .../query-dataset.009.s3bucket.sqlpp} | 2 +- .../query-dataset.011.query.sqlpp} | 5 +- .../query-dataset.099.ddl.sqlpp} | 2 +- .../query-dataset.001.s3bucket.sqlpp} | 2 +- .../query-dataset.002.ddl.sqlpp} | 20 +- .../query-dataset.003.query.sqlpp} | 5 +- .../query-dataset.004.s3bucket.sqlpp} | 2 +- .../query-dataset.006.query.sqlpp} | 5 +- .../query-dataset.007.ddl.sqlpp} | 25 +- .../query-dataset.008.query.sqlpp} | 5 +- .../query-dataset.009.s3bucket.sqlpp} | 2 +- .../query-dataset.010.ddl.sqlpp} | 26 +- .../query-dataset.011.query.sqlpp} | 5 +- .../query-dataset.012.ddl.sqlpp} | 25 +- .../query-dataset.013.query.sqlpp} | 5 +- .../query-dataset.014.s3bucket.sqlpp} | 2 +- .../query-dataset.015.ddl.sqlpp} | 24 +- .../query-dataset.016.query.sqlpp} | 5 +- .../query-dataset.017.s3bucket.sqlpp} | 2 +- .../query-dataset.018.query.sqlpp} | 5 +- .../query-dataset.099.ddl.sqlpp} | 2 +- .../{001 => csv/csv}/query-dataset.000.ddl.sqlpp | 9 +- .../{002 => csv/csv}/query-dataset.002.query.sqlpp | 0 .../{002 => csv/csv}/query-dataset.003.ddl.sqlpp | 0 .../s3/{001 => csv/gz}/query-dataset.000.ddl.sqlpp | 9 +- .../{001 => csv/gz}/query-dataset.002.query.sqlpp | 0 .../s3/{001 => csv/gz}/query-dataset.003.ddl.sqlpp | 0 .../{001 => csv/mixed}/query-dataset.000.ddl.sqlpp | 9 +- .../mixed}/query-dataset.002.query.sqlpp | 0 .../{002 => csv/mixed}/query-dataset.003.ddl.sqlpp | 0 .../external_dataset.000.ddl.sqlpp | 11 +- .../external_dataset.001.query.sqlpp | 4 +- .../external_dataset.099.ddl.sqlpp} | 0 .../json-warnings.001.s3bucket.sqlpp} | 2 +- .../json-warnings.002.ddl.sqlpp} | 17 +- .../json-warnings.003.query.sqlpp} | 5 +- .../json-warnings.099.ddl.sqlpp} | 2 +- .../aws/s3/json/gz/external_dataset.000.ddl.sqlpp | 70 ++++ .../gz}/external_dataset.001.query.sqlpp | 4 +- .../gz/external_dataset.002.query.sqlpp} | 4 +- .../gz/external_dataset.003.query.sqlpp} | 4 +- .../gz/external_dataset.004.query.sqlpp} | 4 +- .../gz/external_dataset.005.query.sqlpp} | 4 +- .../gz/external_dataset.006.query.sqlpp} | 4 +- .../gz/external_dataset.007.ddl.sqlpp} | 0 .../s3/json/json/external_dataset.000.ddl.sqlpp | 70 ++++ .../json}/external_dataset.001.query.sqlpp | 4 +- .../json/external_dataset.002.query.sqlpp} | 4 +- .../json/external_dataset.003.query.sqlpp} | 4 +- .../json/external_dataset.004.query.sqlpp} | 4 +- .../json/external_dataset.005.query.sqlpp} | 4 +- .../json/external_dataset.006.query.sqlpp} | 4 +- .../json/external_dataset.007.ddl.sqlpp} | 0 .../s3/json/mixed/external_dataset.000.ddl.sqlpp | 70 ++++ .../mixed}/external_dataset.001.query.sqlpp | 4 +- .../mixed/external_dataset.002.query.sqlpp} | 4 +- .../mixed/external_dataset.003.query.sqlpp} | 4 +- .../mixed/external_dataset.004.query.sqlpp} | 4 +- .../mixed/external_dataset.005.query.sqlpp} | 4 +- .../mixed/external_dataset.006.query.sqlpp} | 4 +- .../mixed/external_dataset.007.ddl.sqlpp} | 0 .../query-dataset.000.s3bucket.sqlpp} | 6 +- .../query-dataset.001.ddl.sqlpp} | 24 +- .../{002 => jsonl}/query-dataset.002.query.sqlpp | 5 +- .../query-dataset.099.ddl.sqlpp} | 2 +- .../aws/s3/negative/negative.000.ddl.sqlpp | 4 +- .../query-dataset.000.s3bucket.sqlpp} | 4 +- .../query-dataset.001.ddl.sqlpp} | 18 +- .../query-dataset.002.query.sqlpp | 5 +- .../query-dataset.003.s3bucket.sqlpp} | 2 +- .../query-dataset.005.query.sqlpp} | 5 +- .../query-dataset.006.s3bucket.sqlpp} | 2 +- .../query-dataset.008.query.sqlpp} | 5 +- .../query-dataset.009.s3bucket.sqlpp} | 2 +- .../query-dataset.011.query.sqlpp} | 5 +- .../query-dataset.099.ddl.sqlpp} | 0 .../query-dataset.000.s3bucket.sqlpp} | 4 +- .../query-dataset.001.ddl.sqlpp} | 16 +- .../query-dataset.002.query.sqlpp | 5 +- .../query-dataset.003.s3bucket.sqlpp} | 2 +- .../query-dataset.005.query.sqlpp} | 5 +- .../query-dataset.006.s3bucket.sqlpp} | 2 +- .../query-dataset.008.query.sqlpp} | 5 +- .../query-dataset.009.s3bucket.sqlpp} | 2 +- .../query-dataset.011.query.sqlpp} | 5 +- .../query-dataset.099.ddl.sqlpp} | 2 +- .../query-dataset.001.s3bucket.sqlpp} | 2 +- .../query-dataset.002.ddl.sqlpp} | 16 +- .../query-dataset.003.query.sqlpp} | 5 +- .../query-dataset.099.ddl.sqlpp} | 2 +- .../s3/{002 => tsv/gz}/query-dataset.000.ddl.sqlpp | 9 +- .../{002 => tsv/gz}/query-dataset.002.query.sqlpp | 0 .../s3/{002 => tsv/gz}/query-dataset.003.ddl.sqlpp | 0 .../{002 => tsv/mixed}/query-dataset.000.ddl.sqlpp | 9 +- .../mixed}/query-dataset.002.query.sqlpp | 0 .../{002 => tsv/mixed}/query-dataset.003.ddl.sqlpp | 0 .../{002 => tsv/tsv}/query-dataset.000.ddl.sqlpp | 9 +- .../{002 => tsv/tsv}/query-dataset.002.query.sqlpp | 0 .../{002 => tsv/tsv}/query-dataset.003.ddl.sqlpp | 0 .../gby-case-01/gby-case-01.1.ddl.sqlpp} | 13 +- .../gby-case-01/gby-case-01.2.update.sqlpp} | 43 ++- .../gby-case-01/gby-case-01.3.query.sqlpp} | 9 +- .../gby-case-01/gby-case-01.4.query.sqlpp} | 7 +- .../gby-nested-01/gby-nested-01.1.ddl.sqlpp} | 9 +- .../gby-nested-01/gby-nested-01.2.update.sqlpp | 66 ++++ .../gby-nested-01/gby-nested-01.3.query.sqlpp} | 25 +- .../loj-02-push-select.01.ddl.sqlpp} | 13 +- .../loj-02-push-select.02.update.sqlpp} | 15 +- .../loj-02-push-select.03.query.sqlpp} | 15 +- .../loj-02-push-select.04.query.sqlpp} | 16 +- .../loj-02-push-select.05.query.sqlpp} | 29 +- .../loj-02-push-select.06.query.sqlpp} | 29 +- .../load/csv_01/csv_01.2.update.sqlpp | 2 +- .../load/csv_02/csv_02.2.update.sqlpp | 2 +- .../load/csv_03/csv_03.2.update.sqlpp | 2 +- .../load/csv_08_header_cr/csv_08.2.update.sqlpp | 2 +- .../load/csv_08_header_crlf/csv_08.2.update.sqlpp | 2 +- .../load/csv_08_header_lf/csv_08.2.update.sqlpp | 2 +- .../external-dataset/external-dataset.1.ddl.sqlpp} | 11 +- .../external-dataset.2.metrics.sqlpp} | 6 +- .../external-datasett.3.ddl.sqlpp} | 6 +- .../queries_sqlpp/objects/ObjectsQueries.xml | 2 +- .../queries_sqlpp/tpcds/q19/q19.2.update.sqlpp | 12 +- .../queries_sqlpp/tpcds/q25/q25.2.update.sqlpp | 12 +- .../queries_sqlpp/tpcds/q29/q29.2.update.sqlpp | 12 +- .../queries_sqlpp/tpcds/q30/q30.2.update.sqlpp | 8 +- .../queries_sqlpp/tpcds/q34/q34.2.update.sqlpp | 10 +- .../queries_sqlpp/tpcds/q43/q43.2.update.sqlpp | 6 +- .../queries_sqlpp/tpcds/q46/q46.2.update.sqlpp | 12 +- .../queries_sqlpp/tpcds/q50/q50.2.update.sqlpp | 8 +- .../queries_sqlpp/tpcds/q57/q57.2.update.sqlpp | 8 +- .../queries_sqlpp/tpcds/q59/q59.2.update.sqlpp | 6 +- .../queries_sqlpp/tpcds/q62/q62.2.update.sqlpp | 10 +- .../queries_sqlpp/tpcds/q63/q63.2.update.sqlpp | 8 +- .../queries_sqlpp/tpcds/q73/q73.2.update.sqlpp | 10 +- .../queries_sqlpp/tpcds/q79/q79.2.update.sqlpp | 10 +- .../queries_sqlpp/tpcds/q81/q81.2.update.sqlpp | 8 +- .../queries_sqlpp/tpcds/q85/q85.2.update.sqlpp | 14 +- .../queries_sqlpp/tpcds/q88/q88.2.update.sqlpp | 8 +- .../queries_sqlpp/tpcds/q89/q89.2.update.sqlpp | 8 +- .../queries_sqlpp/tpcds/q90/q90.2.update.sqlpp | 8 +- .../queries_sqlpp/tpcds/q91/q91.2.update.sqlpp | 14 +- .../queries_sqlpp/tpcds/q96/q96.2.update.sqlpp | 8 +- .../query-ASTERIXDB-1591.2.update.sqlpp | 14 +- .../query-ASTERIXDB-1596.2.update.sqlpp | 6 +- .../results/api/get-query/get-query.1.adm | 1 + .../results/api/get-query/get-query.2.adm | 1 + .../results/api/get-query/get-query.3.adm | 1 + .../api/post-non-query/post-non-query.2.adm | 1 + .../aws/s3/000/external_dataset.001.adm | 14 - .../aws/s3/001/external_dataset.001.adm | 6 - .../aws/s3/002/external_dataset.001.adm | 6 - .../aws/s3/csv-header/external_dataset.001.adm} | 0 .../aws/s3/csv-header/external_dataset.002.adm} | 0 .../aws/s3/csv-header/external_dataset.003.adm | 2 + .../aws/s3/csv-header/external_dataset.004.adm | 6 + .../aws/s3/csv-no-header/external_dataset.001.adm} | 0 .../aws/s3/csv-no-header/external_dataset.002.adm} | 0 .../aws/s3/csv-no-header/external_dataset.003.adm | 2 + .../aws/s3/csv-no-header/external_dataset.004.adm | 6 + .../aws/s3/csv-warnings/external_dataset.001.adm | 2 + .../aws/s3/csv-warnings/external_dataset.002.adm | 1 + .../aws/s3/csv-warnings/external_dataset.003.adm | 1 + .../aws/s3/csv-warnings/external_dataset.004.adm | 3 + .../aws/s3/csv-warnings/external_dataset.005.adm | 3 + .../aws/s3/csv-warnings/external_dataset.006.adm | 1 + .../aws/s3/csv-warnings/external_dataset.007.adm | 2 + .../aws/s3/csv/csv/external_dataset.001.adm | 30 ++ .../aws/s3/csv/gz/external_dataset.001.adm | 30 ++ .../aws/s3/csv/mixed/external_dataset.001.adm | 60 +++ .../external_dataset.001.adm | 1 + .../aws/s3/json-warnings/json-warnings.003.adm | 1 + .../aws/s3/json/gz/external_dataset.001.adm | 1 + .../aws/s3/json/gz/external_dataset.002.adm | 1 + .../aws/s3/json/gz/external_dataset.003.adm | 1 + .../aws/s3/json/gz/external_dataset.004.adm | 25 ++ .../aws/s3/json/gz/external_dataset.005.adm | 1 + .../aws/s3/json/gz/external_dataset.006.adm | 25 ++ .../aws/s3/json/json/external_dataset.001.adm | 1 + .../aws/s3/json/json/external_dataset.002.adm | 1 + .../aws/s3/json/json/external_dataset.003.adm | 1 + .../aws/s3/json/json/external_dataset.004.adm | 25 ++ .../aws/s3/json/json/external_dataset.005.adm | 1 + .../aws/s3/json/json/external_dataset.006.adm | 25 ++ .../aws/s3/json/mixed/external_dataset.001.adm | 1 + .../aws/s3/json/mixed/external_dataset.002.adm | 1 + .../aws/s3/json/mixed/external_dataset.003.adm | 1 + .../aws/s3/json/mixed/external_dataset.004.adm | 50 +++ .../aws/s3/json/mixed/external_dataset.005.adm | 1 + .../aws/s3/json/mixed/external_dataset.006.adm | 50 +++ .../aws/s3/jsonl/external_dataset.002.adm | 50 +++ .../aws/s3/tsv-header/external_dataset.001.adm} | 0 .../aws/s3/tsv-header/external_dataset.002.adm} | 0 .../aws/s3/tsv-header/external_dataset.003.adm | 2 + .../aws/s3/tsv-header/external_dataset.004.adm | 6 + .../aws/s3/tsv-no-header/external_dataset.001.adm} | 0 .../aws/s3/tsv-no-header/external_dataset.002.adm} | 0 .../aws/s3/tsv-no-header/external_dataset.003.adm | 2 + .../aws/s3/tsv-no-header/external_dataset.004.adm | 6 + .../aws/s3/tsv-warnings/external_dataset.001.adm | 2 + .../aws/s3/tsv/gz/external_dataset.001.adm | 30 ++ .../aws/s3/tsv/mixed/external_dataset.001.adm | 60 +++ .../aws/s3/tsv/tsv/external_dataset.001.adm | 30 ++ .../results/group-by/gby-case-01/gby-case-01.3.adm | 2 + .../results/group-by/gby-case-01/gby-case-01.4.adm | 2 + .../group-by/gby-nested-01/gby-nested-01.3.adm | 2 + .../loj-02-push-select/loj-02-push-select.03.adm | 2 + .../loj-02-push-select/loj-02-push-select.04.adm | 2 + .../loj-02-push-select/loj-02-push-select.05.adm | 2 + .../loj-02-push-select/loj-02-push-select.06.adm | 2 + .../runtimets/results/load/csv_06/csv_06.1.adm | 3 + .../runtimets/results/load/csv_07/csv_07.1.adm | 3 + .../external-dataset/external-dataset.2.regexadm | 1 + .../src/test/resources/runtimets/testsuite.xml | 3 - .../runtimets/testsuite_external_dataset.xml | 45 ++- .../testsuite_external_dataset_one_partition.xml | 91 +++++ .../test/resources/runtimets/testsuite_sqlpp.xml | 73 ++-- .../asterix/common/exceptions/ErrorCode.java | 6 +- .../common/external/IDataSourceAdapter.java | 7 + .../src/main/resources/asx_errormsg/en.properties | 2 +- asterixdb/asterix-dashboard/pom.xml | 235 ++++++------ .../asterix/external/api/AsterixInputStream.java | 8 + .../asterix/external/api/IDataFlowController.java | 7 + .../asterix/external/api/IRecordConverter.java | 9 + .../asterix/external/api/IRecordDataParser.java | 26 +- .../apache/asterix/external/api/IRecordReader.java | 11 + .../dataflow/AbstractDataFlowController.java | 6 + .../dataflow/FeedRecordDataFlowController.java | 7 +- .../dataflow/RecordDataFlowController.java | 11 +- .../dataflow/StreamDataFlowController.java | 2 + .../external/dataset/adapter/FeedAdapter.java | 5 + .../external/dataset/adapter/GenericAdapter.java | 5 + .../external/dataset/adapter/LookupAdapter.java | 7 +- .../external/input/record/CharArrayRecord.java | 4 +- .../input/record/RecordWithMetadataAndPK.java | 4 +- .../CSVToRecordWithMetadataAndPKConverter.java | 24 +- .../converter/CSVWithRecordConverterFactory.java | 5 +- .../record/converter/DCPConverterFactory.java | 3 +- .../record/converter/IRecordConverterFactory.java | 3 +- .../input/record/reader/aws/AwsS3InputStream.java | 89 +++-- .../record/reader/aws/AwsS3InputStreamFactory.java | 26 +- .../stream/EmptyLineSeparatedRecordReader.java | 2 +- .../record/reader/stream/LineRecordReader.java | 57 +-- .../reader/stream/QuotedLineRecordReader.java | 92 +++-- .../reader/stream/SemiStructuredRecordReader.java | 164 +++++--- .../record/reader/stream/StreamRecordReader.java | 35 +- .../input/stream/AbstractMultipleInputStream.java | 78 ++++ .../input/stream/AsterixInputStreamReader.java | 8 + .../external/input/stream/LocalFSInputStream.java | 97 +++-- .../operators/ExternalScanOperatorDescriptor.java | 11 +- .../asterix/external/parser/ADMDataParser.java | 10 +- .../external/parser/DelimitedDataParser.java | 162 ++++++-- .../asterix/external/parser/HiveRecordParser.java | 3 +- .../asterix/external/parser/JSONDataParser.java | 3 +- .../apache/asterix/external/parser/RSSParser.java | 3 +- .../external/parser/RecordWithMetadataParser.java | 13 +- .../external/parser/RecordWithPKDataParser.java | 5 +- .../asterix/external/parser/TweetParser.java | 3 +- .../parser/factory/DelimitedDataParserFactory.java | 3 +- .../factory/RecordWithMetadataParserFactory.java | 2 +- .../provider/DataflowControllerProvider.java | 6 + .../external/util/ExternalDataConstants.java | 24 +- .../asterix/external/util/ExternalDataUtils.java | 99 +++-- .../apache/asterix/external/util/ParseUtil.java | 36 +- .../external/parser/TestRecordWithPKParser.java | 4 +- .../external/parser/test/RecordWithMetaTest.java | 21 +- .../external/parser/test/TweetParserTest.java | 9 +- .../sqlpp/rewrites/SqlppFunctionBodyRewriter.java | 3 + .../lang/sqlpp/rewrites/SqlppQueryRewriter.java | 11 +- .../AbstractSqlppExpressionExtractionVisitor.java | 91 ++++- .../rewrites/visitor/SqlppCaseRewriteVisitor.java | 104 ++++++ .../visitor/SqlppWindowRewriteVisitor.java | 18 +- .../om/base/temporal/ADateParserFactory.java | 9 +- .../om/base/temporal/ADateTimeParserFactory.java | 3 +- .../om/base/temporal/ADurationParserFactory.java | 3 +- .../om/base/temporal/ATimeParserFactory.java | 7 +- .../ABinaryHexStringConstructorDescriptor.java | 5 +- asterixdb/asterix-server/pom.xml | 24 ++ asterixdb/pom.xml | 54 ++- .../appended-resources/supplemental-models.xml | 227 +++++++++++ ...tent.com_aws_aws-sdk-java-v2_2.10.83_NOTICE.txt | 16 + ...dd80e12f8835674c8ffb0f4a2efb64c7b585_NOTICE.txt | 2 + .../AbstractIntroduceGroupByCombinerRule.java | 6 + .../rewriter/rules/PushSelectIntoJoinRule.java | 91 +++-- .../apache/hyracks/api/exceptions/ErrorCode.java | 1 + .../org/apache/hyracks/api/util/CleanupUtils.java | 4 +- .../hyracks/api/util/HyracksThrowingConsumer.java | 9 +- .../src/main/resources/errormsg/en.properties | 1 + .../common/data/parsers/BooleanParserFactory.java | 51 ++- .../data/parsers/ByteArrayBase64ParserFactory.java | 3 +- .../data/parsers/ByteArrayHexParserFactory.java | 3 +- .../common/data/parsers/DoubleParserFactory.java | 5 +- .../common/data/parsers/FloatParserFactory.java | 5 +- .../dataflow/common/data/parsers/IValueParser.java | 2 +- .../common/data/parsers/IntegerParserFactory.java | 122 +++--- .../common/data/parsers/LongParserFactory.java | 123 +++--- .../data/parsers/UTF8StringParserFactory.java | 3 +- .../parsers/ByteArrayBase64ParserFactoryTest.java | 3 +- .../parsers/ByteArrayHexParserFactoryTest.java | 3 +- .../common/data/parsers/ParserFactoryTest.java | 218 +++++++++++ .../std/file/DelimitedDataTupleParserFactory.java | 27 +- .../file/FieldCursorForDelimitedDataParser.java | 100 +++-- .../dataflow/std/join/OptimizedHybridHashJoin.java | 14 + .../OptimizedHybridHashJoinOperatorDescriptor.java | 21 +- .../hyracks/dataflow/std/file/CursorTest.java | 11 +- .../examples/text/WordTupleParserFactory.java | 4 +- .../hyracks/http/server/AbstractServlet.java | 3 +- .../apache/hyracks/http/server/utils/HttpUtil.java | 42 ++- .../apache/hyracks/maven/license/LicenseMojo.java | 42 ++- .../org/apache/hyracks/maven/license/Override.java | 10 + .../org/apache/hyracks/util/ThrowingConsumer.java | 6 +- hyracks-fullstack/pom.xml | 68 ++-- 392 files changed, 4666 insertions(+), 1643 deletions(-)
