This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch iotdb-1971
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 7a8d55b finish preprocess workflow
new 85d1a91 DataSetFragmentExecutionPoolManager
add c4f4eb9 [IOTDB-2068] GZIP compressor meets
ArrayIndexOutOfBoundsException (#4488)
add 38637f9 [IOTDB-2061] Read data in batches to limit max IO (#4490)
add 6a88895 [IOTDB-2061] Add max cached buffer size and max concurrent
sub query parameter (#4486)
add 521f562 [IOTDB-2070] fix CLI doesn't accept statements with unclosed
brackets (#4487)
new e2dc690 Merge branch 'master' of github.com:apache/iotdb into
iotdb-1971
new 1da1a6b fragment task dataset & join dataset
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/iotdb/cli/utils/JlineUtils.java | 14 +---
.../resources/conf/iotdb-engine.properties | 7 +-
server/src/assembly/resources/conf/iotdb-env.bat | 4 +
server/src/assembly/resources/conf/iotdb-env.sh | 7 +-
.../org/apache/iotdb/db/concurrent/ThreadName.java | 1 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 12 +--
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 9 +--
.../query/dataset/udf/UDTFAlignByTimeDataSet.java | 2 +
.../db/query/dataset/udf/UDTFFragmentDataSet.java | 86 ++++++++++++++++++++++
.../query/dataset/udf/UDTFFragmentDataSetTask.java | 85 +++++++++++++++++++++
.../db/query/dataset/udf/UDTFJoinDataSet.java | 12 +--
...va => DataSetFragmentExecutionPoolManager.java} | 29 +++++---
.../iotdb/db/query/pool/QueryTaskPoolManager.java | 10 ++-
.../db/query/udf/core/layer/LayerBuilder.java | 3 +-
.../apache/iotdb/tsfile/compress/ICompressor.java | 58 ++++++++++++++-
.../compress/GZIPCompressOverflowException.java | 10 +--
.../iotdb/tsfile/read/TsFileSequenceReader.java | 66 +++++++++++++----
.../apache/iotdb/tsfile/write/page/PageWriter.java | 4 +
.../iotdb/tsfile/write/page/TimePageWriter.java | 4 +
.../iotdb/tsfile/write/page/ValuePageWriter.java | 4 +
.../org/apache/iotdb/tsfile/compress/GZIPTest.java | 17 ++++-
.../org/apache/iotdb/tsfile/compress/LZ4Test.java | 17 ++++-
.../apache/iotdb/tsfile/compress/SnappyTest.java | 17 ++++-
23 files changed, 402 insertions(+), 76 deletions(-)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/dataset/udf/UDTFFragmentDataSetTask.java
copy
server/src/main/java/org/apache/iotdb/db/query/pool/{QueryTaskPoolManager.java
=> DataSetFragmentExecutionPoolManager.java} (61%)
copy cli/src/main/java/org/apache/iotdb/exception/ArgsErrorException.java =>
tsfile/src/main/java/org/apache/iotdb/tsfile/exception/compress/GZIPCompressOverflowException.java
(77%)