This is an automated email from the ASF dual-hosted git repository.
spricoder pushed a change to branch feature/optimize_memory
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from e33d234b2fe fix template
add 6db2249c12c Load: Add LoadWithConvertOnTypeMismatchIT on Table Model
&& Fix TSInsertTabletReq.writeToTable is not set True in
PipeTransferTabletRawReq.toTPipeTransferRawReq when inserting a Tablet in Table
mode (#14611)
add 487a1a21ce9 Pipe & Load: Retry when a file operation causes an
exception (#14598)
add d60c3d52cb1 IoTConsensusV2: Fix adoption for table-deletion #14648
add 90cdf3bbc94 Load: Consider isGeneratedByPipe mark when executing
tsfile-tablet conversion in analysis stage (#14651)
add d9214b31465 Rename interface name of FunctionArguments
add 5f8b2c08ac9 Adjust default wal_throttle_threshold_in_byte and
region_migration_speed_limit_bytes_per_second (#14653)
add 815ea9c069d Implemented query for schema related Information schema &
Fixed the bug that the deviceEntry get from cache does not reserve query memory
add a4ce6f7a1a3 Modify the condition to skip compaction schdule after
insertion compaction task selection (#14644)
add bbd4383c613 Merge branch 'master' into feature/optimize_memory
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/udf/AggregateFunctionExample.java | 2 +-
.../apache/iotdb/udf/ScalarFunctionExample.java | 2 +-
.../db/query/udf/example/relational/AllSum.java | 6 +-
.../query/udf/example/relational/ContainNull.java | 2 +-
.../db/query/udf/example/relational/DatePlus.java | 2 +-
.../query/udf/example/relational/FirstTwoSum.java | 2 +-
.../db/query/udf/example/relational/MyAvg.java | 2 +-
.../db/query/udf/example/relational/MyCount.java | 2 +-
.../iotdb/it/utils/TsFileTableGenerator.java | 202 +++++++++++
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 80 ++++-
.../pipe/it/tablemodel/IoTDBPipeWithLoadIT.java | 8 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 41 +++
.../customizer/parameter/FunctionArguments.java | 22 +-
.../payload/SubscriptionFileHandler.java | 24 +-
.../org/apache/iotdb/session/util/RetryUtils.java | 37 +-
.../consensus/request/ConfigPhysicalPlanType.java | 2 +
.../DescTable4InformationSchemaPlan.java} | 9 +-
.../ShowTable4InformationSchemaPlan.java} | 8 +-
...p.java => DescTable4InformationSchemaResp.java} | 20 +-
...p.java => ShowTable4InformationSchemaResp.java} | 17 +-
.../iotdb/confignode/manager/ConfigManager.java | 18 +
.../apache/iotdb/confignode/manager/IManager.java | 6 +
.../manager/schema/ClusterSchemaManager.java | 32 ++
.../persistence/executor/ConfigPlanExecutor.java | 4 +
.../persistence/schema/ClusterSchemaInfo.java | 77 +++++
.../confignode/persistence/schema/ConfigMTree.java | 16 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 12 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 4 +-
.../batch/PipeTabletEventTsFileBatch.java | 1 +
.../request/PipeConsensusDeleteNodeReq.java | 4 +-
.../async/handler/PipeTransferTsFileHandler.java | 13 +-
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 15 +-
.../pipeconsensus/PipeConsensusReceiver.java | 31 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 7 +-
...leStatementDataTypeConvertExecutionVisitor.java | 7 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 14 +
.../InformationSchemaContentSupplierFactory.java | 372 ++++++++++++++++++---
.../iotdb/db/queryengine/plan/Coordinator.java | 4 +
.../queryengine/plan/analyze/AnalyzeVisitor.java | 14 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 12 +-
.../load/LoadTsFileToTableModelAnalyzer.java | 14 +-
.../load/LoadTsFileToTreeModelAnalyzer.java | 8 +-
.../config/metadata/relational/ShowDBTask.java | 4 +-
.../plan/planner/TableOperatorGenerator.java | 9 +-
.../relational/analyzer/StatementAnalyzer.java | 12 +-
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 10 +-
.../DataNodeLocationSupplierFactory.java | 11 +
.../sql/ast/AbstractQueryDeviceWithCache.java | 2 +
.../plan/relational/sql/ast/AstVisitor.java | 4 +
.../{DescribeTable.java => CountStatement.java} | 40 ++-
.../plan/relational/sql/ast/LoadTsFile.java | 9 +
.../plan/relational/sql/parser/AstBuilder.java | 36 +-
.../plan/relational/sql/rewrite/ShowRewrite.java | 51 ++-
.../plan/scheduler/load/LoadTsFileScheduler.java | 2 +-
.../plan/statement/crud/LoadTsFileStatement.java | 9 +
.../schemaengine/table/InformationSchemaUtils.java | 9 +-
.../db/storageengine/dataregion/DataRegion.java | 121 ++++---
.../schedule/CompactionScheduleContext.java | 21 ++
.../compaction/schedule/CompactionScheduler.java | 60 ++--
.../impl/RewriteCrossSpaceCompactionSelector.java | 11 +-
.../db/storageengine/load/LoadTsFileManager.java | 21 +-
.../load/active/ActiveLoadDirScanner.java | 27 +-
.../load/active/ActiveLoadTsFileLoader.java | 13 +-
...leStatementDataTypeConvertExecutionVisitor.java | 7 +-
.../converter/LoadTsFileDataTypeConverter.java | 78 +++--
.../InsertionCrossSpaceCompactionSelectorTest.java | 4 +-
.../cross/InsertionCrossSpaceCompactionTest.java | 64 +++-
.../conf/iotdb-system.properties.template | 6 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 17 +-
.../commons/pipe/receiver/IoTDBReceiverAgent.java | 7 +-
.../snapshot/PipeSnapshotResourceManager.java | 9 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 22 ++
.../utils/{TestOnly.java => RetryUtils.java} | 38 ++-
.../src/main/thrift/confignode.thrift | 19 ++
74 files changed, 1564 insertions(+), 364 deletions(-)
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/utils/TsFileTableGenerator.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/cluster/NodeType.java
=>
iotdb-client/session/src/main/java/org/apache/iotdb/session/util/RetryUtils.java
(59%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{subscription/ShowSubscriptionPlan.java
=> table/DescTable4InformationSchemaPlan.java} (79%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{subscription/ShowSubscriptionPlan.java
=> table/ShowTable4InformationSchemaPlan.java} (79%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/table/{FetchTableResp.java
=> DescTable4InformationSchemaResp.java} (61%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/table/{ShowTableResp.java
=> ShowTable4InformationSchemaResp.java} (64%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{DescribeTable.java
=> CountStatement.java} (65%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/{TestOnly.java
=> RetryUtils.java} (60%)
