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 1da1a6b fragment task dataset & join dataset
new 4f9d53a fix bug when spliting
new 9086826 init QueryDataSet and fix bug
new afb1d5f move packBuffer and putPBOSToBuffer into QueryDataSetUtils
new f678504 pass tests when canBeSplitIntoFragments := 2 <=
fragmentDataSetIndexToLayerPointReaders.size()
new 65e6715 udf_min_fragment_number_to_trigger_parallel_execution
new 834dd92 udf_min_fragment_number_to_trigger_parallel_execution docs
The 6 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:
.../Advanced-Features/UDF-User-Defined-Function.md | 3 +-
.../Advanced-Features/UDF-User-Defined-Function.md | 3 +-
.../resources/conf/iotdb-engine.properties | 5 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 17 ++
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 13 ++
.../query/dataset/udf/UDTFAlignByTimeDataSet.java | 48 +-----
.../iotdb/db/query/dataset/udf/UDTFDataSet.java | 6 +-
.../db/query/dataset/udf/UDTFFragmentDataSet.java | 11 +-
.../query/dataset/udf/UDTFFragmentDataSetTask.java | 17 +-
.../db/query/dataset/udf/UDTFJoinDataSet.java | 182 +++++++++++++++++++--
.../iotdb/db/query/expression/Expression.java | 3 +
.../query/expression/binary/BinaryExpression.java | 14 ++
.../db/query/expression/unary/ConstantOperand.java | 7 +
.../query/expression/unary/FunctionExpression.java | 18 ++
.../query/expression/unary/NegationExpression.java | 9 +
.../query/expression/unary/TimeSeriesOperand.java | 7 +
.../pool/DataSetFragmentExecutionPoolManager.java | 8 +-
.../db/query/udf/core/layer/LayerBuilder.java | 26 +--
.../query/udf/core/layer/RawQueryInputLayer.java | 36 ++--
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 33 ++++
.../tsfile/read/query/dataset/QueryDataSet.java | 18 ++
21 files changed, 384 insertions(+), 100 deletions(-)
