This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch ssl_between_nodes
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from e9a0d58348a add more client supports
new e99289941d0 seprate configs
new 1f3a9e860fc fix cluster bugs
add c17ca38218b Pipe: Banned conversion IT (#15973)
add 67f63e09fa5 Implement Extract expression in TableModel
add 24345354e4c [AINode] Accelerate memory efficiency of the
multiprocessing architecture of inference_manager (#15956)
new 9c90eede908 Merge branch 'master' of github.com:apache/iotdb into
ssl_between_nodes
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/db/it/utils/TestUtils.java | 33 ++-
.../manual/enhanced/IoTDBPipeTypeConversionIT.java | 3 +
.../manual/IoTDBPipeTypeConversionIT.java | 3 +
.../IoTDBExtractTable2IT.java} | 51 ++--
.../IoTDBExtractTable3IT.java} | 51 ++--
.../query/recent/extract/IoTDBExtractTableIT.java | 317 +++++++++++++++++++++
iotdb-core/ainode/ainode/core/config.py | 30 ++
.../ainode/core/inference/inference_request.py | 3 +-
.../core/inference/inference_request_pool.py | 20 +-
iotdb-core/ainode/ainode/core/ingress/iotdb.py | 1 +
.../ainode/core/manager/inference_manager.py | 16 +-
.../ainode/ainode/core/manager/model_manager.py | 2 +
iotdb-core/ainode/ainode/core/rpc/client.py | 20 +-
iotdb-core/ainode/ainode/core/rpc/handler.py | 2 +-
iotdb-core/ainode/ainode/core/script.py | 4 +
.../confignode/conf/ConfigNodeDescriptor.java | 1 +
.../manager/consensus/ConsensusManager.java | 2 +-
.../service/thrift/ConfigNodeRPCService.java | 2 +-
.../iot/client/AsyncIoTConsensusServiceClient.java | 2 +-
.../iot/client/SyncIoTConsensusServiceClient.java | 6 +-
.../db/consensus/DataRegionConsensusImpl.java | 6 +-
.../db/consensus/SchemaRegionConsensusImpl.java | 2 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 2 +-
.../execution/exchange/MPPDataExchangeService.java | 2 +-
.../fragment/FragmentInstanceContext.java | 6 +-
.../relational/ColumnTransformerBuilder.java | 23 ++
.../queryengine/plan/analyze/PredicateUtils.java | 13 +-
.../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 +
.../column/unary/scalar/ExtractTransformer.java | 106 +++++++
.../db/service/DataNodeInternalRPCService.java | 2 +-
.../iotdb/db/service/ExternalRPCService.java | 2 +-
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 14 +-
...AnalyzeTest.java => ExtractExpressionTest.java} | 43 ++-
.../conf/iotdb-system.properties.template | 22 +-
.../iotdb/commons/client/ainode/AINodeClient.java | 2 +-
.../client/ainode/AsyncAINodeServiceClient.java | 2 +-
.../AsyncConfigNodeInternalServiceClient.java | 2 +-
.../async/AsyncDataNodeExternalServiceClient.java | 2 +-
.../async/AsyncDataNodeInternalServiceClient.java | 2 +-
.../AsyncDataNodeMPPDataExchangeServiceClient.java | 2 +-
.../async/AsyncPipeConsensusServiceClient.java | 2 +-
.../client/sync/SyncConfigNodeIServiceClient.java | 6 +-
.../sync/SyncDataNodeInternalServiceClient.java | 2 +-
.../SyncDataNodeMPPDataExchangeServiceClient.java | 6 +-
.../sync/SyncPipeConsensusServiceClient.java | 6 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 23 +-
.../iotdb/commons/conf/CommonDescriptor.java | 14 +-
.../service/AbstractThriftServiceThread.java | 1 +
.../db/relational/grammar/sql/RelationalSql.g4 | 1 +
pom.xml | 2 +-
72 files changed, 1097 insertions(+), 202 deletions(-)
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%)
