This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a change to branch fixCastTypeForDefaultValue
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 6a50a009825 Resolve type mismatch when WHEN result type differs from
ELSE (INT32 vs INT64)
add 7054c8ab8a2 Add result size limit and time slice control for
TransformOperator
add b49aaacc945 Fix C++ query dataset timeout propagation (#17399)
add 35326e84d82 Disabled some unstable function (#17373)
add 6b33deab459 Pipe: Fixed the bug that mod may not be released in
historical pipe (#17379)
add 9bfe0b0a78e Pipe: Made the historical pipe split auto dropped after
completion (#17295)
add 77fe3e72a78 Fix rest service port conflicts bug (#17401)
add 6ef35e4537e Cleaned multiple potential problems in pipe module (#17396)
add 67b017b3469 Support COPY TO TsFile for exporting query results in
table model (#17372)
add 7cde3c96f93 Pipe: Optimized the procedure waiting timeout for some
time-consuming procedure & Construct the historical pipe when realtime pipe
creation times out (#17404)
add b85ac145a4c Fix C++ client time column access causing UB for non-long
types (#17397) (#17400)
add 68fc992af53 Pipe: Fixed some potential OPC UA problems & Added IT for
`` in opc (#17393)
add 8a0228ee297 Merge branch 'iotdb_master' into fixCastTypeForDefaultValue
add 0eee24a09fb fix it
No new revisions were added by this update.
Summary of changes:
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 2 +-
.../iotdb/db/it/schema/IoTDBSchemaSyntaxIT.java | 154 +++++
.../manual/enhanced/IoTDBPipeAutoDropIT.java | 123 ++--
.../treemodel/auto/basic/IoTDBPipeDataSinkIT.java | 74 ++-
.../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 40 +-
.../it/db/it/IoTDBCaseWhenThenTableIT.java | 2 +-
.../query/recent/copyto/IoTDBCopyToTsFileIT.java | 668 +++++++++++++++++++++
.../IoTDBUncorrelatedInPredicateSubqueryIT.java | 32 +-
.../client-cpp/src/main/IoTDBRpcDataSet.cpp | 20 +
.../client-cpp/src/main/SessionConnection.cpp | 2 +-
iotdb-client/client-cpp/src/test/cpp/sessionIT.cpp | 35 ++
.../iotdb/confignode/manager/ProcedureManager.java | 25 +-
.../runtime/heartbeat/PipeHeartbeat.java | 2 +-
.../pipe/source/IoTDBConfigRegionSource.java | 6 +-
.../exception/DiskSpaceInsufficientException.java | 4 +
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 2 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 2 +-
.../agent/task/connection/PipeEventCollector.java | 2 +-
.../sink/PipeRealtimePriorityBlockingQueue.java | 11 +-
.../common/deletion/PipeDeleteDataNodeEvent.java | 3 +-
.../pipe/metric/overview/PipeResourceMetrics.java | 2 +-
.../receiver/PipeDataNodeReceiverMetrics.java | 4 +-
.../processor/aggregate/AggregateProcessor.java | 4 +-
.../iotconsensusv2/IoTConsensusV2Receiver.java | 25 +-
.../IoTConsensusV2ReceiverAgent.java | 2 +-
.../resource/memory/PipeDynamicMemoryBlock.java | 4 +-
.../pipe/resource/memory/PipeMemoryWeightUtil.java | 4 +-
.../resource/tsfile/PipeTsFileResourceManager.java | 15 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 4 +-
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 2 +-
.../protocol/opcua/server/OpcUaKeyStoreLoader.java | 14 +-
.../sink/protocol/opcua/server/OpcUaNameSpace.java | 7 +-
.../protocol/opcua/server/OpcUaServerBuilder.java | 1 +
.../websocket/WebSocketConnectorServer.java | 23 +-
.../util/builder/PipeTableModelTsFileBuilder.java | 9 +-
.../util/builder/PipeTreeModelTsFileBuilder.java | 9 +-
.../pipe/sink/util/builder/PipeTsFileBuilder.java | 4 +-
.../source/dataregion/IoTDBDataRegionSource.java | 2 +-
...istoricalDataRegionTsFileAndDeletionSource.java | 6 +-
.../PipeRealtimeDataRegionHybridSource.java | 34 +-
.../realtime/PipeRealtimeDataRegionLogSource.java | 42 +-
.../realtime/PipeRealtimeDataRegionSource.java | 35 +-
.../PipeRealtimeDataRegionTsFileSource.java | 18 +-
.../execution/executor/RegionWriteExecutor.java | 82 ++-
.../queryengine/execution/memory/MemoryPool.java | 3 +-
.../operator/process/TransformOperator.java | 18 +-
.../operator/process/copyto/CopyToOptions.java | 157 +++++
.../process/copyto/IFormatCopyToWriter.java | 72 +++
.../process/copyto/TableCopyToOperator.java | 187 ++++++
.../process/copyto/tsfile/CopyToTsFileOptions.java | 272 +++++++++
.../copyto/tsfile/TsFileFormatCopyToWriter.java | 186 ++++++
.../config/executor/ClusterConfigTaskExecutor.java | 9 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 4 +-
.../plan/planner/TableOperatorGenerator.java | 36 ++
.../plan/planner/plan/node/PlanVisitor.java | 5 +
.../relational/analyzer/StatementAnalyzer.java | 9 +
.../plan/relational/metadata/TableSchema.java | 9 +
.../plan/relational/planner/IrTypeAnalyzer.java | 1 +
.../relational/planner/TableLogicalPlanner.java | 68 ++-
.../planner/distribute/AddExchangeNodes.java | 23 +
.../distribute/TableDistributedPlanGenerator.java | 8 +
.../TableModelTypeProviderExtractor.java | 7 +
...tSourceColumns.java => PruneCopyToColumns.java} | 18 +-
.../{ExplainAnalyzeNode.java => CopyToNode.java} | 122 ++--
.../plan/relational/planner/node/Patterns.java | 4 +
.../optimizations/LogicalOptimizeFactory.java | 2 +
.../optimizations/UnaliasSymbolReferences.java | 20 +
.../plan/relational/sql/ast/AstVisitor.java | 4 +
.../sql/ast/{Prepare.java => CopyTo.java} | 81 +--
.../sql/ast/DefaultTraversalVisitor.java | 6 +
.../plan/relational/sql/parser/AstBuilder.java | 74 +++
.../plan/relational/sql/util/SqlFormatter.java | 16 +
.../db/storageengine/rescon/disk/TierManager.java | 32 +
.../TsFileDeduplicationBlockingPendingQueue.java | 2 +-
.../execution/operator/TransformOperatorTest.java | 136 +++++
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 +
.../task/connection/BlockingPendingQueue.java | 21 +-
.../pipe/datastructure/pattern/TreePattern.java | 11 +-
.../pipe/sink/client/IoTDBSyncClientManager.java | 2 +-
.../schema/column/ColumnHeaderConstant.java | 15 +
.../db/relational/grammar/sql/RelationalSql.g4 | 30 +-
pom.xml | 2 +-
82 files changed, 2752 insertions(+), 482 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBSchemaSyntaxIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/copyto/IoTDBCopyToTsFileIT.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/copyto/CopyToOptions.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/copyto/IFormatCopyToWriter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/copyto/TableCopyToOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/copyto/tsfile/CopyToTsFileOptions.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/copyto/tsfile/TsFileFormatCopyToWriter.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/{PruneOutputSourceColumns.java
=> PruneCopyToColumns.java} (76%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/{ExplainAnalyzeNode.java
=> CopyToNode.java} (51%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{Prepare.java
=> CopyTo.java} (50%)
