You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by mb...@apache.org on 2020/05/14 20:26:19 UTC
[asterixdb] 26/26: Merge "Merge commit 'aa7ff7b' from
'gerrit/mad-hatter'"
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 <de...@asterixdb.apache.org>
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(-)