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 527cae49ac7 update
add b938c689937 Fix review
add 5d9367fff02 fix review
add ea195168a95 Feature/cppclient asan (#16293)
add 71bb8cc8ef9 only check magic string when encrypt function is open
(#16292)
add e09bdbe2c9c Modified db parameter in data import (#16294)
add 0a2166fab5b UDFT pattern_match: A similarity matching algorithm based
on sketch and example
add 8417f2b8ce7 Fix improper retries in dispatcher & measurements not set
to null when inserting row out-of-ttl (#16297)
add 1c539697c7e Pipe: Setup PipeLogger to reduce the selected pipe logs &
Switched some useless logger for pipe in configNode to debug level (#16296)
add 6a7665a0b2c Pipe: split full-sync pipe into history and realtime pipes
(#16250)
add 8e8c1a6ca52 Supports streaming load mem chunk & Push down filter,
limit and offset to MemPointIterator
add e1cbccf65bd [Bug Fix] Download config.json for Large TimeSeries Model
(#16295)
add dae4a2e8490 Pipe IT: enlarge timeout in
testLoadWhenIncomingIdColumnsArePrefixOfExisting (#16301)
add 9854f01be7a fix: MeasurementSchema not initialized after automatic
metadata creation failed (#16300)
add 4e4a215f57a Add sql to show configurations
add f8875c01213 Fix NodeSupplier connection leaky while encountering
exception
add aaf5139029e refine tsfileWriter reset logic (#16309)
add 5339c4a0990 fixup! Pipe: split full-sync pipe into history and
realtime pipes (#16250) (#16316)
add 64c69006964 reduce log (#16298)
add 182a78ae2df [AINode] Refactor thrift integration (#16323)
add 01d88b7d120 Fix some bugs in AlignedTVListIterator
add ded266441d8 Pipe: Further reduce the pipe logs & Added configurations
for tsFile segment lock (#16315)
add 48a512fd456 Merge branch 'master' of github.com:apache/iotdb into
ssl_between_nodes
add b19b93a0549 Fix review
No new revisions were added by this update.
Summary of changes:
.gitignore | 1 +
.../it/env/cluster/config/MppCommonConfig.java | 6 +
.../env/cluster/config/MppSharedCommonConfig.java | 7 +
.../it/env/remote/config/RemoteCommonConfig.java | 5 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 +
.../db/it/aligned/IoTDBAlignedMemQueryIT.java | 97 +++
.../org/apache/iotdb/db/it/utils/TestUtils.java | 65 ++
.../manual/AbstractPipeTableModelDualManualIT.java | 6 +-
.../manual/basic/IoTDBPipePermissionIT.java | 6 +-
.../tablemodel/manual/basic/IoTDBPipeSourceIT.java | 6 +-
.../manual/basic/IoTDBPipeWithLoadIT.java | 1 -
.../enhanced/IoTDBPipeSinkCompressionIT.java | 6 +-
.../auto/AbstractPipeDualTreeModelAutoIT.java | 6 +-
.../treemodel/auto/basic/IoTDBPipeAutoSplitIT.java | 106 +++
.../treemodel/auto/basic/IoTDBPipeSourceIT.java | 6 +-
.../auto/enhanced/IoTDBPipeSinkCompressionIT.java | 6 +-
.../manual/AbstractPipeDualTreeModelManualIT.java | 6 +-
.../treemodel/manual/IoTDBPipePermissionIT.java | 6 +-
.../iotdb/pipe/it/single/AbstractPipeSingleIT.java | 3 +-
.../relational/it/db/it/IoTDBInternalSSLIT.java | 643 ----------------
.../it/db/it/IoTDBSetConfigurationTableIT.java | 78 +-
.../relational/it/db/it/IoTDBWindowTVFIT.java | 283 ++++++-
.../it/insertquery/IoTDBInsertQueryIT.java | 4 +-
.../IoTDBInsertQueryWithInternalSSLIT.java | 90 +++
.../relational/it/schema/IoTDBDatabaseIT.java | 12 +-
.../it/session/IoTDBSessionRelationalIT.java | 38 +
.../iotdb/session/it/IoTDBSessionComplexIT.java | 49 ++
.../org/apache/iotdb/tool/common/Constants.java | 6 +-
.../org/apache/iotdb/tool/common/OptionsUtil.java | 8 +-
.../org/apache/iotdb/tool/data/ExportData.java | 4 +-
.../apache/iotdb/tool/data/ExportDataTable.java | 4 +-
.../org/apache/iotdb/tool/data/ExportDataTree.java | 9 +-
.../org/apache/iotdb/tool/data/ImportData.java | 20 +-
.../apache/iotdb/tool/data/ImportDataTable.java | 94 +--
iotdb-client/client-cpp/src/main/CMakeLists.txt | 5 +
iotdb-client/client-cpp/src/test/CMakeLists.txt | 5 +
iotdb-client/client-cpp/src/test/cpp/sessionIT.cpp | 16 +-
.../iotdb/rpc/NettyTNonblockingTransport.java | 61 +-
.../org/apache/iotdb/session/ThriftConnection.java | 1 +
iotdb-core/ainode/.gitignore | 2 +-
iotdb-core/ainode/{ainode => iotdb}/__init__.py | 0
.../{ainode/core => iotdb/ainode}/__init__.py | 0
.../inference => iotdb/ainode/core}/__init__.py | 0
.../ainode/{ => iotdb}/ainode/core/ai_node.py | 16 +-
.../ainode/{ => iotdb}/ainode/core/config.py | 10 +-
.../ainode/{ => iotdb}/ainode/core/constant.py | 4 +-
.../ainode/{ => iotdb}/ainode/core/exception.py | 5 +-
.../ainode/core/inference}/__init__.py | 0
.../ainode/core/inference/dispatcher}/__init__.py | 0
.../inference/dispatcher/abstract_dispatcher.py | 4 +-
.../core/inference/dispatcher/basic_dispatcher.py | 12 +-
.../ainode/core/inference/inference_request.py | 4 +-
.../core/inference/inference_request_pool.py | 10 +-
.../ainode/core/inference/pool_controller.py | 19 +-
.../ainode/core/inference/pool_group.py | 11 +-
.../core/inference/pool_scheduler}/__init__.py | 0
.../pool_scheduler/abstract_pool_scheduler.py | 2 +-
.../pool_scheduler/basic_pool_scheduler.py | 10 +-
.../core/inference/request_scheduler}/__init__.py | 0
.../abstract_request_scheduler.py | 0
.../request_scheduler/basic_request_scheduler.py | 4 +-
.../ainode/core/inference/strategy}/__init__.py | 0
.../strategy/abstract_inference_pipeline.py | 0
.../strategy/timer_sundial_inference_pipeline.py | 6 +-
.../strategy/timerxl_inference_pipeline.py | 6 +-
.../{ => iotdb}/ainode/core/inference/utils.py | 0
.../ainode/core/ingress}/__init__.py | 0
.../{ => iotdb}/ainode/core/ingress/dataset.py | 0
.../{ => iotdb}/ainode/core/ingress/iotdb.py | 14 +-
iotdb-core/ainode/{ => iotdb}/ainode/core/log.py | 4 +-
.../ainode/core/manager}/__init__.py | 0
.../ainode/core/manager/cluster_manager.py | 4 +-
.../ainode/core/manager/inference_manager.py | 38 +-
.../ainode/core/manager/model_manager.py | 20 +-
.../{ => iotdb}/ainode/core/manager/utils.py | 8 +-
.../ainode/core/model}/__init__.py | 0
.../ainode/core/model/built_in_model_factory.py | 54 +-
.../{ => iotdb}/ainode/core/model/model_enums.py | 0
.../{ => iotdb}/ainode/core/model/model_factory.py | 14 +-
.../{ => iotdb}/ainode/core/model/model_info.py | 4 +-
.../{ => iotdb}/ainode/core/model/model_storage.py | 24 +-
.../ainode/core/model/sundial}/__init__.py | 0
.../core/model/sundial/configuration_sundial.py | 0
.../ainode/core/model/sundial/flow_loss.py | 0
.../ainode/core/model/sundial/modeling_sundial.py | 8 +-
.../core/model/sundial/ts_generation_mixin.py | 0
.../ainode/core/model/timerxl}/__init__.py | 0
.../core/model/timerxl/configuration_timer.py | 0
.../ainode/core/model/timerxl/modeling_timer.py | 6 +-
.../core/model/timerxl/ts_generation_mixin.py | 0
.../{ => iotdb}/ainode/core/model/uri_utils.py | 10 +-
.../util => iotdb/ainode/core/rpc}/__init__.py | 0
.../ainode/{ => iotdb}/ainode/core/rpc/client.py | 16 +-
.../ainode/{ => iotdb}/ainode/core/rpc/handler.py | 18 +-
.../ainode/{ => iotdb}/ainode/core/rpc/service.py | 8 +-
.../ainode/{ => iotdb}/ainode/core/rpc/status.py | 6 +-
.../ainode/{ => iotdb}/ainode/core/script.py | 14 +-
.../ainode/iotdb/ainode/core/util}/__init__.py | 0
.../{ => iotdb}/ainode/core/util/activation.py | 0
.../ainode/{ => iotdb}/ainode/core/util/cache.py | 4 +-
.../{ => iotdb}/ainode/core/util/decorator.py | 0
.../ainode/core/util/huggingface_cache.py | 0
.../ainode/{ => iotdb}/ainode/core/util/lock.py | 0
.../ainode/{ => iotdb}/ainode/core/util/masking.py | 0
.../ainode/{ => iotdb}/ainode/core/util/serde.py | 2 +-
iotdb-core/ainode/pom.xml | 6 +-
iotdb-core/ainode/pyproject.toml | 16 +-
.../confignode/client/CnToCnNodeRequestType.java | 1 +
.../handlers/rpc/PipeHeartbeatRPCHandler.java | 2 +-
.../client/sync/CnToDnSyncRequestType.java | 1 +
.../client/sync/SyncConfigNodeClientPool.java | 2 +
.../client/sync/SyncDataNodeClientPool.java | 3 +
.../confignode/conf/ConfigNodeDescriptor.java | 2 +
.../iotdb/confignode/manager/ConfigManager.java | 25 +-
.../apache/iotdb/confignode/manager/IManager.java | 4 +
.../iotdb/confignode/manager/node/NodeManager.java | 32 +
.../runtime/heartbeat/PipeHeartbeatScheduler.java | 2 +-
.../coordinator/task/PipeTaskCoordinatorLock.java | 10 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 2 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 10 +-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 18 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 +
.../consensus/iot/client/DispatchLogHandler.java | 4 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 11 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 6 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 40 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 3 +
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 40 +-
.../pipeconsensus/PipeConsensusReceiver.java | 304 +++-----
.../protocol/thrift/IoTDBDataNodeReceiver.java | 29 +-
.../resource/log/PipePeriodicalLogReducer.java | 91 +++
.../db/pipe/resource/memory/PipeMemoryManager.java | 27 +-
.../tsfile/PipeTsFileResourceSegmentLock.java | 63 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 20 +-
.../PipeTransferTabletBatchEventHandler.java | 10 +-
.../PipeTransferTabletInsertionEventHandler.java | 10 +-
.../async/handler/PipeTransferTsFileHandler.java | 19 +-
...istoricalDataRegionTsFileAndDeletionSource.java | 2 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 2 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 8 +
.../impl/DataNodeInternalRPCServiceImpl.java | 13 +
.../execution/operator/source/FileLoaderUtils.java | 6 +-
.../execution/operator/source/SeriesScanUtil.java | 341 +++++++--
.../iotdb/db/queryengine/plan/Coordinator.java | 2 +
.../plan/analyze/schema/NormalSchemaFetcher.java | 10 +-
.../execution/config/TableConfigTaskVisitor.java | 10 +
.../execution/config/TreeConfigTaskVisitor.java | 8 +
.../config/executor/ClusterConfigTaskExecutor.java | 111 +++
.../config/executor/IConfigTaskExecutor.java | 4 +
.../config/sys/ShowConfigurationTask.java | 101 +++
.../function/TableBuiltinTableFunction.java | 6 +-
.../function/tvf/PatternMatchTableFunction.java | 266 +++++++
.../match/MatchConfig.java} | 31 +-
.../function/tvf/match/QetchAlgorithm.java | 683 +++++++++++++++++
.../function/tvf/match/model/MatchState.java | 233 ++++++
.../function/tvf/match/model/PatternSegment.java | 285 +++++++
.../function/tvf/match/model/Point.java} | 24 +-
.../function/tvf/match/model/RegexMatchState.java | 396 ++++++++++
.../function/tvf/match/model/Section.java | 238 ++++++
.../plan/relational/sql/ast/AstVisitor.java | 4 +
...adConfiguration.java => ShowConfiguration.java} | 7 +-
.../plan/relational/sql/parser/AstBuilder.java | 14 +
.../scheduler/FragmentInstanceDispatcherImpl.java | 12 +
.../plan/statement/StatementVisitor.java | 6 +
...tement.java => ShowConfigurationStatement.java} | 32 +-
.../schemaregion/utils/ResourceByPathUtils.java | 113 ++-
.../db/storageengine/dataregion/DataRegion.java | 1 +
.../memtable/AlignedReadOnlyMemChunk.java | 129 +++-
.../dataregion/memtable/ReadOnlyMemChunk.java | 76 +-
.../read/reader/chunk/MemAlignedChunkLoader.java | 27 +-
.../read/reader/chunk/MemChunkLoader.java | 21 +-
.../dataregion/tsfile/TsFileResource.java | 6 +-
.../apache/iotdb/db/utils/ModificationUtils.java | 32 +-
.../db/utils/datastructure/AlignedTVList.java | 262 +++++--
.../db/utils/datastructure/MemPointIterator.java | 73 +-
.../datastructure/MemPointIteratorFactory.java | 112 ++-
.../MergeSortMultiAlignedTVListIterator.java | 65 +-
.../MergeSortMultiTVListIterator.java | 36 +-
.../datastructure/MultiAlignedTVListIterator.java | 133 +++-
.../utils/datastructure/MultiTVListIterator.java | 196 +++--
.../OrderedMultiAlignedTVListIterator.java | 16 +-
.../datastructure/OrderedMultiTVListIterator.java | 15 +-
.../iotdb/db/utils/datastructure/TVList.java | 248 ++++--
.../memtable/AlignedTVListIteratorTest.java | 843 +++++++++++++++++++++
.../memtable/NonAlignedTVListIteratorTest.java | 630 +++++++++++++++
.../reader/chunk/MemAlignedChunkLoaderTest.java | 1 +
.../read/reader/chunk/MemChunkLoaderTest.java | 6 +
.../iotdb/db/utils/ConfigurationFileUtilsTest.java | 15 +
.../conf/iotdb-system.properties.template | 13 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 116 ++-
.../iotdb/commons/conf/ConfigurationFileUtils.java | 222 ++++--
.../commons/pipe/agent/task/PipeTaskAgent.java | 19 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 26 +
.../iotdb/commons/pipe/config/PipeDescriptor.java | 21 +
.../commons/pipe/receiver/IoTDBFileReceiver.java | 109 ++-
.../pipe/receiver/PipeReceiverStatusHandler.java | 2 +-
.../commons/pipe/resource/log/PipeLogger.java | 58 ++
.../pipe/sink/client/IoTDBSyncClientManager.java | 10 +-
.../schema/column/ColumnHeaderConstant.java | 18 +
.../org/apache/iotdb/commons/utils/RetryUtils.java | 2 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 5 +
.../thrift-commons/src/main/thrift/common.thrift | 5 +
.../src/main/thrift/confignode.thrift | 3 +
.../src/main/thrift/datanode.thrift | 2 +
.../iotdb/library/match/PatternExecutor.java | 9 +-
205 files changed, 7568 insertions(+), 1980 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedMemQueryIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeAutoSplitIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBInternalSSLIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/insertquery/IoTDBInsertQueryWithInternalSSLIT.java
rename iotdb-core/ainode/{ainode => iotdb}/__init__.py (100%)
rename iotdb-core/ainode/{ainode/core => iotdb/ainode}/__init__.py (100%)
rename iotdb-core/ainode/{ainode/core/inference =>
iotdb/ainode/core}/__init__.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/ai_node.py (93%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/config.py (98%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/constant.py (98%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/exception.py (97%)
rename iotdb-core/ainode/{ainode/core/inference/dispatcher =>
iotdb/ainode/core/inference}/__init__.py (100%)
rename iotdb-core/ainode/{ainode/core/inference/pool_scheduler =>
iotdb/ainode/core/inference/dispatcher}/__init__.py (100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/inference/dispatcher/abstract_dispatcher.py (90%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/inference/dispatcher/basic_dispatcher.py (85%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/inference/inference_request.py (96%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/inference/inference_request_pool.py (96%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/inference/pool_controller.py
(92%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/inference/pool_group.py (92%)
rename iotdb-core/ainode/{ainode/core/inference/request_scheduler =>
iotdb/ainode/core/inference/pool_scheduler}/__init__.py (100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/inference/pool_scheduler/abstract_pool_scheduler.py (96%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/inference/pool_scheduler/basic_pool_scheduler.py (86%)
rename iotdb-core/ainode/{ainode/core/inference/strategy =>
iotdb/ainode/core/inference/request_scheduler}/__init__.py (100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/inference/request_scheduler/abstract_request_scheduler.py
(100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/inference/request_scheduler/basic_request_scheduler.py (95%)
rename iotdb-core/ainode/{ainode/core/ingress =>
iotdb/ainode/core/inference/strategy}/__init__.py (100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/inference/strategy/abstract_inference_pipeline.py (100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/inference/strategy/timer_sundial_inference_pipeline.py (88%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/inference/strategy/timerxl_inference_pipeline.py (88%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/inference/utils.py (100%)
rename iotdb-core/ainode/{ainode/core/manager =>
iotdb/ainode/core/ingress}/__init__.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/ingress/dataset.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/ingress/iotdb.py (98%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/log.py (98%)
rename iotdb-core/ainode/{ainode/core/model =>
iotdb/ainode/core/manager}/__init__.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/manager/cluster_manager.py
(93%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/manager/inference_manager.py
(91%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/manager/model_manager.py (90%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/manager/utils.py (94%)
rename iotdb-core/ainode/{ainode/core/model/sundial =>
iotdb/ainode/core/model}/__init__.py (100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/model/built_in_model_factory.py (96%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/model/model_enums.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/model/model_factory.py (96%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/model/model_info.py (98%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/model/model_storage.py (96%)
rename iotdb-core/ainode/{ainode/core/model/timerxl =>
iotdb/ainode/core/model/sundial}/__init__.py (100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/model/sundial/configuration_sundial.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/model/sundial/flow_loss.py
(100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/model/sundial/modeling_sundial.py (98%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/model/sundial/ts_generation_mixin.py (100%)
rename iotdb-core/ainode/{ainode/core/rpc =>
iotdb/ainode/core/model/timerxl}/__init__.py (100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/model/timerxl/configuration_timer.py (100%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/model/timerxl/modeling_timer.py (99%)
rename iotdb-core/ainode/{ =>
iotdb}/ainode/core/model/timerxl/ts_generation_mixin.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/model/uri_utils.py (94%)
rename iotdb-core/ainode/{ainode/core/util =>
iotdb/ainode/core/rpc}/__init__.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/rpc/client.py (96%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/rpc/handler.py (82%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/rpc/service.py (95%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/rpc/status.py (89%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/script.py (91%)
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/core/util}/__init__.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/util/activation.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/util/cache.py (96%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/util/decorator.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/util/huggingface_cache.py
(100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/util/lock.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/util/masking.py (100%)
rename iotdb-core/ainode/{ => iotdb}/ainode/core/util/serde.py (98%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/log/PipePeriodicalLogReducer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/ShowConfigurationTask.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/PatternMatchTableFunction.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/{FunctionKind.java
=> tvf/match/MatchConfig.java} (60%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/match/QetchAlgorithm.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/match/model/MatchState.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/match/model/PatternSegment.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{pipe/event/common/watermark/PipeWatermarkEvent.java
=> queryengine/plan/relational/function/tvf/match/model/Point.java} (69%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/match/model/RegexMatchState.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/match/model/Section.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{LoadConfiguration.java
=> ShowConfiguration.java} (86%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/{SetConfigurationStatement.java
=> ShowConfigurationStatement.java} (68%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/AlignedTVListIteratorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/NonAlignedTVListIteratorTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/resource/log/PipeLogger.java
