This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch feat/show-receivers
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from ffb798e0e69 Merge remote-tracking branch 'origin/master' into
feat/show-receivers
add 5467513eaa2 Fix flaky multilevel priority queue test (#18013)
add 8ca049d8b8c Fix/unconsensus tsfile mods (#18008)
add 15dba18b1c7 Fix aggregation metric recording (#18018)
add 2fc89d07d08 C++ client: build with OpenSSL 3.x by default and bundle
the runtime … (#17987)
add 797dfa5d5cf Pipe: isolate async sink client resources by endpoint
(#18015)
add 4d05a851ef5 Limit concurrent load tsfile type conversions (#18014)
add 1d893f1d197 Support unified pipe pattern inclusion keys (#18016)
add c98bc5a0327 Use MinFolderOccupiedSpaceFirstStrategy for IoTConsensus
recv and all… (#18020)
add ced3908f07e Reduce IoTConsensus snapshot transmission memory and log
overhead (#18019)
add 1073715a081 Add RPC auto resizing buffer memory control (#17911)
add e948e49afbe Added show create pipe/database/topic (#17702)
add f1b45088029 Pipe: Fix tablet event alignment and row count handling
(#17999)
add e0e79aaaaaf Fix raw password user sync under strong policy (#18021)
add cd5c3a31195 Fix empty deleteTimeseries requests (#18012)
add 1811e13f640 Pipe: Retry history LoadTsFile while waiting for schema
(#18031)
add f96fc5824f6 Pipe: merge batched aligned chunks in scan parser (#18010)
add 580fd6afc86 Fix tag index memory accounting (#18029)
add 7f41f064858 Fix internal procedure deduplication (#18036)
add fcd52d7ff06 Support IoTDBLocal in UDF for table model (#18035)
add bb17653da71 Merge remote-tracking branch 'origin/master' into
tmp/resolve-pr-17869
No new revisions were added by this update.
Summary of changes:
.github/scripts/package-client-cpp-manylinux228.sh | 13 +
.github/workflows/client-cpp-package.yml | 18 +-
.github/workflows/multi-language-client.yml | 15 +-
.../iotdblocal/CreateTableProbeFunction.java | 12 +-
.../DeviceIdListInProcessTableFunction.java | 72 ++-
.../iotdblocal/DeviceIdListTableFunction.java | 95 ++--
.../DeviceNameEnrichBeforeStartTableFunction.java | 144 +++++
.../DeviceNameEnrichInProcessTableFunction.java | 120 ++--
.../relational/iotdblocal/DeviceNameFunction.java | 68 ++-
.../iotdblocal/DeviceSummaryFunction.java | 98 ++++
.../iotdblocal/DeviceSummaryNoCloseFunction.java | 93 +++
.../iotdblocal/DropTableProbeFunction.java | 11 +-
.../relational/iotdblocal/InsertProbeFunction.java | 15 +-
.../iotdblocal/IoTDBLocalLogAggregateFunction.java | 93 +--
.../IoTDBLocalLogFunction.java} | 49 +-
.../relational/iotdblocal/IoTDBLocalLogHelper.java | 93 +++
.../IoTDBLocalLogTableFunction.java} | 63 ++-
...QueryUdafAtBeforeDestroyAggregateFunction.java} | 37 +-
...alQueryUdafAtBeforeStartAggregateFunction.java} | 51 +-
.../LocalQueryUdafInAddInputAggregateFunction.java | 81 ++-
...alQueryUdafInCombineStateAggregateFunction.java | 81 ++-
...alQueryUdafInOutputFinalAggregateFunction.java} | 40 +-
.../MutatingQueryProbeFunction.java} | 29 +-
.../SecretTableQueryFunction.java} | 30 +-
.../it/env/cluster/config/MppDataNodeConfig.java | 37 ++
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 2 -
.../it/env/remote/config/RemoteDataNodeConfig.java | 27 +
.../apache/iotdb/itbase/env/DataNodeConfig.java | 12 +
...TDBRegionMigrateWithDeletionMultiDataDirIT.java | 182 ++++++
...gionMigrateWithDeletionMultiDataDirTableIT.java | 185 ++++++
.../db/it/IoTDBAutoResizingBufferMemoryIT.java | 274 +++++++++
.../iotdb/db/it/IoTDBLoadTsFileActiveRetryIT.java | 226 ++++++++
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 2 +-
.../manual/AbstractPipeTableModelDualManualIT.java | 2 +
.../manual/basic/IoTDBPipePermissionIT.java | 2 +
.../manual/basic/IoTDBPipeProtocolIT.java | 6 +
.../tablemodel/manual/basic/IoTDBPipeSourceIT.java | 2 +
.../manual/basic/IoTDBPipeWithLoadIT.java | 2 +
.../manual/enhanced/IoTDBPipeAutoConflictIT.java | 2 +
.../manual/enhanced/IoTDBPipeAutoDropIT.java | 2 +
.../manual/enhanced/IoTDBPipeClusterIT.java | 2 +
.../enhanced/IoTDBPipeSinkCompressionIT.java | 4 +-
.../auto/AbstractPipeDualTreeModelAutoIT.java | 6 +-
.../treemodel/auto/basic/IoTDBPipeAutoSplitIT.java | 2 +
.../treemodel/auto/basic/IoTDBPipeProcessorIT.java | 2 +
.../treemodel/auto/basic/IoTDBPipeProtocolIT.java | 6 +
.../IoTDBPipeReceiverAutoCreateDisabledIT.java | 65 ++-
.../treemodel/auto/basic/IoTDBPipeSourceIT.java | 65 ++-
.../auto/enhanced/IoTDBPipeAutoConflictIT.java | 2 +
.../auto/enhanced/IoTDBPipeClusterIT.java | 2 +
.../auto/enhanced/IoTDBPipeIdempotentIT.java | 2 +
.../auto/enhanced/IoTDBPipeSinkCompressionIT.java | 2 +
.../auto/enhanced/IoTDBPipeWithLoadIT.java | 2 +
.../manual/AbstractPipeDualTreeModelManualIT.java | 4 +-
.../manual/IoTDBPipeMetaHistoricalIT.java | 4 +-
.../manual/IoTDBPipeMetaLeaderChangeIT.java | 7 +-
.../treemodel/manual/IoTDBPipePermissionIT.java | 4 +-
.../iotdb/pipe/it/single/AbstractPipeSingleIT.java | 1 +
.../single/IoTDBLegacyPipeReceiverSecurityIT.java | 1 +
.../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 1 +
.../pipe/it/single/IoTDBPipePermissionIT.java | 1 +
.../pipe/it/triple/AbstractPipeTripleManualIT.java | 5 +-
.../relational/it/db/it/IoTDBLoadTsFileIT.java | 1 +
.../relational/it/db/it/udf/IoTDBLocalIT.java | 451 +++++++++++++++
.../relational/it/db/it/udf/IoTDBLocalLogIT.java | 159 ++++++
.../relational/it/db/it/udf/SQLFunctionUtils.java | 1 -
.../relational/it/schema/IoTDBDatabaseIT.java | 60 ++
.../dual/tablemodel/IoTDBSubscriptionTopicIT.java | 27 +
.../java/org/apache/iotdb/udf/api/IoTDBLocal.java | 70 +++
.../udf/api/{State.java => UDFResultSet.java} | 28 +-
.../udf/api/relational/AggregateFunction.java | 33 ++
.../iotdb/udf/api/relational/ScalarFunction.java | 19 +
.../processor/TableFunctionDataProcessor.java | 34 ++
.../processor/TableFunctionLeafProcessor.java | 17 +
iotdb-client/client-cpp/CMakeLists.txt | 27 +-
iotdb-client/client-cpp/README.md | 53 +-
iotdb-client/client-cpp/README_zh.md | 8 +-
.../client-cpp/cmake/FetchBuildTools.cmake | 17 +-
iotdb-client/client-cpp/cmake/FetchOpenSSL.cmake | 58 +-
iotdb-client/client-cpp/cmake/FetchThrift.cmake | 21 +-
.../client-cpp/cmake/InstallOpenSSLRuntime.cmake | 121 ++++
iotdb-client/client-cpp/examples/CMakeLists.txt | 35 ++
iotdb-client/client-cpp/examples/README.md | 2 +-
iotdb-client/client-cpp/examples/README_zh.md | 2 +-
iotdb-client/client-cpp/pom.xml | 4 +-
.../client-cpp/src/assembly/client-cpp.xml | 2 +
.../package-metadata/third_party/DEPENDENCIES.md | 25 +-
.../assembly/package-metadata/third_party/NOTICE | 34 ++
.../third_party/licenses/LICENSE-Boost-1.0 | 23 +
iotdb-client/client-cpp/third-party/README.md | 6 +-
iotdb-client/client-go | 2 +-
.../en/org/apache/iotdb/rpc/i18n/RpcMessages.java | 6 +
.../zh/org/apache/iotdb/rpc/i18n/RpcMessages.java | 6 +
.../org/apache/iotdb/rpc/AutoResizingBuffer.java | 53 +-
...t.java => AutoResizingBufferMemoryControl.java} | 8 +-
.../iotdb/rpc/AutoResizingBufferMemoryManager.java | 110 ++++
.../iotdb/rpc/AutoScalingBufferReadTransport.java | 18 +-
.../iotdb/rpc/AutoScalingBufferWriteTransport.java | 20 +-
.../rpc/TCompressedElasticFramedTransport.java | 29 +-
.../apache/iotdb/rpc/TElasticFramedTransport.java | 38 +-
.../iotdb/rpc/TSnappyElasticFramedTransport.java | 8 +-
.../rpc/TimeoutChangeableTFastFramedTransport.java | 6 +-
.../TimeoutChangeableTSnappyFramedTransport.java | 6 +-
.../apache/iotdb/rpc/AutoResizingBufferTest.java | 193 +++++++
.../apache/iotdb/session/SessionConnection.java | 3 +
.../org/apache/iotdb/session/pool/SessionPool.java | 3 +
.../iotdb/session/SessionConnectionTest.java | 8 +
.../apache/iotdb/session/pool/SessionPoolTest.java | 11 +
.../execution/operator/CommonOperatorContext.java | 15 +
.../function/TableFunctionLeafOperator.java | 16 +-
.../process/function/TableFunctionOperator.java | 28 +-
.../relational/aggregation/AccumulatorFactory.java | 81 ++-
.../aggregation/AggregationOperator.java | 15 +-
.../relational/aggregation/TableAggregator.java | 49 +-
.../UserDefinedAggregateFunctionAccumulator.java | 65 ++-
.../GroupedUserDefinedAggregateAccumulator.java | 44 +-
.../grouped/StreamingAggregationOperator.java | 9 +-
.../builder/InMemoryHashAggregationBuilder.java | 9 +-
.../relational/ColumnTransformerBuilder.java | 71 ++-
.../iotdb/calc/metric/QueryExecutionMetricSet.java | 15 +-
.../calc/plan/planner/TableOperatorGenerator.java | 111 +++-
.../udf/UserDefineScalarFunctionTransformer.java | 46 +-
.../confignode/procedure/ProcedureExecutor.java | 1 -
.../procedure/TimeoutExecutorThread.java | 19 +-
.../iotdb/confignode/service/ConfigNode.java | 2 +
.../confignode/persistence/AuthorInfoTest.java | 44 +-
.../procedure/TestProcedureExecutor.java | 10 +
.../iotdb/consensus/config/ConsensusConfig.java | 20 +-
.../iotdb/consensus/config/IoTConsensusConfig.java | 23 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 5 +
.../consensus/iot/IoTConsensusServerImpl.java | 143 +++--
.../iot/snapshot/SnapshotFragmentReader.java | 14 +-
.../apache/iotdb/consensus/ratis/utils/Utils.java | 23 +-
.../iot/snapshot/SnapshotFragmentReaderTest.java | 97 ++++
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 6 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 7 +
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 2 +
.../iotdb/db/i18n/StorageEngineMessages.java | 4 +
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 4 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 7 +
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 2 +
.../iotdb/db/i18n/StorageEngineMessages.java | 4 +
.../apache/iotdb/db/conf/DataNodeMemoryConfig.java | 9 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 17 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 9 +-
.../db/consensus/DataRegionConsensusImpl.java | 6 +
...java => LoadAnalyzeMissingSchemaException.java} | 5 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 4 +
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 8 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 5 +-
.../event/common/tablet/PipeTabletCollector.java | 6 +
.../tablet/parser/TabletInsertionEventParser.java | 12 +-
.../TabletInsertionEventTreePatternParser.java | 3 +-
.../parser/scan/SinglePageWholeChunkReader.java | 38 +-
.../scan/TsFileInsertionEventScanParser.java | 383 +++++++++----
.../visitor/PipeStatementTSStatusVisitor.java | 4 +-
.../pipe/resource/memory/PipeMemoryWeightUtil.java | 18 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 48 +-
.../source/dataregion/IoTDBDataRegionSource.java | 4 +
.../iotdb/db/protocol/session/SessionManager.java | 25 +
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 7 +-
.../common/header/DatasetHeaderFactory.java | 12 +
.../execution/aggregation/TreeAggregator.java | 92 ++-
.../fragment/FragmentInstanceContext.java | 63 +++
.../fragment/FragmentInstanceManager.java | 2 +
.../execution/operator/OperatorContext.java | 27 +
.../operator/process/AggregationOperator.java | 25 +-
.../process/RawDataAggregationOperator.java | 129 +++--
.../operator/process/TagAggregationOperator.java | 15 +-
.../AbstractSeriesAggregationScanOperator.java | 26 +-
.../relational/AbstractAggTableScanOperator.java | 85 +--
.../execution/schedule/task/DriverTask.java | 21 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 44 ++
.../plan/analyze/load/LoadTsFileAnalyzer.java | 57 ++
.../load/TreeSchemaAutoCreatorAndVerifier.java | 22 +-
.../execution/config/TableConfigTaskVisitor.java | 65 +++
.../execution/config/TreeConfigTaskVisitor.java | 6 +
.../config/executor/ClusterConfigTaskExecutor.java | 156 +++++-
.../config/executor/IConfigTaskExecutor.java | 6 +
...TablesTask.java => ShowCreateDatabaseTask.java} | 64 ++-
.../metadata/relational/ShowCreatePipeTask.java | 186 ++++++
.../sys/subscription/ShowCreateTopicTask.java | 116 ++++
.../planner/DataNodeTableOperatorGenerator.java | 25 +-
.../plan/planner/LocalExecutionPlanContext.java | 4 +
.../relational/analyzer/StatementAnalyzer.java | 18 +
.../plan/relational/sql/ast/AstVisitor.java | 12 +
.../ast/{ShowDB.java => ShowCreateDatabase.java} | 30 +-
.../ast/{StartPipe.java => ShowCreatePipe.java} | 20 +-
.../ast/{ShowTopics.java => ShowCreateTopic.java} | 20 +-
.../plan/relational/sql/parser/AstBuilder.java | 21 +
.../relational/sql/util/DataNodeSqlFormatter.java | 29 +
.../db/queryengine/udf/InternalQueryExecutor.java | 133 +++++
.../db/queryengine/udf/InternalQueryResult.java | 65 +++
.../iotdb/db/queryengine/udf/IoTDBLocalImpl.java | 147 +++++
.../iotdb/db/queryengine/udf/UDFResultSetImpl.java | 154 +++++
.../schemaengine/schemaregion/tag/TagManager.java | 125 +++--
.../dataregion/snapshot/SnapshotLoader.java | 31 +-
.../active/ActiveLoadFailedMessageHandler.java | 17 +
.../load/active/ActiveLoadTsFileLoader.java | 2 +-
...ertedInsertTabletStatementExceptionVisitor.java | 9 +-
...ertedInsertTabletStatementExceptionVisitor.java | 9 +-
.../converter/LoadTsFileDataTypeConverter.java | 112 ++++
.../db/storageengine/rescon/disk/TierManager.java | 18 +-
.../pipe/event/PipeTabletInsertionEventTest.java | 98 ++++
.../pipe/event/TsFileInsertionEventParserTest.java | 343 +++++++++++-
.../db/pipe/pattern/TreePatternPruningTest.java | 41 +-
.../receiver/PipeStatementTsStatusVisitorTest.java | 32 ++
.../sink/IoTDBDataNodeAsyncClientManagerTest.java | 57 ++
.../fragment/FragmentInstanceContextTest.java | 623 +++++++++++++++++++++
.../queue/MultilevelPriorityQueueTest.java | 13 +-
.../plan/analyze/load/LoadTsFileAnalyzerTest.java | 33 ++
.../metadata/relational/ShowCreateTaskTest.java | 234 ++++++++
...StatementTest.java => ShowCreateTopicTest.java} | 42 +-
.../schemaregion/tag/TagManagerTest.java | 216 +++++++
.../dataregion/snapshot/IoTDBSnapshotTest.java | 98 +++-
.../active/ActiveLoadFailedMessageHandlerTest.java | 51 ++
.../load/active/ActiveLoadTsFileLoaderTest.java | 152 +++++
...atementDataTypeConvertExecutionVisitorTest.java | 19 +
.../conf/iotdb-system.properties.template | 8 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 2 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 2 +
.../iotdb/commons/auth/user/BasicUserManager.java | 6 +-
.../iotdb/commons/conf/CommonDescriptor.java | 1 -
.../disk/strategy/DirectoryStrategyType.java | 32 +-
.../MinFolderOccupiedSpaceFirstStrategy.java | 3 +-
.../memory/AutoResizingBufferMemoryMetrics.java | 112 ++++
.../apache/iotdb/commons/memory/MemoryConfig.java | 87 ++-
.../pipe/config/constant/PipeSourceConstant.java | 2 +
.../pipe/config/constant/SystemConstant.java | 6 +
.../pipe/datastructure/pattern/TreePattern.java | 179 +++---
.../schema/column/ColumnHeaderConstant.java | 19 +
.../apache/iotdb/commons/utils/JVMCommonUtils.java | 11 +-
.../disk/strategy/DirectoryStrategyTypeTest.java | 63 +++
.../pattern/TreePatternParseTest.java | 83 +++
.../iotdb/commons/utils/JVMCommonUtilsTest.java | 27 +
.../db/relational/grammar/sql/RelationalSql.g4 | 15 +
pom.xml | 4 +
237 files changed, 9667 insertions(+), 1331 deletions(-)
mode change 100755 => 100644 .github/scripts/package-client-cpp-manylinux228.sh
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/exchange/TsBlockSerdeFactory.java
=>
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/CreateTableProbeFunction.java
(72%)
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/function/Split.java
=>
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/DeviceIdListInProcessTableFunction.java
(63%)
copy example/udf/src/main/java/org/apache/iotdb/udf/table/SplitExample.java =>
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/DeviceIdListTableFunction.java
(60%)
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/DeviceNameEnrichBeforeStartTableFunction.java
copy
example/udf/src/main/java/org/apache/iotdb/udf/table/ExcludeColumnExample.java
=>
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/DeviceNameEnrichInProcessTableFunction.java
(50%)
copy example/udf/src/main/java/org/apache/iotdb/udf/ScalarFunctionExample.java
=>
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/DeviceNameFunction.java
(51%)
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/DeviceSummaryFunction.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/DeviceSummaryNoCloseFunction.java
copy
iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/NodeType.java
=>
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/DropTableProbeFunction.java
(74%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/consensus/ConfigRegionId.java
=>
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/InsertProbeFunction.java
(71%)
copy
example/udf/src/main/java/org/apache/iotdb/udf/AggregateFunctionExample.java =>
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/IoTDBLocalLogAggregateFunction.java
(52%)
copy
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/{DatePlus.java
=> iotdblocal/IoTDBLocalLogFunction.java} (56%)
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/IoTDBLocalLogHelper.java
copy
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/{MySplit.java
=> iotdblocal/IoTDBLocalLogTableFunction.java} (69%)
copy
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/{MyCount.java
=> iotdblocal/LocalQueryUdafAtBeforeDestroyAggregateFunction.java} (70%)
copy
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/{MyCount.java
=> iotdblocal/LocalQueryUdafAtBeforeStartAggregateFunction.java} (61%)
copy
example/udf/src/main/java/org/apache/iotdb/udf/AggregateFunctionExample.java =>
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/LocalQueryUdafInAddInputAggregateFunction.java
(57%)
copy
example/udf/src/main/java/org/apache/iotdb/udf/AggregateFunctionExample.java =>
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/iotdblocal/LocalQueryUdafInCombineStateAggregateFunction.java
(55%)
copy
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/{MyCount.java
=> iotdblocal/LocalQueryUdafInOutputFinalAggregateFunction.java} (68%)
copy
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/{ContainNull.java
=> iotdblocal/MutatingQueryProbeFunction.java} (67%)
copy
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/{ContainNull.java
=> iotdblocal/SecretTableQueryFunction.java} (64%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv1/IoTDBRegionMigrateWithDeletionMultiDataDirIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv1/IoTDBRegionMigrateWithDeletionMultiDataDirTableIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBAutoResizingBufferMemoryIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBLoadTsFileActiveRetryIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/udf/IoTDBLocalIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/udf/IoTDBLocalLogIT.java
create mode 100644
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/IoTDBLocal.java
copy iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/{State.java =>
UDFResultSet.java} (54%)
create mode 100644 iotdb-client/client-cpp/cmake/InstallOpenSSLRuntime.cmake
create mode 100644
iotdb-client/client-cpp/src/assembly/package-metadata/third_party/NOTICE
create mode 100644
iotdb-client/client-cpp/src/assembly/package-metadata/third_party/licenses/LICENSE-Boost-1.0
copy
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/{TimeoutChangeableTransport.java
=> AutoResizingBufferMemoryControl.java} (82%)
create mode 100644
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/AutoResizingBufferMemoryManager.java
create mode 100644
iotdb-client/service-rpc/src/test/java/org/apache/iotdb/rpc/AutoResizingBufferTest.java
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/snapshot/SnapshotFragmentReaderTest.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/load/{LoadRuntimeOutOfMemoryException.java
=> LoadAnalyzeMissingSchemaException.java} (85%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/{ShowTablesTask.java
=> ShowCreateDatabaseTask.java} (60%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/ShowCreatePipeTask.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/subscription/ShowCreateTopicTask.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{ShowDB.java
=> ShowCreateDatabase.java} (70%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{StartPipe.java
=> ShowCreatePipe.java} (78%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{ShowTopics.java
=> ShowCreateTopic.java} (76%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/udf/InternalQueryExecutor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/udf/InternalQueryResult.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/udf/IoTDBLocalImpl.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/udf/UDFResultSetImpl.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceContextTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/ShowCreateTaskTest.java
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{parser/CountDBStatementTest.java
=> ShowCreateTopicTest.java} (52%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/schemaregion/tag/TagManagerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadFailedMessageHandlerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadTsFileLoaderTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/memory/AutoResizingBufferMemoryMetrics.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/disk/strategy/DirectoryStrategyTypeTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/datastructure/pattern/TreePatternParseTest.java
