You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2022/04/14 01:47:21 UTC
[iotdb] branch master updated (f3dc12ff59 -> 7cc2a739b4)

This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


    from f3dc12ff59 [IOTDB-2896] Fix warning of illegal cross compaction strategy (#5503)
     add 7cc2a739b4 [IOTDB-2911][Part 1: Underlying Data Structures] TransformOperator: operator implementation for nested expression evaluation (#5513)

No new revisions were added by this update.

Summary of changes:
 .../db/mpp/operator/process/TransformOperator.java | 118 +++++++++++++++++++++
 .../db/mpp/operator/source/SeriesScanUtil.java     |  16 ++-
 .../apache/iotdb/db/qp/physical/crud/UDTFPlan.java |  37 ++-----
 .../apache/iotdb/db/query/dataset/UDTFDataSet.java |   3 +-
 .../iotdb/db/query/expression/Expression.java      |  12 ++-
 .../query/expression/binary/BinaryExpression.java  |  14 ++-
 .../db/query/expression/unary/ConstantOperand.java |   8 +-
 .../query/expression/unary/FunctionExpression.java |  26 +++--
 .../query/expression/unary/LogicNotExpression.java |  17 ++-
 .../query/expression/unary/NegationExpression.java |  11 +-
 .../query/expression/unary/TimeSeriesOperand.java  |  10 +-
 .../db/query/udf/core/executor/UDTFContext.java    |  60 +++++++++++
 .../iotdb/db/query/udf/core/layer/DAGBuilder.java  |   9 +-
 .../{DAGBuilder.java => EvaluationDAGBuilder.java} |  66 ++++++------
 .../query/udf/core/layer/RawQueryInputLayer.java   |   4 +
 .../query/udf/core/layer/TsBlockInputDataSet.java  |  64 +++++++++++
 .../iotdb/tsfile/read/common/block/TsBlock.java    |  80 +++++++++++---
 .../read/common/block/column/BinaryColumn.java     |   5 +
 .../read/common/block/column/BooleanColumn.java    |   5 +
 .../tsfile/read/common/block/column/Column.java    |   5 +
 .../read/common/block/column/DoubleColumn.java     |   5 +
 .../read/common/block/column/FloatColumn.java      |   5 +
 .../tsfile/read/common/block/column/IntColumn.java |   5 +
 .../read/common/block/column/LongColumn.java       |   5 +
 .../block/column/RunLengthEncodedColumn.java       |   6 ++
 .../read/common/block/column/TimeColumn.java       |   4 +
 26 files changed, 495 insertions(+), 105 deletions(-)
 create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/TransformOperator.java
 create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/executor/UDTFContext.java
 copy server/src/main/java/org/apache/iotdb/db/query/udf/core/layer/{DAGBuilder.java => EvaluationDAGBuilder.java} (59%)
 create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/layer/TsBlockInputDataSet.java