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 1727c5648600aa15b5f461312eedab8006abdc74 Merge: 43da2c5 54bff81 Author: Apache AsterixDB Gerrit <[email protected]> AuthorDate: Wed May 13 23:41:51 2020 +0000 Merge "Merge commit 'f1cd417' from 'gerrit/mad-hatter'" asterixdb/asterix-app/data/csv/01.csv | 3 + asterixdb/asterix-app/data/csv/02.csv | 3 + asterixdb/asterix-app/data/csv/empty.csv | 5 + asterixdb/asterix-app/data/csv/sample_09.csv | 17 ++ asterixdb/asterix-app/data/csv/sample_10.csv | 39 ++++ asterixdb/asterix-app/data/csv/sample_11.csv | 4 + asterixdb/asterix-app/data/csv/sample_12.csv | 16 ++ asterixdb/asterix-app/data/csv/sample_13.csv | 11 ++ asterixdb/asterix-app/data/tsv/01.tsv | 3 + asterixdb/asterix-app/data/tsv/02.tsv | 3 + asterixdb/asterix-app/data/tsv/sample_01.tsv | 28 +++ .../asterix/app/translator/QueryTranslator.java | 54 +++-- .../aws/AwsS3ExternalDatasetTest.java | 27 +++ .../test/runtime/ResultStreamingFailureTest.java | 83 ++++++++ .../csv-parser-001/csv-parser-001.1.ddl.sqlpp | 35 ++++ .../csv-parser-001/csv-parser-001.2.query.sqlpp} | 8 +- .../csv-parser-001/csv-parser-001.3.query.sqlpp} | 8 +- .../csv-parser-001/csv-parser-001.4.query.sqlpp} | 8 +- .../csv-parser-001/csv-parser-001.5.query.sqlpp} | 8 +- .../csv-parser-001/csv-parser-001.6.query.sqlpp} | 8 +- .../csv-parser-001/csv-parser-001.7.query.sqlpp} | 8 +- .../csv-parser-001/csv-parser-001.8.ddl.sqlpp} | 8 +- .../tsv-parser-001/tsv-parser-002.1.ddl.sqlpp} | 14 +- .../tsv-parser-001/tsv-parser-002.2.query.sqlpp} | 8 +- .../tsv-parser-001/tsv-parser-002.3.ddl.sqlpp} | 8 +- .../aws/s3/001/query-dataset.000.ddl.sqlpp} | 24 ++- .../aws/s3/001/query-dataset.002.query.sqlpp} | 8 +- .../aws/s3/001/query-dataset.003.ddl.sqlpp} | 8 +- .../aws/s3/002/query-dataset.000.ddl.sqlpp} | 24 ++- .../aws/s3/002/query-dataset.002.query.sqlpp} | 8 +- .../aws/s3/002/query-dataset.003.ddl.sqlpp} | 8 +- .../aws/s3/negative/negative.000.ddl.sqlpp} | 23 ++- .../get-item_03/get-item_03.4.query.sqlpp} | 19 +- .../misc/case_01/case_01.1.query.sqlpp | 2 +- .../misc/case_02/case_02.1.query.sqlpp | 2 +- .../misc/case_03/case_03.1.query.sqlpp | 2 +- .../misc/case_04/case_04.1.query.sqlpp | 2 +- .../misc/case_05/case_05.1.query.sqlpp | 2 +- .../misc/case_06/case_06.1.query.sqlpp | 2 +- .../misc/case_07/case_07.1.query.sqlpp | 2 +- .../numeric/add_double/add_double.1.query.sqlpp | 2 +- .../union/union_nested/union_nested.1.ddl.sqlpp | 48 +++-- .../union_nested/union_nested.2.update.sqlpp} | 8 +- .../union/union_nested/union_nested.3.query.sqlpp | 93 +++++++++ .../csv-parser-001/csv-parser-001.2.adm | 15 ++ .../csv-parser-001/csv-parser-001.3.adm | 32 +++ .../csv-parser-001/csv-parser-001.4.adm | 4 + .../csv-parser-001/csv-parser-001.5.adm | 13 ++ .../csv-parser-001/csv-parser-001.6.adm | 3 + .../csv-parser-001/csv-parser-001.7.adm | 0 .../tsv-parser-001/tsv-parser-001.2.adm | 28 +++ .../aws/s3/001/external_dataset.001.adm | 6 + .../aws/s3/002/external_dataset.001.adm | 6 + .../{get-item_03.1.adm => get-item_03.3.adm} | 0 .../results/list/get-item_03/get-item_03.4.adm | 1 + .../results/union/union_nested/union_nested.3.adm | 138 +++++++++++++ .../numeric/add_double/add_double.1.ast | 7 +- .../runtimets/testsuite_external_dataset.xml | 18 +- .../test/resources/runtimets/testsuite_sqlpp.xml | 17 ++ .../asterix/common/exceptions/ErrorCode.java | 6 +- .../src/main/resources/asx_errormsg/en.properties | 6 +- .../asterix-doc/src/main/markdown/sqlpp/2_expr.md | 9 +- .../external/input/HDFSDataSourceFactory.java | 2 +- .../external/input/record/CharArrayRecord.java | 6 + .../CSVToRecordWithMetadataAndPKConverter.java | 13 +- .../record/reader/aws/AwsS3InputStreamFactory.java | 17 +- .../record/reader/aws/AwsS3ReaderFactory.java | 18 -- .../stream/EmptyLineSeparatedRecordReader.java | 3 +- .../record/reader/stream/LineRecordReader.java | 28 ++- .../reader/stream/QuotedLineRecordReader.java | 87 ++++---- .../reader/stream/SemiStructuredRecordReader.java | 4 +- .../record/reader/stream/StreamRecordReader.java | 3 +- .../reader/stream/StreamRecordReaderFactory.java | 2 +- .../input/stream/AsterixInputStreamReader.java | 4 +- .../input/stream/SocketServerInputStream.java | 5 + .../external/parser/DelimitedDataParser.java | 65 +++--- .../parser/factory/DelimitedDataParserFactory.java | 52 +---- .../factory/RecordWithMetadataParserFactory.java | 2 +- .../external/provider/AdapterFactoryProvider.java | 15 +- .../external/provider/ParserFactoryProvider.java | 7 +- .../util/ExternalDataCompatibilityUtils.java | 17 +- .../external/util/ExternalDataConstants.java | 35 +++- .../asterix/external/util/ExternalDataUtils.java | 220 +++++++++++++++------ .../parser/test/ByteBufUTF8DecodeTest.java | 5 +- .../external/parser/test/RecordWithMetaTest.java | 5 +- .../DatasetTupleTranslator.java | 103 ++++++---- .../asterix/metadata/feeds/FeedMetadataUtil.java | 10 +- .../evaluators/functions/GetItemDescriptor.java | 4 + asterixdb/asterix-server/pom.xml | 4 +- .../appended-resources/supplemental-models.xml | 6 +- ....com_netty_netty_netty-4.1.48.Final_NOTICE.txt} | 0 .../apache/hyracks/api/channels/IInputChannel.java | 5 + .../src/main/resources/errormsg/en.properties | 2 +- .../hyracks/client/result/ResultSetReader.java | 65 +++--- .../hyracks/comm/channels/NetworkInputChannel.java | 5 + .../comm/channels/ResultNetworkInputChannel.java | 6 + .../MaterializedPartitionInputChannel.java | 5 + .../common/data/parsers/BooleanParserFactory.java | 62 ++++++ .../std/file/DelimitedDataTupleParserFactory.java | 9 +- .../file/FieldCursorForDelimitedDataParser.java | 179 ++++++++++------- .../hyracks/dataflow/std/file/CursorTest.java | 5 +- .../muxdemux/AbstractChannelWriteInterface.java | 10 +- .../muxdemux/FullFrameChannelWriteInterface.java | 18 +- .../storage/am/common/impls/AbstractTreeIndex.java | 12 +- .../storage/common/compression/file/LAFWriter.java | 23 ++- .../org/apache/hyracks/test/support/TestUtils.java | 5 + .../java/org/apache/hyracks/util/NetworkUtil.java | 11 ++ .../org/apache/hyracks/util/NetworkUtilTest.java | 42 ++++ hyracks-fullstack/pom.xml | 27 ++- 109 files changed, 1611 insertions(+), 635 deletions(-)
