This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch nested-operations
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 1c36448 struct of DAGBuilder & TransformerBuilder
new 9731a89 IntermediateLayer
new 8a492c2 DAG builder
new de1c509 introduce MultiInputIntermediateLayer
new c8e960b SingleInputSingleOutputIntermediateLayer &
SingleInputMultiOutputIntermediateLayer
The 4 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:
.../db/query/dataset/UDTFAlignByTimeDataSet.java | 2 +
.../apache/iotdb/db/query/dataset/UDTFDataSet.java | 2 +-
.../db/query/dataset/UDTFNonAlignDataSet.java | 1 +
.../iotdb/db/query/expression/Expression.java | 12 +-
.../expression/binary/AdditionExpression.java | 10 ++
.../query/expression/binary/BinaryExpression.java | 44 ++++--
.../expression/binary/DivisionExpression.java | 10 ++
.../query/expression/binary/ModuloExpression.java | 9 ++
.../binary/MultiplicationExpression.java | 10 ++
.../expression/binary/SubtractionExpression.java | 10 ++
.../query/expression/unary/FunctionExpression.java | 35 +++--
.../query/expression/unary/NegationExpression.java | 33 +++--
.../query/expression/unary/TimeSeriesOperand.java | 24 ++-
.../query/udf/core/builder/TransformerBuilder.java | 41 -----
.../udf/core/{builder => layer}/DAGBuilder.java | 35 ++---
.../udf/core/{input => layer}/InputLayer.java | 4 +-
.../udf/core/layer/IntermediateLayer.java} | 9 +-
.../MultiInputIntermediateLayer.java} | 16 +-
.../udf/core/{input => layer}/SafetyLine.java | 2 +-
.../SingleInputMultiOutputIntermediateLayer.java | 165 +++++++++++++++++++++
.../SingleInputSingleOutputIntermediateLayer.java} | 15 +-
.../udf/core/transformer/UDFQueryTransformer.java | 2 +-
.../tv/ElasticSerializableTVList.java | 5 +-
.../ElasticSerializableTVListTest.java | 2 +-
24 files changed, 369 insertions(+), 129 deletions(-)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/builder/TransformerBuilder.java
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/{builder =>
layer}/DAGBuilder.java (72%)
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/{input =>
layer}/InputLayer.java (99%)
copy server/src/main/java/org/apache/iotdb/db/{metrics/sink/Sink.java =>
query/udf/core/layer/IntermediateLayer.java} (80%)
copy
server/src/main/java/org/apache/iotdb/db/query/udf/core/{transformer/ArithmeticModuloTransformer.java
=> layer/MultiInputIntermediateLayer.java} (68%)
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/{input =>
layer}/SafetyLine.java (97%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/layer/SingleInputMultiOutputIntermediateLayer.java
copy
server/src/main/java/org/apache/iotdb/db/query/udf/core/{transformer/ArithmeticAdditionTransformer.java
=> layer/SingleInputSingleOutputIntermediateLayer.java} (67%)