This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch pipe-report-realtime-filtered-evemts
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 94335b0a372 Merge branch 'master' of https://github.com/apache/iotdb
into pipe-report-realtime-filtered-evemts
add 67f63e09fa5 Implement Extract expression in TableModel
add 24345354e4c [AINode] Accelerate memory efficiency of the
multiprocessing architecture of inference_manager (#15956)
add 3021737d9b7 Avoid NPE in dealWithException of QueryExecution
add 9bb8e9b58d2 [AINode] Update AINode docker file and pytorch dependency
(#15979)
add a804650a7fe Bump version to 2.0.6-SNAPSHOT
add 5bb17061bb5 [AINode] Bump version to 2.0.6.dev (#15988)
add 2288d7af396 [AINode] AINode docker compose file (#15987)
add f076824eb05 Pipe: Fixed some errors in cherry-picking (#15984)
add d34054dec5e Pipe: Fix the problem that a cluster crash in the
multi-cluster receiving end causes all synchronization to be suspended (#15962)
add 75d7f27fbdf Pipe: Reduce IoTDBAirGapConnector Handshake times (#15990)
add b9e7bd3aece Load: Fixed the issue that the loading table model file
failed under Tree Dialect Cli (#15942)
add 0340423366a Pipe: Update the log of the heartbeat process reported by
DN to CN (#15983)
add fbc28c6e27a Fixed issues in the rest service module: BLOB, DATE, table
model parameters, and added statistical delay monitoring items to
FastLastQuery. (#15917)
add 1d2f36ec00c Fix that stopping ratis may get stuck due to closed
FlushManager (#15992)
add 550210ce9d3 Merge branches 'pipe-report-realtime-filtered-evemts' and
'master' of https://github.com/apache/iotdb into
pipe-report-realtime-filtered-evemts
No new revisions were added by this update.
Summary of changes:
code-coverage/pom.xml | 2 +-
distribution/pom.xml | 12 +-
.../main/DockerCompose/docker-compose-ainode.yml | 30 +-
.../docker-compose-cluster-1c1d1a.yml | 4 +-
docker/src/main/Dockerfile-1.0.0-ainode | 5 +-
example/client-cpp-example/pom.xml | 2 +-
example/jdbc/pom.xml | 2 +-
example/mqtt-customize/pom.xml | 2 +-
example/mqtt/pom.xml | 2 +-
example/pipe-count-point-processor/pom.xml | 2 +-
example/pipe-opc-ua-sink/pom.xml | 2 +-
example/pom.xml | 2 +-
example/rest-java-example/pom.xml | 2 +-
.../java/org/apache/iotdb/TableHttpExample.java | 2 +-
.../java/org/apache/iotdb/TableHttpsExample.java | 2 +-
example/schema/pom.xml | 2 +-
example/session/pom.xml | 2 +-
example/trigger/pom.xml | 2 +-
example/udf/pom.xml | 2 +-
integration-test/pom.xml | 32 +--
.../iotdb/it/env/cluster/node/AINodeWrapper.java | 2 +-
.../org/apache/iotdb/db/it/IoTDBRestServiceIT.java | 145 +++++++++-
...oTDBRestartIT.java => IoTDBRestartRatisIT.java} | 12 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 33 ++-
.../manual/basic/IoTDBPipeDataSinkIT.java | 14 +-
.../IoTDBExtractTable2IT.java} | 51 ++--
.../IoTDBExtractTable3IT.java} | 51 ++--
.../query/recent/extract/IoTDBExtractTableIT.java | 317 +++++++++++++++++++++
.../relational/it/rest/it/IoTDBRestServiceIT.java | 32 ++-
iotdb-api/external-api/pom.xml | 2 +-
iotdb-api/pipe-api/pom.xml | 2 +-
iotdb-api/pom.xml | 2 +-
iotdb-api/trigger-api/pom.xml | 2 +-
iotdb-api/udf-api/pom.xml | 2 +-
iotdb-client/cli/pom.xml | 22 +-
iotdb-client/client-cpp/pom.xml | 4 +-
iotdb-client/client-py/pom.xml | 8 +-
iotdb-client/isession/pom.xml | 8 +-
iotdb-client/jdbc/pom.xml | 8 +-
iotdb-client/pom.xml | 2 +-
iotdb-client/service-rpc/pom.xml | 6 +-
iotdb-client/session/pom.xml | 10 +-
iotdb-core/ainode/ainode/core/ainode.py | 10 +-
iotdb-core/ainode/ainode/core/config.py | 68 ++---
iotdb-core/ainode/ainode/core/constant.py | 52 ++--
.../ainode/core/inference/inference_request.py | 3 +-
.../core/inference/inference_request_pool.py | 20 +-
.../ainode/core/manager/inference_manager.py | 16 +-
.../ainode/ainode/core/manager/model_manager.py | 2 +
iotdb-core/ainode/ainode/core/rpc/handler.py | 2 +-
iotdb-core/ainode/ainode/core/rpc/service.py | 4 +-
iotdb-core/ainode/ainode/core/script.py | 10 +-
iotdb-core/ainode/poetry.lock | 259 ++++++++++-------
iotdb-core/ainode/pom.xml | 10 +-
iotdb-core/ainode/pyproject.toml | 5 +-
.../ainode/resources/conf/iotdb-ainode.properties | 20 +-
iotdb-core/antlr/pom.xml | 2 +-
iotdb-core/confignode/pom.xml | 26 +-
.../runtime/heartbeat/PipeHeartbeatParser.java | 5 +-
iotdb-core/consensus/pom.xml | 14 +-
iotdb-core/datanode/pom.xml | 40 +--
.../client/IoTDBDataNodeAsyncClientManager.java | 49 +++-
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 5 +
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 6 -
.../realtime/assigner/PipeDataRegionAssigner.java | 9 -
.../resource/tsfile/PipeTsFileResourceManager.java | 60 ++--
.../rest/table/v1/handler/QueryDataSetHandler.java | 36 ++-
.../table/v1/handler/RequestValidationHandler.java | 12 +-
.../v1/handler/StatementConstructionHandler.java | 4 +-
.../rest/v1/handler/QueryDataSetHandler.java | 54 +++-
.../rest/v2/handler/QueryDataSetHandler.java | 37 ++-
.../protocol/rest/v2/impl/RestApiServiceImpl.java | 13 +-
.../db/queryengine/common/MPPQueryContext.java | 4 +
.../fragment/FragmentInstanceContext.java | 6 +-
.../relational/ColumnTransformerBuilder.java | 23 ++
.../queryengine/plan/analyze/PredicateUtils.java | 13 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 22 ++
.../queryengine/plan/execution/QueryExecution.java | 32 ++-
.../plan/planner/TableOperatorGenerator.java | 24 +-
.../plan/planner/plan/TableModelTimePredicate.java | 6 +-
.../plan/planner/plan/TimePredicate.java | 4 +-
.../plan/planner/plan/TreeModelTimePredicate.java | 4 +-
.../relational/analyzer/AggregationAnalyzer.java | 6 +
.../relational/analyzer/ExpressionAnalyzer.java | 18 ++
.../relational/analyzer/StatementAnalyzer.java | 17 ++
.../predicate/ConvertPredicateToFilterVisitor.java | 7 +-
.../ConvertPredicateToTimeFilterVisitor.java | 80 +++++-
.../PredicateCombineIntoTableScanChecker.java | 23 +-
.../planner/IrExpressionInterpreter.java | 19 ++
.../plan/relational/planner/IrTypeAnalyzer.java | 7 +
.../relational/planner/ir/ExpressionRewriter.java | 6 +
.../planner/ir/ExpressionTreeRewriter.java | 20 ++
.../ir/GlobalTimePredicateExtractVisitor.java | 16 +-
.../optimizations/PushPredicateIntoTableScan.java | 13 +-
.../plan/relational/sql/ast/AstVisitor.java | 4 +
.../sql/ast/DefaultTraversalVisitor.java | 5 +
.../plan/relational/sql/ast/Expression.java | 3 +
.../sql/ast/{WhenClause.java => Extract.java} | 107 ++++---
.../relational/sql/ast/TableExpressionType.java | 3 +-
.../plan/relational/sql/parser/AstBuilder.java | 14 +
.../relational/sql/util/ExpressionFormatter.java | 6 +
.../queryengine/plan/statement/StatementType.java | 4 +-
.../column/unary/scalar/ExtractTransformer.java | 106 +++++++
.../iotdb/db/service/DataNodeShutdownHook.java | 2 +-
.../dataregion/memtable/TsFileProcessor.java | 7 -
.../rescon/memory/AbstractPoolManager.java | 16 +-
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 14 +-
...AnalyzeTest.java => ExtractExpressionTest.java} | 43 ++-
iotdb-core/metrics/core/pom.xml | 4 +-
iotdb-core/metrics/interface/pom.xml | 8 +-
iotdb-core/metrics/pom.xml | 2 +-
iotdb-core/node-commons/pom.xml | 24 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 16 ++
.../iotdb/commons/pipe/config/PipeConfig.java | 7 +
.../iotdb/commons/pipe/config/PipeDescriptor.java | 5 +
.../connector/client/IoTDBSyncClientManager.java | 14 +
.../connector/protocol/IoTDBAirGapConnector.java | 11 +
iotdb-core/pom.xml | 2 +-
iotdb-core/relational-grammar/pom.xml | 2 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 1 +
iotdb-protocol/openapi/pom.xml | 2 +-
.../src/main/openapi3/iotdb_rest_table_v1.yaml | 2 +-
iotdb-protocol/pom.xml | 2 +-
iotdb-protocol/thrift-ainode/pom.xml | 4 +-
iotdb-protocol/thrift-commons/pom.xml | 2 +-
iotdb-protocol/thrift-confignode/pom.xml | 4 +-
iotdb-protocol/thrift-consensus/pom.xml | 4 +-
iotdb-protocol/thrift-datanode/pom.xml | 4 +-
library-udf/pom.xml | 4 +-
pom.xml | 4 +-
scripts/sbin/stop-ainode.sh | 22 +-
scripts/sbin/windows/stop-ainode.bat | 18 +-
132 files changed, 1904 insertions(+), 669 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{IoTDBRestartIT.java =>
IoTDBRestartRatisIT.java} (98%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/{IoTDBQueryAttributeTableIT.java
=> extract/IoTDBExtractTable2IT.java} (57%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/{IoTDBQueryAttributeTableIT.java
=> extract/IoTDBExtractTable3IT.java} (57%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/extract/IoTDBExtractTableIT.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{WhenClause.java
=> Extract.java} (52%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ExtractTransformer.java
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/{ExplainAnalyzeTest.java
=> ExtractExpressionTest.java} (52%)
