You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ju...@apache.org on 2026/10/19 09:16:16 UTC
(iotdb) branch feat/pipe-logical-backup-sink updated (6355496a6f8 -> 7772f632331)
This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch feat/pipe-logical-backup-sink
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 6355496a6f8 feat: add logical backup dump and restore workflow
add 94329e01692 [Pipe] Move OPC UA sink to pipe library (#18464)
add 5aae6697fba [Pipe] Avoid no-op consensus writes for covered progress (#18574)
add 76005c94103 Avoid holding ProcedureManager lock while waiting for table tasks (#18673)
add 9be80ead1dc Fix PathPatternNode wildcard cache lifecycle (#18672)
add 3b47945b3ce Show pre-deleted table schemas and improve write errors (#18626)
add 34349e3ad8b Fix snapshot omission of closing TsFiles (#18682)
add 142d3b14fce Pipe: Cache table-model pattern matches by table (#18648)
add 8d94de90db3 Fix stale OPC UA builtin plugin references (#18687)
add a670bce7ec6 Refactor TSDataType switches to use TypeService (#18606)
add 4405647b0f2 Fix schema partition lookup during ConfigNode removal (#18686)
add 02b8c6c0437 Bump ratis to 3.3.1 (#18605)
add f00b24c66eb Fix table-model pipe batch leader redirects (#18690)
add be8606615e5 Fix SinkChannel failure propagation test race (#18675)
add 56b09f28dec Fix schema cache pollution from LAST queries on virtual regions (#18694)
add 6377522ce2c Fix pipe leader cache updates for multi-device redirects (#18689)
add af6f8f52e5a [Test] Avoid metadata lease fencing in DataNode unit tests (#18284)
add a3330994747 Fix scan termination for finished fragment instances (#18701)
add e7ec99f5d17 Datanode: validate that a query id belongs to the calling session (#18643)
add c2ea4a40704 Add ImportWAL tool with WAL replay controls (#18516)
add 02ae00db9bc Wait for region leader election before region migration (#18699)
add fbd5fd22a6c Fix flaky SHOW RECEIVERS lifecycle test (#18700)
add c32431faa5d Use TypeService for ImportWAL snapshot replay (#18711)
add 0594afc33a8 fix the table function that has scalar argument of null value (#18714)
add ee17d1a8d25 [Subscription] Recover realtime admission after queue backpressure (#18715)
add ab15c0a19b0 Recover WAL metadata from readable entries and quarantine unrecoverable files (#18693)
add 6fa33f21ba0 Fix duplicate subscription auto commits (#18710)
add c8bf0bcfbf3 Validate region operation requests before submitting procedures (#18696)
add 473672dfc32 Fix fenced owner heartbeat lease refresh (#18717)
add a22746a57af Fix thread pool lifecycle leaks (#18703)
add 5750e9d4014 [Subscription] Fix consumer close deadlock (#18704)
add d6b602e4463 [Subscription] Bound heartbeat provider failures (#18712)
add 7984abcabb6 [Pipe] Fix AirGap receiver retry request body reuse (#18721)
add 90959ab504c Fix UPDATE attribute column validation (#18705)
add 81caad0395f [Query] Allow concurrent local fragment execution for last-query collection (#18727)
add 881ed81484b Fix deletion matching during compaction (#18732)
add a51258bbb97 [Performance] Reduce aligned flush duplicate timestamp overhead
add f24b24dcf7c Add proactive RegionGroup allocation and policy hot reload (#18692)
add d587d8d295c Remove JDBC OSGi support (#18719)
add 79631e3ec62 Register IoTDBDriver as a JDBC 4 service provider (#18744)
add ba287a9cb41 Fix SHOW DEVICES limit offset test ordering (#18745)
add a6cfe257b1d Avoid size estimation for fixed-length compaction points (#18707)
add dacf7c681f8 Expand some codes for use in the future (#18752)
add f58a52fe90c Fix WAL replay stalls on oversized entries (#18728)
add ce6c1f5f477 Fix pipe sink metrics lifecycle race (#18722)
add b2cc8b52126 Fix metrics lost after metric service restart and conflicting metric series (#18748)
add 9e40726175d Reuse tablet device ranges during writes (#18734)
add d74b2744ed1 Fix schema region snapshot memory accounting (#18750)
add bd3109ef1ba Fix tag index query for pre-deleted timeseries (#18751)
add afb90593d1c Fix subscription TsFile deduplication and poll concurrency (#18758)
add 864321f86a7 Fix async subscription commits after close (#18757)
add 3227bc1a219 [Subscription] Increase consensus catch-up batch size (#18739)
add 3154bffd068 [Subscription] Prevent unsubscribe from blocking on prefetch cleanup (#18742)
add 4092a780097 Fix pipe TsFile transfer when mod file is missing (#18756)
add 61e405bbfdb Revert "Show pre-deleted table schemas and improve write errors (#18626)" (#18762)
add f510a924968 Fix ordering propagation around table and window functions (#18749)
add 50d86cf4161 Fix flaky heartbeat executor bound test (#18773)
add 825bf9e6b8b Stop data region write retry promptly (#18730)
add 94694d92f25 Avoid redundant TsFile table schema registration (#18731)
add daf9dd8d771 Reject duplicate schema region IDs during recovery (#18754)
add 166883a1b2e Fix semantic error for unsupported table INSERT time expressions (#18759)
add f8bfcffc9ba Fix subscription stalls after consumer disconnect (#18760)
add ef9bb521ccf Fix subscription cache memory configuration (#18761)
add abd499334f0 [Subscription] Bound pending WAL gap replay per round (#18766)
add 8f1bed8246c [Subscription] Consolidate poll queue fixes (#18771)
add 5d389dd6e86 Fix subscription WAL retention at replay cursor (#18769)
add 5a9c6b9f293 Fix SHOW TTL wildcard path scope (#18763)
add ec72c599ce6 Show pre-delete tables in SHOW TABLES and reject modifications on them (#18770)
add 0c9a5ee0916 Optimize tag index timeseries lookup (#18753)
add 2f9f9cab1b7 Fix TTL expired data ratio in settle compaction (#18777)
add b777d3c3f3d [Subscription] Reuse uncovered committed WAL retention boundary (#18778)
add e163f3bc802 Stabilize subscription heartbeat executor test (#18782)
add df27bbc5001 Fix table delete routing to region leaders (#18779)
add acb801e163e [Subscription] Prevent consumers from idling on dry regions (#18738)
add 0c9fb83974f [Fix] Prevent silent subscription data loss on WAL replay gaps (#18741)
add ce14b310e1d [Subscription] Flush lingering batch before WAL gap retry (#18785)
add bbe63644769 Revert "[Fix] Prevent silent subscription data loss on WAL replay gaps (#18741)" (#18786)
add 5756dc831ae Build: upgrade Develocity Maven extension (#18790)
add 40e7ce62936 Reject truncated Thrift containers before allocation (#18631)
add 28c193871de Update extra-enforcer-rules to 1.12.1 and drop its maven-dependency-tree pin (#18796)
add a1c0e90b546 Fix nonexistent file paths in Python client README and correct doc typos (#18797)
add 3a42dddc3f6 Upgrade Docker base image to eclipse-temurin:17-jre-jammy (#18795)
add d20082b1615 [Misc] Add generic extension points to reduce cross-branch conflicts (#18683)
add 4473a133d08 Fix table rename on a DataNode that missed the pre-release (#18800)
add 48233ea92dd [Fix] Isolate FileReaderManager reader I/O with per-file locks (#18788)
add 59d9e3e10ad Bump at.yawk.lz4:lz4-java from 1.11.1 to 1.11.4 (#18798)
add 620be2861b8 Bump com.fasterxml.jackson.core:jackson-core from 2.18.9 to 2.18.11 (#18789)
add eb0e3f1f208 Fix duplicate DataRegion scheduling after recovery (#18803)
add 1a834815784 Fix read lock leak in disk usage statistics (#18807)
add 94f99d6516a Extend the node state machine and persist node statuses (#18801)
add cb0269d9fde Standardize ConfigRegionStateMachine log messages (#18811)
add 99a3e06c76b [Fix] Preserve absent local search index during subscription WAL replay (#18805)
add 83f6428629d Fix subscription WAL replay cursor boundaries (#18810)
add 24fb54f7e77 Bump Thrift to 0.25.0 (#18793)
add 21d53dd015c Bound subscription memory borrowing and report admission failures (#18812)
add b94aa09ab66 [Fix] Prevent consensus subscription teardown from blocking unsubscribe (#18804)
add 054f5dedae5 [Subscription] Report retained WAL file gaps and retry transient reads (#18818)
add f16e5b36fb5 Eliminate OPC UA sink test port allocation race (#18817)
add 741a13a5d24 Remove some printed errMsg when stop DN (#18799)
add abcbf2ed525 [Subscription] Release exhausted TsFile parsers before batch ACK (#18820)
add 6819c8beb9f [Fix] Remap failed-measurement indices when reordering insert columns (#18819)
add e3c4a4e5178 [Pipe] Support region-level realtime downgrading (#18441)
add fea5bd2490a Fix oversized subscription requests with slicing (#18695)
add 2751ee133b4 Retry failed procedure rollback without losing state (#18822)
add 312c205c8b5 Fix schema region NPE during DataNode shutdown (#18821)
add 0f91bed7544 Fix schema existence check fail-open behavior (#18755)
add 5c27559f02f Add subscription stall diagnostics and reduce WAL prefetch overhead (#18808)
add 932c1da25f7 Batch aligned memtable column expansion to reduce region lock contention (#18816)
add 86b46e61a81 Fix stale fragment cleanup removing query memory registrations (#18834)
add 45411925426 Temporarily skip IoTDBNodeStatusFailoverIT (#18839)
add 17b95c8360e Expand some plan types for use in the future (#18836)
add ecf526ad73a Python: fix swapped session and statement IDs in query result sets (#18842)
add 27f89fa72fc [Feature] Make DROP TABLE asynchronous and expose deletion progress (#18806)
add c179b0cd4ed [Session] Throw IoTDBConnectionException instead of NPE when retries are exhausted (#18794)
add a78f5a736c7 [Performance] Pre-size collections with known cardinality
add 491d9b3590b [Test] Stabilize table DDL HA tests for async DROP TABLE (#18852)
add 426376b1955 [Storage] Replace IDeviceID.isTableModel with the data model from context (#18814)
add 510fc7c4544 Fix subscription initialization retries for transient WAL reads (#18829)
add 3d57d2507fa [Subscription] Preserve WAL replay progress across pending gaps (#18831)
add a7e508cf458 [Subscription] Index consensus ACK progress by writer (#18835)
add 030bedd2b2b Fix DATE conversion beyond tablet row count (#18832)
add 72b4d16ac6d [Test] Fix AlignedWritableMemChunkTest compilation error (#18859)
add aec1ad6139c [Pipe] Wake parser workers when admission is available (#18843)
add 0a79a4925e9 Fix flaky space quota result polling in cluster tests (#18850)
add a498d7d2a46 Fix schema mutation validation, accounting and deletion performance (#18861)
add edd5a74c42d Prevent query with explict limit 0 (#18858)
add 0c0116afe22 Bound consensus subscription WAL scans per prefetch round (#18849)
add 6eca5b841d7 [Pipe] Add SHOW PIPE MEMORY for named memory blocks (#18575)
add 8effe5d6ce4 Support retaining subscription progress after unsubscribe (#18718)
add db8bc17a27f [Feature] Expose DROP TABLE mod file progress (#18855)
add 5842fbc6a7b [Pipe] Add reliable DataNode completion metric (#18563)
add 3f1706cbce0 Fix subscription realtime retention under shared memory pressure (#18870)
add f106a0f1d16 [Test] Wait for asynchronous table deletion in session IT (#18877)
add 1b290ae320c [Bugfix] Reclaim RPC buffers by evicting idle clients (#18853)
add ed61790920d [Test] Fix pipe memory ownership test compilation (#18881)
add f8135bb7284 [Test] Fix Ratis mini-cluster shutdown race (#18879)
add e3bbab5e7e8 [Subscription] Support per-topic uncommitted event recycle timeouts (#18876)
add e1baa97f2db [Fix] Stop only the listening DataNode process in Windows stop-datanode.bat (#18883)
add d77a81534e3 Fix deletion WAL logging and flush completion ordering (#18872)
add 673434b3335 Fix quoted tree path parsing in table views (#18884)
add 264053f1423 [Test] Fix deletion regression test flush control
add 532d6c13add Fence IoTConsensus applies before storage shutdown (#18841)
add 6402cd9594b Revert "[Test] Fix deletion regression test flush control"
add f660639add9 [Test] Exclude mock initialization from pipe worker timeouts (#18886)
add a7b88b1027e [Test] Fix deletion regression test flush control (#18888)
add d2b97bc8455 Reuse DataRegion insert lock for IoTConsensus shutdown fencing (#18893)
add 330b0c7ca41 [Test] Fix relational session cleanup and invalid timestamp test setup (#18887)
add aa365aa53f1 [Client] Add Fast Last Query API to C++ session (#18860)
add e492e444a8d [Fix] Preserve table insert errors for rejected fields (#18880)
add 9b807abb93f [Bugfix] Preserve retained subscription progress after the last consumer closes (#18894)
add 9a078cc105e [Subscription] Fix WAL replay progress after realtime gaps (#18895)
add 4e9679da812 feat: support automatic schema creation in Session (#18890)
add 62337565abc feat(load): route decoded tsfile pieces through consensus (#18698)
add c6f86b52a94 [Subscription] Release uncommitted tablet payloads with WAL replay (#18866)
add bacbd5a6dc4 Fix ConfigNode client failover with stale candidates (#18847)
add c9c16af42f6 [Test] Fix dynamic status queries and asynchronous deletion polling (#18899)
add d1aaa0dd909 Optimize errMsg when set configuration default- #18856
add 4acf90c3d89 [Subscription] Resume realtime delivery after WAL gap recovery (#18912)
add e28c4ebce7c Fix ObjectWriter accepting segment offsets beyond EOF (#18907)
add ad1bd47951f Fix tree path quoting in SHOW CREATE VIEW (#18911)
add 5690cec26c2 [Test] Use consistent time units for asynchronous assertion flushes (#18905)
add 77d59829e14 [Fix] Reject table inserts when all fields fail validation (#18908)
add 4c34a253927 [Subscription] Preserve writer order and back off on blocked safe frontiers (#18844)
add 7772f632331 Merge origin/master into feat/pipe-logical-backup-sink
No new revisions were added by this update.
Summary of changes:
.github/workflows/multi-language-client.yml | 12 +-
.mvn/extensions.xml | 2 +-
LICENSE-binary | 25 +-
architecture-test/pom.xml | 284 +
.../db/utils/TSDataTypeSwitchArchitectureTest.java | 23 +-
.../iotdb/db/utils/TSDataTypeSwitchRule.java | 182 +
.../iotdb/db/utils/TSDataTypeSwitchRuleTest.java | 186 +
dependencies.json | 3 -
distribution/pom.xml | 9 +
distribution/src/assembly/library-pipe.xml | 51 +
docker/ReadMe.md | 4 +-
docker/src/main/Dockerfile-1.0.0-confignode | 2 +-
docker/src/main/Dockerfile-1.0.0-datanode | 2 +-
docker/src/main/Dockerfile-1.0.0-standalone | 2 +-
docker/src/main/Dockerfile-1c1d | 2 +-
example/pom.xml | 1 -
.../org/apache/iotdb/DataMigrationExample.java | 64 +-
.../main/java/org/apache/iotdb/TabletExample.java | 56 +-
example/udf/pom.xml | 6 +
.../java/org/apache/iotdb/udf/UDAFExample.java | 106 +-
.../v1/handler/StatementConstructionHandler.java | 113 +-
.../rest/protocol/utils/InsertRowDataUtils.java | 109 +-
.../iotdb/rest/protocol/utils/TypeServices.java | 162 +
.../v1/handler/StatementConstructionHandler.java | 113 +-
.../v2/handler/StatementConstructionHandler.java | 113 +-
.../protocol/v2/handler/FastLastHandlerTest.java | 5 +-
integration-test/pom.xml | 7 +
.../apache/iotdb/db/query/udf/example/TwoSum.java | 44 +-
.../apache/iotdb/db/query/udf/example/UDAFAvg.java | 112 +-
.../apache/iotdb/db/query/udf/example/UDAFSum.java | 112 +-
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 12 +
.../it/env/cluster/config/MppConfigNodeConfig.java | 6 +
.../it/env/cluster/config/MppDataNodeConfig.java | 6 +
.../env/remote/config/RemoteConfigNodeConfig.java | 5 +
.../it/env/remote/config/RemoteDataNodeConfig.java | 5 +
.../apache/iotdb/itbase/env/ConfigNodeConfig.java | 2 +
.../apache/iotdb/itbase/env/DataNodeConfig.java | 2 +
.../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 31 +-
.../it/cluster/IoTDBClusterNodeShutdownHookIT.java | 60 +-
.../it/cluster/IoTDBNodeStatusFailoverIT.java | 743 +++
.../it/cluster/IoTDBNodeStatusPersistenceIT.java | 379 ++
.../confignode/it/cluster/NodeStatusTestAgent.java | 203 +
.../load/IoTDBRegionGroupLeaderDistributionIT.java | 3 +-
.../it/partition/IoTDBPartitionCreationIT.java | 58 +-
.../it/partition/IoTDBPartitionDurableIT.java | 49 +-
.../IoTDBProactiveRegionGroupDistributionIT.java | 1471 +++++
.../IoTDBProactiveRegionGroupExtensionIT.java | 368 ++
.../commit/IoTDBMigrateMultiRegionForIoTV1IT.java | 9 +-
.../IoTDBRegionGroupExpandAndShrinkForIoTV1IT.java | 123 +-
.../IoTDBRemoveConfigNodeSchemaPartitionIT.java | 262 +
.../iotdb/db/it/IoTDBLoadTsFileClusterIT.java | 383 ++
.../it/IoTDBRecreatedTimeseriesCompactionIT.java | 125 +
.../apache/iotdb/db/it/IoTDBShowPipeMemoryIT.java | 246 +
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 24 +-
.../iotdb/db/it/auth/IoTDBSeriesPermissionIT.java | 68 +
.../db/it/last/IoTDBLastQueryVirtualRegionIT.java | 137 +
.../iotdb/db/it/quotas/IoTDBSpaceQuotaIT.java | 5 +
.../apache/iotdb/db/it/utils/IoTDBTestUtilsIT.java | 136 +
.../org/apache/iotdb/db/it/utils/TestUtils.java | 147 +-
.../manual/basic/IoTDBPipePermissionIT.java | 8 +-
.../manual/basic/IoTDBPipeWithLoadIT.java | 3 +-
.../manual/enhanced/IoTDBPipeAutoDropIT.java | 71 +-
.../manual/enhanced/IoTDBPipeClusterIT.java | 41 +-
.../manual/enhanced/IoTDBPipeMetaIT.java | 20 +-
.../treemodel/auto/basic/IoTDBPipeLifeCycleIT.java | 6 +-
.../auto/basic/IoTDBShowReceiversLifecycleIT.java | 2 +
.../auto/enhanced/IoTDBPipeAutoDropIT.java | 105 +-
.../auto/enhanced/IoTDBPipeClusterIT.java | 38 +-
.../treemodel/manual/IoTDBPipeInclusionIT.java | 26 +-
.../manual/IoTDBPipeMetaHistoricalIT.java | 6 +-
.../treemodel/manual/IoTDBPipePermissionIT.java | 12 +-
.../iotdb/pipe/it/single/AbstractPipeSingleIT.java | 70 +-
.../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 17 +-
.../iotdb/pipe/it/single/IoTDBShowReceiversIT.java | 6 +-
.../it/db/it/IoTDBDeletionTableClusterIT.java | 152 +
.../relational/it/db/it/IoTDBDeletionTableIT.java | 4 +-
.../relational/it/db/it/IoTDBInsertTableIT.java | 195 +
.../db/it/IoTDBMultiTAGsWithAttributesTableIT.java | 10 +-
.../it/db/it/IoTDBOrderingPropertyIT.java | 486 ++
.../it/db/it/IoTDBSetConfigurationTableIT.java | 11 +
.../it/db/it/IoTDBSetSystemStatusTableIT.java | 70 +-
.../it/db/it/IoTDBWindowFunction3IT.java | 6 +-
.../relational/it/db/it/IoTDBWindowFunctionIT.java | 40 +-
.../relational/it/db/it/IoTDBWindowTVFIT.java | 86 +
.../it/insertquery/IoTDBInsertQueryIT.java | 3 +-
.../it/query/old/IoTDBSimpleQueryTableIT.java | 24 +
.../relational/it/query/recent/IoTDBCteIT.java | 5 +-
...ableAggregationQueryWithNetworkPartitionIT.java | 5 +-
.../it/query/recent/IoTExplainAnalyzeIT.java | 5 +-
.../query/view/recent/IoTDBTableViewQueryIT.java | 11 +-
.../IoTDBTableViewQueryWithCachedDeviceIT.java | 3 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 73 +-
.../iotdb/relational/it/schema/IoTDBDeviceIT.java | 57 +-
.../it/schema/IoTDBDropTableModProgressIT.java | 106 +
.../relational/it/schema/IoTDBTableDDLHAIT.java | 21 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 121 +-
.../it/session/IoTDBSessionRelationalIT.java | 136 +-
.../iotdb/session/it/IoTDBConnectionsIT.java | 53 +-
.../iotdb/session/it/pool/SessionPoolIT.java | 21 +-
.../IoTDBConsensusSubscriptionBasicTableIT.java | 60 +
...TDBConsensusSubscriptionUnsubscribeTableIT.java | 253 +
.../org/apache/iotdb/pipe/api/event/Event.java | 18 +-
.../event/dml/insertion/TsFileInsertionEvent.java | 5 +
.../java/org/apache/iotdb/udf/api/access/Row.java | 7 +-
.../org/apache/iotdb/udf/api/utils/RowImpl.java | 30 +-
.../en/org/apache/iotdb/cli/i18n/CliMessages.java | 4 +
.../zh/org/apache/iotdb/cli/i18n/CliMessages.java | 4 +
.../java/org/apache/iotdb/cli/AbstractCli.java | 79 +-
.../apache/iotdb/tool/data/AbstractDataTool.java | 67 +-
.../java/org/apache/iotdb/cli/AbstractCliTest.java | 44 +
iotdb-client/client-cpp/src/include/Session.h | 5 +
.../client-cpp/src/rpc/SessionConnection.cpp | 38 +
.../client-cpp/src/rpc/SessionConnection.h | 3 +
iotdb-client/client-cpp/src/session/Session.cpp | 5 +
iotdb-client/client-cpp/test/cpp/sessionIT.cpp | 47 +
iotdb-client/client-py/README.md | 6 +-
iotdb-client/client-py/iotdb/Session.py | 128 +-
.../client-py/tests/unit/test_session_query_ids.py | 132 +
.../org/apache/iotdb/isession/SessionDataSet.java | 39 +-
.../org/apache/iotdb/isession/TypeServices.java | 68 +
iotdb-client/jdbc/README.md | 23 -
iotdb-client/jdbc/osgi.bnd | 31 -
iotdb-client/jdbc/pom.xml | 81 -
iotdb-client/jdbc/src/main/feature/feature.xml | 36 -
.../org/apache/iotdb/jdbc/i18n/JdbcMessages.java | 5 +-
.../org/apache/iotdb/jdbc/i18n/JdbcMessages.java | 4 +-
.../main/java/org/apache/iotdb/jdbc/Activator.java | 42 -
.../iotdb/jdbc/GroupedLSBWatermarkEncoder.java | 56 +-
.../iotdb/jdbc/IoTDBAbstractDatabaseMetadata.java | 62 +-
.../apache/iotdb/jdbc/IoTDBDataSourceFactory.java | 79 -
.../java/org/apache/iotdb/jdbc/IoTDBDriver.java | 2 -
.../resources/META-INF/services/java.sql.Driver | 20 +
.../iotdb/jdbc/DriverServiceRegistrationTest.java | 32 +-
.../org/apache/iotdb/jdbc/IoTDBStatementTest.java | 39 +
.../en/org/apache/iotdb/rpc/i18n/RpcMessages.java | 6 +
.../zh/org/apache/iotdb/rpc/i18n/RpcMessages.java | 6 +
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 185 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 96 +-
.../org/apache/iotdb/rpc/NonOpenTransport.java | 6 +
.../rpc/TCompressedElasticFramedTransport.java | 4 +
.../apache/iotdb/rpc/TElasticFramedTransport.java | 74 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 26 +
.../java/org/apache/iotdb/rpc/TypeServices.java | 162 +
.../iotdb/rpc/stmt/PreparedParameterSerde.java | 41 +-
.../org/apache/iotdb/rpc/IoTDBJDBCDataSetTest.java | 176 +
.../iotdb/rpc/TElasticFramedTransportReadTest.java | 266 +
.../iotdb/rpc/TElasticFramedTransportTest.java | 101 +
.../iotdb/rpc/stmt/PreparedParameterSerdeTest.java | 12 +
.../iotdb/session/AbstractSessionBuilder.java | 2 +
.../java/org/apache/iotdb/session/Session.java | 196 +-
.../apache/iotdb/session/SessionConnection.java | 25 +-
.../apache/iotdb/session/TableSessionBuilder.java | 12 +
.../org/apache/iotdb/session/pool/SessionPool.java | 5 +
.../session/pool/TableSessionPoolBuilder.java | 12 +
.../iotdb/session/util/SessionTypeServices.java | 435 ++
.../apache/iotdb/session/util/SessionUtils.java | 301 +-
.../iotdb/session/BrokenSessionConnectionTest.java | 222 +
.../iotdb/session/SessionCacheLeaderTest.java | 79 +-
.../java/org/apache/iotdb/session/SessionTest.java | 43 +
.../iotdb/session/util/SessionUtilsTest.java | 21 +
.../subscription/i18n/SubscriptionMessages.java | 6 +
.../subscription/i18n/SubscriptionMessages.java | 6 +
.../rpc/subscription/config/ConsumerConstant.java | 2 +-
.../iotdb/rpc/subscription/config/TopicConfig.java | 19 +
.../rpc/subscription/config/TopicConstant.java | 7 +
.../payload/request/PipeSubscribeRequestType.java | 1 +
.../payload/request/PipeSubscribeSliceReq.java | 169 +
.../request/PipeSubscribeSliceReqBuilder.java | 80 +
.../request/PipeSubscribeSliceReqHandler.java | 141 +
.../SubscriptionSessionConnection.java | 8 +
.../base/AbstractSubscriptionConsumer.java | 40 +-
.../base/AbstractSubscriptionConsumerBuilder.java | 2 +-
.../base/AbstractSubscriptionProvider.java | 188 +-
.../base/AbstractSubscriptionProviders.java | 72 +-
.../base/AbstractSubscriptionPullConsumer.java | 19 +
.../base/SubscriptionExecutorServiceManager.java | 68 +
.../tree/SubscriptionTreePullConsumer.java | 2 +-
.../tree/SubscriptionTreePushConsumer.java | 2 +-
.../payload/SubscriptionRecordHandler.java | 76 +-
.../session/subscription/payload/TypeServices.java | 115 +
.../rpc/subscription/config/TopicConfigTest.java | 34 +
.../payload/request/PipeSubscribeSliceReqTest.java | 203 +
...SubscriptionConsumerHeartbeatIsolationTest.java | 341 ++
.../base/SubscriptionConsumerLifecycleTest.java | 220 +-
.../base/SubscriptionProviderSlicingTest.java | 232 +
.../subscription/payload/TypeServicesTest.java | 69 +
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 1 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 6 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 53 +
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 53 +
.../aggregation/CentralMomentAccumulator.java | 35 +-
.../aggregation/CorrelationAccumulator.java | 20 +-
.../aggregation/CovarianceAccumulator.java | 20 +-
.../aggregation/RegressionAccumulator.java | 20 +-
.../execution/aggregation/VarianceAccumulator.java | 115 +-
.../operator/RowReferenceTsBlockManager.java | 12 +-
.../SimpleTsBlockWithPositionComparator.java | 2 +-
.../process/AbstractLinearFillOperator.java | 15 +-
.../operator/process/FilterAndProjectOperator.java | 6 +-
.../process/PatternRecognitionOperator.java | 2 +-
.../process/TableLinearFillWithGroupOperator.java | 18 +-
.../process/TableNextFillWithGroupOperator.java | 5 +
.../operator/process/TableStreamSortOperator.java | 4 +-
.../execution/operator/process/TopKOperator.java | 95 +-
.../process/join/merge/MergeSortComparator.java | 46 +-
.../merge/comparator/JoinKeyComparatorFactory.java | 36 +-
.../rowpattern/PatternPartitionExecutor.java | 2 +-
.../process/rowpattern/expression/Computation.java | 2 +-
.../rowpattern/expression/NaryComputation.java | 2 +-
.../process/window/TopKRankingOperator.java | 12 +-
.../process/window/function/value/LagFunction.java | 36 -
.../window/function/value/LeadFunction.java | 36 -
.../window/function/value/ValueWindowFunction.java | 9 +
.../process/window/partition/frame/RangeFrame.java | 294 +-
.../operator/process/window/utils/ColumnList.java | 9 +
.../process/window/utils/RowComparator.java | 174 +-
.../relational/MergeSortFullOuterJoinOperator.java | 6 +-
.../AbstractApproxMostFrequentAccumulator.java | 2 +-
.../AbstractApproxPercentileAccumulator.java | 64 +-
.../relational/aggregation/AccumulatorFactory.java | 64 +-
.../ApproxCountDistinctAccumulator.java | 54 +-
.../relational/aggregation/AvgAccumulator.java | 207 +-
.../relational/aggregation/ExtremeAccumulator.java | 165 +-
.../relational/aggregation/FirstAccumulator.java | 248 +-
.../relational/aggregation/FirstByAccumulator.java | 226 +-
.../relational/aggregation/LastAccumulator.java | 282 +-
.../relational/aggregation/LastByAccumulator.java | 222 +-
.../relational/aggregation/MaxAccumulator.java | 193 +-
.../relational/aggregation/MinAccumulator.java | 193 +-
.../aggregation/PercentileAccumulator.java | 132 +-
.../relational/aggregation/SumAccumulator.java | 204 +-
.../aggregation/TableCentralMomentAccumulator.java | 51 +-
.../aggregation/TableCorrelationAccumulator.java | 33 +-
.../aggregation/TableCovarianceAccumulator.java | 33 +-
.../aggregation/TableMaxMinByBaseAccumulator.java | 352 +-
.../aggregation/TableModeAccumulator.java | 667 +--
.../aggregation/TableRegressionAccumulator.java | 33 +-
.../aggregation/TableVarianceAccumulator.java | 226 +-
.../source/relational/aggregation/Utils.java | 62 +-
...AbstractGroupedApproxPercentileAccumulator.java | 58 +-
.../GroupedApproxCountDistinctAccumulator.java | 74 +-
.../aggregation/grouped/GroupedAvgAccumulator.java | 133 +-
.../grouped/GroupedCentralMomentAccumulator.java | 38 +-
.../grouped/GroupedCorrelationAccumulator.java | 29 +-
.../grouped/GroupedCovarianceAccumulator.java | 29 +-
.../grouped/GroupedExtremeAccumulator.java | 337 +-
.../grouped/GroupedFirstAccumulator.java | 458 +-
.../grouped/GroupedFirstByAccumulator.java | 463 +-
.../grouped/GroupedLastAccumulator.java | 457 +-
.../grouped/GroupedLastByAccumulator.java | 463 +-
.../aggregation/grouped/GroupedMaxAccumulator.java | 368 +-
.../grouped/GroupedMaxMinByBaseAccumulator.java | 903 +---
.../aggregation/grouped/GroupedMinAccumulator.java | 494 +-
.../grouped/GroupedModeAccumulator.java | 323 +-
.../grouped/GroupedPercentileAccumulator.java | 78 +-
.../grouped/GroupedRegressionAccumulator.java | 29 +-
.../aggregation/grouped/GroupedSumAccumulator.java | 125 +-
.../grouped/GroupedVarianceAccumulator.java | 177 +-
.../aggregation/grouped/array/BinaryBigArray.java | 7 +
.../aggregation/grouped/array/BooleanBigArray.java | 5 +
.../aggregation/grouped/array/DoubleBigArray.java | 5 +
.../aggregation/grouped/array/FloatBigArray.java | 5 +
.../aggregation/grouped/array/IntBigArray.java | 5 +
.../aggregation/grouped/array/LongBigArray.java | 5 +
.../grouped/rate/GroupedNaiveDeltaAccumulator.java | 49 +-
.../rate/GroupedNaiveIncreaseAccumulator.java | 49 +-
.../grouped/rate/GroupedNaiveIrateAccumulator.java | 31 +-
.../grouped/rate/GroupedNaiveRateAccumulator.java | 46 +-
.../rate/GroupedOrderedDeltaAccumulator.java | 50 +-
.../rate/GroupedOrderedIncreaseAccumulator.java | 50 +-
.../rate/GroupedOrderedIrateAccumulator.java | 31 +-
.../rate/GroupedOrderedRateAccumulator.java | 47 +-
.../aggregation/rate/NaiveDeltaAccumulator.java | 47 +-
.../aggregation/rate/NaiveIncreaseAccumulator.java | 47 +-
.../aggregation/rate/NaiveIrateAccumulator.java | 29 +-
.../aggregation/rate/NaiveRateAccumulator.java | 44 +-
.../aggregation/rate/OrderedDeltaAccumulator.java | 47 +-
.../rate/OrderedIncreaseAccumulator.java | 47 +-
.../aggregation/rate/OrderedIrateAccumulator.java | 30 +-
.../aggregation/rate/OrderedRateAccumulator.java | 44 +-
.../aggregation/rate/RateFunctionValidation.java | 56 +-
.../relational/ColumnTransformerBuilder.java | 123 +-
.../calc/plan/planner/CommonOperatorUtils.java | 129 +-
.../calc/plan/planner/TableOperatorGenerator.java | 148 +-
.../AbstractCaseWhenThenColumnTransformer.java | 2 +-
.../AbstractGreatestLeastColumnTransformer.java | 47 +-
.../multi/BinaryGreatestColumnTransformer.java | 2 +-
.../column/multi/BinaryLeastColumnTransformer.java | 2 +-
.../multi/BooleanGreatestColumnTransformer.java | 2 +-
.../multi/BooleanLeastColumnTransformer.java | 2 +-
.../multi/DoubleGreatestColumnTransformer.java | 2 +-
.../column/multi/DoubleLeastColumnTransformer.java | 2 +-
.../multi/FloatGreatestColumnTransformer.java | 2 +-
.../column/multi/FloatLeastColumnTransformer.java | 2 +-
.../multi/Int32GreatestColumnTransformer.java | 2 +-
.../column/multi/Int32LeastColumnTransformer.java | 2 +-
.../multi/Int64GreatestColumnTransformer.java | 2 +-
.../column/multi/Int64LeastColumnTransformer.java | 2 +-
.../multi/LogicalAndMultiColumnTransformer.java | 2 +-
.../multi/LogicalOrMultiColumnTransformer.java | 2 +-
.../dag/column/multi/MultiColumnTransformer.java | 2 +-
.../dag/column/unary/InColumnTransformer.java | 220 +-
.../AbstractCastFunctionColumnTransformer.java | 370 +-
.../scalar/CastFunctionColumnTransformer.java | 56 +-
.../unary/scalar/FormatColumnTransformer.java | 37 +-
.../unary/scalar/RoundColumnTransformer.java | 37 +-
.../scalar/RoundFunctionColumnTransformer.java | 39 +-
.../scalar/TryCastFunctionColumnTransformer.java | 58 +-
.../transformation/dag/util/CastFunctionUtils.java | 251 +-
.../datastructure/row/SerializableRowList.java | 64 +-
.../datastructure/tv/SerializableTVList.java | 40 +-
.../org/apache/iotdb/calc/utils/TypeServices.java | 5675 ++++++++++++++++++++
.../apache/iotdb/calc/utils/sort/DiskSpiller.java | 4 +-
.../aggregation/LastDescendingInputTest.java | 108 +
.../aggregation/NumericBatchAggregationTest.java | 224 +
.../aggregation/NumericMomentBatchTest.java | 157 +
.../relational/aggregation/SumAccumulatorTest.java | 140 +
.../aggregation/VarianceAccumulatorTest.java | 125 +
.../GroupedApproxCountDistinctMaskTest.java | 50 +
.../aggregation/rate/RateBatchInputTest.java | 253 +
.../column/unary/scalar/NumericCastBatchTest.java | 184 +
.../apache/iotdb/calc/utils/TypeServicesTest.java | 416 ++
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 74 +-
.../iotdb/confignode/i18n/ManagerMessages.java | 31 +-
.../iotdb/confignode/i18n/ProcedureMessages.java | 9 +
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 77 +-
.../iotdb/confignode/i18n/ManagerMessages.java | 31 +-
.../iotdb/confignode/i18n/ProcedureMessages.java | 18 +-
.../client/async/CnToDnAsyncRequestType.java | 1 +
.../CnToDnInternalServiceAsyncRequestManager.java | 15 +-
.../handlers/heartbeat/AINodeHeartbeatHandler.java | 4 +-
.../heartbeat/ConfigNodeHeartbeatHandler.java | 4 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 7 +-
.../rpc/DataNodeAsyncRequestRPCHandler.java | 9 +
.../rpc/GetDropTableModProgressRPCHandler.java | 59 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 70 +-
.../consensus/request/ConfigPhysicalPlan.java | 8 +
.../consensus/request/ConfigPhysicalPlanType.java | 11 +
.../request/ConfigPhysicalPlanVisitor.java | 8 +
.../request/write/auth/AuthorTreePlan.java | 4 +-
.../write/confignode/UpdateNodeStatusPlan.java | 104 +
.../pipe/payload/PipeDeactivateTemplatePlan.java | 4 +-
.../pipe/task/OperateMultiplePipesPlanV2.java | 2 +-
.../topic/AlterMultipleTopicsPlan.java | 2 +-
.../write/table/SetTableColumnPropertiesPlan.java | 80 +
.../partition/GetRegionGroupsByTimeResp.java | 25 +
.../statemachine/ConfigRegionStateMachine.java | 16 +-
.../confignode/manager/ClusterQuotaManager.java | 5 +-
.../iotdb/confignode/manager/ConfigManager.java | 209 +-
.../apache/iotdb/confignode/manager/IManager.java | 21 +-
.../iotdb/confignode/manager/ProcedureManager.java | 654 ++-
.../confignode/manager/RetryFailedTasksThread.java | 3 +-
.../iotdb/confignode/manager/load/LoadManager.java | 76 +-
.../manager/load/balancer/RegionBalancer.java | 12 +-
.../partition/DataPartitionPolicyTable.java | 18 +-
.../manager/load/cache/AbstractLoadCache.java | 9 +-
.../confignode/manager/load/cache/LoadCache.java | 140 +-
.../load/cache/consensus/ConsensusGroupCache.java | 3 +-
.../load/cache/node/AINodeHeartbeatCache.java | 48 -
.../manager/load/cache/node/BaseNodeCache.java | 84 +-
.../load/cache/node/ConfigNodeHeartbeatCache.java | 39 +-
.../load/cache/node/DataNodeHeartbeatCache.java | 57 +-
.../load/cache/node/NodeHeartbeatSample.java | 7 +-
.../manager/load/cache/node/NodeStatistics.java | 17 +
.../manager/load/cache/region/RegionCache.java | 3 +-
.../load/cache/region/RegionGroupCache.java | 2 +-
.../manager/load/service/StatisticsService.java | 2 +-
.../iotdb/confignode/manager/node/NodeManager.java | 25 +-
.../manager/partition/PartitionManager.java | 106 +-
.../partition/RegionGroupExtensionPolicy.java | 4 +-
.../runtime/heartbeat/PipeHeartbeatParser.java | 20 +-
.../PipeConfigNodeRemainingTimeMetrics.java | 20 +-
.../PipeTemporaryMetaInCoordinatorMetrics.java | 18 +-
.../metric/sink/PipeConfigRegionSinkMetrics.java | 17 +-
.../source/PipeConfigRegionSourceMetrics.java | 17 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 26 +
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 7 +
.../pipe/source/ConfigRegionListeningFilter.java | 2 +
.../manager/schema/ClusterSchemaManager.java | 79 +-
.../runtime/SubscriptionRuntimeCoordinator.java | 7 +-
.../persistence/executor/ConfigPlanExecutor.java | 82 +-
.../confignode/persistence/node/NodeInfo.java | 115 +-
.../partition/DatabasePartitionTable.java | 16 +
.../persistence/partition/PartitionInfo.java | 12 +
.../schema/CNPhysicalPlanGenerator.java | 48 +-
.../persistence/schema/CNSnapshotFileType.java | 4 +-
.../persistence/schema/ClusterSchemaInfo.java | 17 +-
.../confignode/persistence/schema/ConfigMTree.java | 78 +-
.../persistence/subscription/SubscriptionInfo.java | 152 +-
.../iotdb/confignode/procedure/Procedure.java | 14 +
.../confignode/procedure/ProcedureExecutor.java | 121 +-
.../procedure/TimeoutExecutorThread.java | 2 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 7 +-
.../procedure/env/RegionMaintainHandler.java | 24 +-
.../procedure/env/RemoveDataNodeHandler.java | 71 +-
.../procedure/impl/StateMachineProcedure.java | 6 +-
.../procedure/impl/node/RemoveAINodeProcedure.java | 1 +
.../impl/node/RemoveDataNodesProcedure.java | 6 +-
.../impl/schema/DeactivateTemplateProcedure.java | 3 +-
.../procedure/impl/schema/SchemaUtils.java | 26 +-
.../table/AbstractAlterOrDropTableProcedure.java | 19 +
...re.java => AbstractSetPropertiesProcedure.java} | 71 +-
.../impl/schema/table/DeleteDevicesProcedure.java | 2 +-
.../impl/schema/table/DropTableProcedure.java | 186 +-
.../impl/schema/table/RenameTableProcedure.java | 2 +-
.../table/SetTableColumnPropertiesProcedure.java | 107 +
.../schema/table/SetTablePropertiesProcedure.java | 218 +-
.../impl/sync/AuthOperationProcedure.java | 2 +-
.../procedure/store/ProcedureFactory.java | 9 +
.../confignode/procedure/store/ProcedureType.java | 2 +
.../confignode/service/ConfigNodeShutdownHook.java | 162 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 +
...ToDnInternalServiceAsyncRequestManagerTest.java | 114 +
.../heartbeat/DataNodeHeartbeatHandlerTest.java | 100 +
.../conf/RegionGroupExtensionPolicyConfigTest.java | 106 +
.../request/ConfigPhysicalPlanSerDeTest.java | 67 +
.../manager/ClusterSchemaManagerTest.java | 89 +
.../ConfigManagerRegionGroupPolicyReloadTest.java | 150 +
.../manager/ConfigManagerShutdownReportTest.java | 161 +
.../ProcedureManagerReconstructRegionTest.java | 190 -
.../ProcedureManagerRegionOperationTest.java | 401 ++
.../manager/ProcedureManagerTableTaskTest.java | 225 +
.../confignode/manager/ProcedureManagerTest.java | 41 +
.../manager/RetryFailedTasksThreadTest.java | 107 +
.../confignode/manager/load/LoadManagerTest.java | 115 +-
.../manager/load/balancer/RegionBalancerTest.java | 144 +
.../DataPartitionPolicyTableProactiveTest.java | 190 +
.../router/priority/GreedyPriorityTest.java | 2 +-
.../priority/LeaderPriorityBalancerTest.java | 2 +-
.../load/cache/ConsensusGroupCacheTest.java | 2 +-
.../load/cache/LoadCacheNodeStatusTest.java | 336 ++
.../cache/LoadCachePersistedNodeStatusTest.java | 898 ++++
.../manager/load/cache/NodeCacheTest.java | 228 +-
.../manager/node/NodeManagerStatusReasonTest.java | 133 +
.../PartitionManagerProactiveExtensionTest.java | 811 +++
.../runtime/heartbeat/PipeHeartbeatParserTest.java | 86 +
.../metric/PipeConfigNodeMetricsRestartTest.java | 184 +
.../SubscriptionRuntimeCoordinatorTest.java | 119 +
.../persistence/CNPhysicalPlanGeneratorTest.java | 20 +
.../iotdb/confignode/persistence/NodeInfoTest.java | 269 +
.../persistence/schema/ClusterSchemaInfoTest.java | 119 +
.../persistence/schema/ConfigMTreeTest.java | 31 +
.../subscription/SubscriptionInfoTest.java | 224 +
.../SubscriptionInfoTopicValidationTest.java | 150 +
.../confignode/procedure/STMProcedureTest.java | 108 +
.../procedure/env/ConfigNodeProcedureEnvTest.java | 93 +
.../procedure/env/RegionMaintainHandlerTest.java | 303 ++
.../impl/node/RemoveDataNodePersistenceTest.java | 581 ++
.../procedure/impl/schema/SchemaUtilsTest.java | 91 +
.../impl/schema/table/DropTableProcedureTest.java | 333 ++
.../service/ConfigNodeShutdownHookTest.java | 346 ++
iotdb-core/consensus/pom.xml | 5 +
.../iotdb/consensus/i18n/IoTConsensusMessages.java | 4 +
.../iotdb/consensus/i18n/IoTConsensusMessages.java | 4 +
.../common/request/IndexedConsensusRequest.java | 20 +
.../apache/iotdb/consensus/iot/IoTConsensus.java | 15 +-
.../consensus/iot/IoTConsensusServerImpl.java | 67 +-
.../consensus/iot/WriterSafeFrontierTracker.java | 33 +
.../consensus/iot/log/ConsensusReqReader.java | 8 +
.../logdispatcher/IoTConsensusMemoryManager.java | 6 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 13 +-
.../logdispatcher/LogDispatcherThreadMetrics.java | 104 +-
.../subscription/SubscriptionQueueAdmission.java | 25 +
.../subscription/SubscriptionQueueRegistry.java | 153 +-
.../SubscriptionQueueRejectionReason.java | 42 +
.../SubscriptionWalRetentionCalculator.java | 10 +-
.../consensus/pipe/IoTConsensusV2ServerImpl.java | 5 +
.../pipe/metric/IoTConsensusV2ServerMetrics.java | 3 -
.../consensus/ratis/metrics/CounterProxy.java | 8 +-
.../ratis/metrics/IoTDBMetricRegistry.java | 34 +-
.../ratis/metrics/MetricRegistryManager.java | 14 +
.../consensus/ratis/metrics/RatisMetricSet.java | 8 +-
.../iotdb/consensus/ratis/metrics/TimerProxy.java | 7 +-
.../request/IndexedConsensusRequestTest.java | 110 +
.../consensus/iot/IoTConsensusServerImplTest.java | 94 +
.../iot/WriterSafeFrontierTrackerTest.java | 20 +
.../LogDispatcherThreadMetricsTest.java | 146 +
.../SubscriptionQueueRegistryTest.java | 88 +
.../metric/IoTConsensusV2ServerMetricsTest.java | 107 +
.../iotdb/consensus/ratis/RecoverReadTest.java | 70 +
.../apache/iotdb/consensus/ratis/TestUtils.java | 51 +-
.../ratis/metrics/RatisMetricSetTest.java | 134 +
iotdb-core/datanode/pom.xml | 45 +-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 19 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 123 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 146 +-
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 5 +-
.../apache/iotdb/db/i18n/ImportWALMessages.java | 163 +
.../iotdb/db/i18n/StorageEngineMessages.java | 219 +-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 18 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 120 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 145 +-
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 5 +-
.../apache/iotdb/db/i18n/ImportWALMessages.java | 162 +
.../iotdb/db/i18n/StorageEngineMessages.java | 213 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 20 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 39 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 40 +-
.../dataregion/DataExecutionVisitor.java | 74 +-
.../dataregion/DataRegionStateMachine.java | 8 +-
.../iotdb/db/lbac/AllowAllLBACAccessControl.java | 47 +
.../apache/iotdb/db/lbac/ILBACAccessControl.java | 74 +
.../db/partition/DataPartitionTableGenerator.java | 8 +-
.../dataregion/PipeDataRegionSinkConstructor.java | 3 -
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 7 +-
.../iotdb/db/pipe/agent/task/PipeDataNodeTask.java | 6 +
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 87 +
.../task/builder/PipeDataNodeTaskBuilder.java | 1 +
.../agent/task/connection/PipeEventCollector.java | 31 +
.../agent/task/stage/PipeTaskProcessorStage.java | 2 +
.../pipe/agent/task/stage/PipeTaskSourceStage.java | 18 +
.../subtask/processor/PipeProcessorSubtask.java | 14 +-
.../PipeProcessorSubtaskExecutionGuard.java | 16 +
.../processor/PipeProcessorSubtaskWorker.java | 29 +-
.../sink/PipeRealtimePriorityBlockingQueue.java | 4 +-
.../db/pipe/event/UserDefinedEnrichedEvent.java | 11 +
.../db/pipe/event/common/PipeInsertionEvent.java | 9 +
.../event/common/heartbeat/PipeHeartbeatEvent.java | 102 +-
.../event/common/row/PipeDataTypeTransformer.java | 34 +-
.../iotdb/db/pipe/event/common/row/PipeRow.java | 29 +-
.../statement/PipeStatementInsertionEvent.java | 15 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 32 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 94 +-
.../pipe/event/common/tablet/PipeTabletUtils.java | 35 +-
.../tablet/parser/TabletInsertionEventParser.java | 209 +-
.../event/common/terminate/PipeTerminateEvent.java | 5 +
.../common/tsfile/PipeTsFileInsertionEvent.java | 246 +-
.../tsfile/parser/TsFileInsertionEventParser.java | 19 +-
.../TsFileInsertionEventParserMemoryManager.java | 68 +-
.../query/TsFileInsertionEventQueryParser.java | 12 +-
...ileInsertionEventQueryParserTabletIterator.java | 2 +-
.../parser/scan/SinglePageWholeChunkReader.java | 41 +-
.../scan/TsFileInsertionEventScanParser.java | 153 +-
.../table/TsFileInsertionEventTableParser.java | 19 +-
...ileInsertionEventTableParserTabletIterator.java | 75 +-
.../tsfile/parser/util/ModsOperationUtil.java | 24 +-
.../event/realtime/PipeRealtimeEventFactory.java | 4 +
.../overview/PipeDataNodeCompletionOperator.java | 420 ++
.../PipeDataNodeRemainingEventAndTimeOperator.java | 4 +
.../overview/PipeDataNodeSinglePipeMetrics.java | 146 +-
.../pipe/metric/overview/PipeResourceMetrics.java | 47 +
.../overview/PipeTsFileToTabletsMetrics.java | 16 +-
.../metric/processor/PipeProcessorMetrics.java | 19 +-
.../schema/PipeSchemaRegionListenerMetrics.java | 16 +-
.../metric/schema/PipeSchemaRegionSinkMetrics.java | 16 +-
.../schema/PipeSchemaRegionSourceMetrics.java | 16 +-
.../metric/sink/PipeDataRegionSinkMetrics.java | 19 +-
.../db/pipe/metric/source/PipeAssignerMetrics.java | 13 +-
.../metric/source/PipeDataRegionSourceMetrics.java | 20 +-
.../processor/aggregate/AggregateProcessor.java | 159 +-
.../aggregate/TimeSeriesRuntimeState.java | 23 +
.../CustomizedReadableIntermediateResults.java | 164 +-
.../numeric/AbstractSameTypeNumericOperator.java | 119 +-
.../downsampling/DownSamplingProcessor.java | 3 +
.../downsampling/PartialPathLastObjectCache.java | 13 +-
.../payload/FetchCombineResultRequest.java | 2 +-
.../protocol/airgap/IoTDBAirGapReceiver.java | 11 +-
.../iotconsensusv2/IoTConsensusV2Receiver.java | 4 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 48 +-
.../transform/converter/ValueConverter.java | 141 +-
.../resource/memory/InsertNodeMemoryEstimator.java | 95 +-
.../pipe/resource/memory/PipeFixedMemoryBlock.java | 37 +-
.../db/pipe/resource/memory/PipeMemoryBlock.java | 282 +-
...moryBlock.java => PipeMemoryBlockCategory.java} | 35 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 955 +++-
.../pipe/resource/memory/PipeMemoryWeightUtil.java | 10 +-
.../resource/memory/PipeModelFixedMemoryBlock.java | 27 +-
.../resource/memory/PipeTabletMemoryBlock.java | 14 +-
.../resource/memory/PipeTsFileMemoryBlock.java | 14 +-
.../resource/tsfile/PipeTsFilePublicResource.java | 29 +-
.../IoTDBDataNodeCacheLeaderClientManager.java | 8 +-
.../batch/PipeSchemaRegionWritePlanEventBatch.java | 9 +-
.../evolvable/batch/PipeTabletEventBatch.java | 9 +-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 53 +-
.../request/PipeTransferTabletBatchReqV2.java | 3 +
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 10 +-
.../iotconsensusv2/IoTConsensusV2SyncSink.java | 7 +-
.../IoTConsensusV2TsFileInsertionEventHandler.java | 8 +-
.../IoTConsensusV2TransferBatchReqBuilder.java | 9 +-
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 7 +-
.../sink/protocol/opcda/OpcDaServerHandle.java | 73 +-
.../db/pipe/sink/protocol/opcda/OpcDaSink.java | 9 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 109 +-
.../PipeTransferTabletInsertNodeEventHandler.java | 13 +-
.../PipeTransferTabletInsertionEventHandler.java | 6 +-
.../async/handler/PipeTransferTsFileHandler.java | 108 +-
.../thrift/sync/IoTDBDataRegionSyncSink.java | 14 +-
.../sink/util/PipeTabletEventTransferUtils.java | 97 +
.../pipe/sink/util/TabletStatementConverter.java | 128 +-
.../builder/PipeTableModelTsFileBuilderV2.java | 3 +-
.../util/builder/PipeTreeModelTsFileBuilderV2.java | 3 +-
.../db/pipe/sink/util/cacher/LeaderCacheUtils.java | 42 +-
.../sink/util/sorter/PipeInsertEventSorter.java | 106 +-
.../source/dataregion/IoTDBDataRegionSource.java | 15 +
...istoricalDataRegionTsFileAndDeletionSource.java | 16 +-
.../PipeRealtimeDataRegionHybridSource.java | 684 ++-
.../realtime/PipeRealtimeDataRegionLogSource.java | 1 +
.../realtime/PipeRealtimeDataRegionSource.java | 76 +-
.../PipeRealtimeDataRegionTsFileSource.java | 151 +-
.../realtime/assigner/DisruptorQueue.java | 8 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 243 +-
.../listener/PipeInsertionDataNodeListener.java | 77 +-
.../matcher/CachedSchemaPatternMatcher.java | 56 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 7 +
.../iotdb/db/protocol/session/ClientSession.java | 23 +
.../iotdb/db/protocol/session/IClientSession.java | 13 +
.../db/protocol/session/InternalClientSession.java | 5 +
.../db/protocol/session/MqttClientSession.java | 5 +
.../db/protocol/session/RestClientSession.java | 5 +
.../iotdb/db/protocol/session/SessionManager.java | 3 +-
.../handler/RPCServiceThriftHandlerMetrics.java | 37 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 150 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 151 +-
.../db/queryengine/common/TimeseriesContext.java | 4 +-
.../execution/aggregation/AccumulatorFactory.java | 34 +-
.../execution/aggregation/AvgAccumulator.java | 105 +-
.../execution/aggregation/ExtremeAccumulator.java | 264 +-
.../aggregation/FirstValueAccumulator.java | 336 +-
.../aggregation/FirstValueDescAccumulator.java | 79 +-
.../aggregation/LastValueAccumulator.java | 327 +-
.../aggregation/LastValueDescAccumulator.java | 89 +-
.../aggregation/MaxMinByBaseAccumulator.java | 315 +-
.../execution/aggregation/MaxValueAccumulator.java | 286 +-
.../execution/aggregation/MinValueAccumulator.java | 287 +-
.../execution/aggregation/SumAccumulator.java | 100 +-
.../db/queryengine/execution/driver/Driver.java | 6 +
.../execution/executor/RegionWriteExecutor.java | 36 +-
.../fragment/FakedFragmentInstanceContext.java | 84 +-
.../fragment/FragmentInstanceContext.java | 185 +-
.../fragment/FragmentInstanceExecution.java | 11 +-
.../fragment/FragmentInstanceFailureInfo.java | 4 +-
.../FragmentInstanceFinishedException.java} | 26 +-
.../execution/fragment/QueryContext.java | 12 +-
.../queryengine/execution/memory/MemoryPool.java | 5 +-
.../execution/operator/AggregationUtil.java | 34 +-
.../process/InsertTabletStatementGenerator.java | 137 +-
.../operator/process/TransformOperator.java | 45 +-
.../process/last/LastQueryCollectOperator.java | 12 +-
.../schema/source/DeviceBlackListConstructor.java | 14 +-
.../execution/operator/source/SeriesScanUtil.java | 506 +-
.../InformationSchemaContentSupplierFactory.java | 202 +-
.../relational/LastQueryAggTableScanOperator.java | 28 +-
.../operator/window/WindowManagerFactory.java | 62 +-
.../execution/schedule/DriverScheduler.java | 9 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 25 +
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 2 +-
.../plan/analyze/ClusterPartitionFetcher.java | 4 +
.../analyze/cache/partition/PartitionCache.java | 54 +-
.../analyze/load/LoadTsFileTableSchemaCache.java | 2 +-
.../analyze/load/LoadTsFileTreeSchemaCache.java | 6 +-
.../plan/analyze/schema/SchemaValidator.java | 78 +-
.../execution/config/TableConfigTaskVisitor.java | 69 +
.../config/executor/ClusterConfigTaskExecutor.java | 66 +-
.../config/executor/IConfigTaskExecutor.java | 9 +
.../config/metadata/ShowClusterDetailsTask.java | 63 +-
.../execution/config/metadata/ShowClusterTask.java | 40 +-
.../config/metadata/ShowConfigNodesTask.java | 28 +-
.../config/metadata/ShowDataNodesTask.java | 30 +-
.../AlterTableSetColumnPropertiesTask.java | 55 +
.../metadata/relational/ShowCreateViewTask.java | 3 +-
.../plan/expression/multi/FunctionExpression.java | 4 +-
.../visitor/ColumnTransformerVisitor.java | 6 +-
.../visitor/CompleteMeasurementSchemaVisitor.java | 2 +-
.../visitor/ExistUnknownTypeInExpression.java | 2 +-
.../visitor/GetMeasurementExpressionVisitor.java | 6 +
.../visitor/IntermediateLayerVisitor.java | 3 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 47 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 6 +
.../plan/planner/OperatorGeneratorUtil.java | 28 +-
.../plan/planner/OperatorTreeGenerator.java | 51 +-
.../plan/node/DataNodePlanNodeDeserializer.java | 7 +
.../plan/planner/plan/node/PlanVisitor.java | 5 +
.../plan/node/load/LoadPieceConsensusRequest.java | 117 +
.../plan/node/load/LoadTsFileConsensusNode.java | 937 ++++
.../plan/node/load/LoadTsFileConsensusOp.java | 60 +
.../plan/node/load/LoadTsFilePieceNode.java | 27 +-
.../metadata/read/LevelTimeSeriesCountNode.java | 4 +-
.../metadata/read/SeriesSchemaFetchScanNode.java | 4 +-
.../node/metadata/read/TimeSeriesCountNode.java | 4 +-
.../metadata/read/TimeSeriesSchemaScanNode.java | 4 +-
.../write/CreateAlignedTimeSeriesNode.java | 14 +-
.../plan/node/metadata/write/MeasurementGroup.java | 14 +-
.../planner/plan/node/sink/IdentitySinkNode.java | 2 +-
.../planner/plan/node/sink/ShuffleSinkNode.java | 2 +-
.../source/AlignedSeriesAggregationScanNode.java | 3 +-
.../plan/node/source/DeviceRegionScanNode.java | 3 +-
.../node/source/SeriesAggregationScanNode.java | 3 +-
.../plan/node/source/TimeseriesRegionScanNode.java | 10 +-
.../plan/node/write/InsertMultiTabletsNode.java | 5 +-
.../plan/planner/plan/node/write/InsertNode.java | 5 +
.../planner/plan/node/write/InsertRowNode.java | 218 +-
.../planner/plan/node/write/InsertRowsNode.java | 5 +-
.../planner/plan/node/write/InsertTabletNode.java | 352 +-
.../plan/node/write/RelationalInsertRowsNode.java | 5 +-
.../parameter/model/ModelInferenceDescriptor.java | 4 +-
.../relational/analyzer/StatementAnalyzer.java | 166 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 85 +-
.../AdditionalInformationSchemaProvider.java | 59 +
...ditionalInformationSchemaProviderRegistry.java} | 29 +-
.../relational/metadata/TableMetadataImpl.java | 11 +-
.../fetcher/TableHeaderSchemaValidator.java | 3 +-
.../distribute/TableDistributedPlanGenerator.java | 594 +-
...ithUncorrelatedScalarSubqueryReconstructor.java | 40 +-
.../TableDeviceAttributeCommitUpdateNode.java | 4 +-
.../DataNodeLocationSupplierFactory.java | 11 +
.../planner/optimizations/SortElimination.java | 65 +-
.../optimizations/TableFunctionOrdering.java | 79 +
.../TransformAggregationToStreamable.java | 5 +-
.../optimizations/TransformSortToStreamSort.java | 45 +-
.../security/TreeAccessCheckVisitor.java | 10 +
.../plan/relational/sql/ast/AstVisitor.java | 4 +
.../sql/ast/DefaultTraversalVisitor.java | 9 +
.../relational/sql/ast/SetColumnProperties.java | 140 +
.../plan/relational/sql/parser/AstBuilder.java | 51 +-
.../relational/sql/util/DataNodeSqlFormatter.java | 25 +
.../plan/scheduler/load/ChunkOffsetCalculator.java | 208 +
.../scheduler/load/DataPartitionBatchFetcher.java | 154 +
.../plan/scheduler/load/DataPartitionResolver.java | 100 +
.../plan/scheduler/load/DataPartitionRouter.java | 144 +
.../scheduler/load/LoadConsensusSubmitter.java | 262 +
.../plan/scheduler/load/LoadFallbackHandler.java | 239 +
.../scheduler/load/LoadTsFileDispatcherImpl.java | 553 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 1292 ++---
.../plan/scheduler/load/LocalLoadStrategy.java | 241 +
.../plan/scheduler/load/MemoryBoundedBuffer.java | 64 +
.../plan/scheduler/load/PieceDispatcher.java | 246 +
.../plan/scheduler/load/TsFileLoadStrategy.java | 46 +
.../plan/scheduler/load/TsFileSplitConsumer.java | 163 +
.../load/TwoPhaseConsensusLoadStrategy.java | 590 ++
.../queryengine/plan/statement/StatementType.java | 1 +
.../plan/statement/StatementVisitor.java | 5 +
.../plan/statement/crud/InsertBaseStatement.java | 46 +
.../plan/statement/crud/InsertRowStatement.java | 29 +-
.../plan/statement/crud/InsertRowsStatement.java | 17 +
.../plan/statement/crud/InsertTabletStatement.java | 69 +-
.../metadata/pipe/ShowPipeMemoryStatement.java | 58 +
...ializableRowRecordListBackedMultiColumnRow.java | 2 +-
.../dag/input/ConstantInputReader.java | 63 +-
.../unary/ArithmeticNegationTransformer.java | 41 +-
.../dag/transformer/unary/InTransformer.java | 131 +-
.../unary/scalar/CastFunctionTransformer.java | 530 +-
.../unary/scalar/DiffFunctionTransformer.java | 42 +-
.../unary/scalar/RoundFunctionTransformer.java | 45 +-
.../transformation/dag/util/TransformUtils.java | 119 +-
.../transformation/dag/util/TypeUtils.java | 61 +-
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 32 +-
.../schemaengine/metric/SchemaEngineMemMetric.java | 7 +-
.../schemaengine/metric/SchemaRegionMemMetric.java | 7 +-
.../rescon/MemSchemaEngineStatistics.java | 4 +
.../schemaengine/schemaregion/ISchemaRegion.java | 10 +-
.../attribute/DeviceAttributeStore.java | 75 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 101 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 42 +-
.../visitor/SchemaRegionPlanDeserializer.java | 18 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 29 +-
.../impl/mem/mnode/impl/BasicInternalMNode.java | 60 +-
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 12 +-
.../schemaengine/schemaregion/tag/TagManager.java | 55 +-
.../schemaregion/utils/MetaFormatUtils.java | 23 +
.../schemaregion/utils/ResourceByPathUtils.java | 5 +-
.../db/schemaengine/table/DataNodeTableCache.java | 35 +-
.../iotdb/db/schemaengine/table/ITableCache.java | 2 +
.../java/org/apache/iotdb/db/service/DataNode.java | 4 +
.../iotdb/db/service/DataNodeShutdownHook.java | 9 +-
.../iotdb/db/service/metrics/CacheMetrics.java | 17 +
.../db/service/metrics/DataNodeMetricsHelper.java | 1 +
.../metrics/IoTDBInternalLocalReporter.java | 1 +
.../iotdb/db/service/metrics/WritingMetrics.java | 80 +-
.../db/service/metrics/file/TsFileMetrics.java | 22 +
.../iotdb/db/storageengine/StorageEngine.java | 133 +-
.../db/storageengine/dataregion/DataRegion.java | 430 +-
.../dataregion/DataRegionMetrics.java | 49 +-
.../performer/impl/FastCompactionPerformer.java | 8 +-
.../impl/ReadChunkCompactionPerformer.java | 2 +-
.../impl/ReadPointCompactionPerformer.java | 2 +-
.../execute/utils/CompactionPathUtils.java | 12 +-
.../compaction/execute/utils/CompactionUtils.java | 15 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 45 +-
.../fast/FastAlignedSeriesCompactionExecutor.java | 6 +-
.../FastNonAlignedSeriesCompactionExecutor.java | 2 +-
.../executor/fast/SeriesCompactionExecutor.java | 5 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 45 +-
.../readchunk/SingleSeriesCompactionExecutor.java | 32 +-
.../utils/writer/AbstractCompactionWriter.java | 92 +-
.../schedule/CompactionScheduleTaskManager.java | 10 +-
.../selector/impl/SettleSelectorImpl.java | 12 +-
.../dataregion/flush/MemTableFlushTask.java | 22 +-
.../dataregion/memtable/AbstractMemTable.java | 94 +-
.../memtable/AbstractWritableMemChunk.java | 9 +-
.../memtable/AlignedReadOnlyMemChunk.java | 126 +-
.../memtable/AlignedWritableMemChunk.java | 493 +-
.../memtable/AlignedWritableMemChunkGroup.java | 37 +-
.../dataregion/memtable/IMemTable.java | 18 +-
.../dataregion/memtable/IWritableMemChunk.java | 14 +-
.../memtable/IWritableMemChunkGroup.java | 12 +-
.../dataregion/memtable/ReadOnlyMemChunk.java | 92 +-
.../dataregion/memtable/TsFileProcessor.java | 242 +-
.../memtable/TsFileProcessorInfoMetrics.java | 55 +-
.../dataregion/memtable/WritableMemChunk.java | 153 +-
.../dataregion/memtable/WritableMemChunkGroup.java | 26 +-
.../modification/DropTableModProgress.java | 65 +
.../dataregion/modification/TagPredicate.java | 24 +
.../dataregion/read/control/FileReaderManager.java | 698 ++-
.../read/reader/chunk/MemAlignedPageReader.java | 52 +-
.../read/reader/chunk/MemPageReader.java | 84 +-
.../dataregion/snapshot/SnapshotLoader.java | 23 +-
.../dataregion/snapshot/SnapshotTaker.java | 8 +-
.../dataregion/tsfile/TsFileLock.java | 27 +-
.../tsfile/timeindex/ArrayDeviceTimeIndex.java | 4 +-
.../tsfile/timeindex/PlainDeviceTimeIndex.java | 4 +-
.../dataregion/utils/DiskUsageStatisticUtil.java | 12 +-
.../utils/TreeDiskUsageStatisticUtil.java | 2 +-
.../dataregion/utils/TsFileResourceUtils.java | 11 +-
.../dataregion/wal/buffer/WALBuffer.java | 40 +-
.../dataregion/wal/buffer/WALEntry.java | 6 +
.../dataregion/wal/buffer/WALEntryType.java | 4 +-
.../dataregion/wal/buffer/WALInfoEntry.java | 6 +
.../wal/checkpoint/CheckpointManager.java | 4 +-
.../dataregion/wal/io/WALByteBufReader.java | 24 +-
.../dataregion/wal/io/WALFileVersion.java | 19 +
.../dataregion/wal/io/WALInputStream.java | 82 +-
.../dataregion/wal/io/WALMetaData.java | 98 +-
.../storageengine/dataregion/wal/io/WALReader.java | 21 +-
.../storageengine/dataregion/wal/io/WALWriter.java | 17 +-
.../dataregion/wal/node/IWALNode.java | 20 +
.../dataregion/wal/node/WALFakeNode.java | 6 +
.../storageengine/dataregion/wal/node/WALNode.java | 88 +-
.../dataregion/wal/recover/WALNodeRecoverTask.java | 54 +-
.../dataregion/wal/recover/WALRepairWriter.java | 125 +-
.../wal/recover/file/TsFilePlanRedoer.java | 13 +-
.../file/UnsealedTsFileRecoverPerformer.java | 20 +-
.../db/storageengine/load/LoadConsensusCompat.java | 49 +
.../db/storageengine/load/LoadStagingDirs.java | 209 +
.../db/storageengine/load/LoadTaskRetention.java | 185 +
.../db/storageengine/load/LoadTsFileCleaner.java | 438 ++
.../db/storageengine/load/LoadTsFileManager.java | 1233 ++---
.../db/storageengine/load/LoadTsFileProgress.java | 905 ++++
.../db/storageengine/load/LoadTsFileSnapshot.java | 481 ++
.../db/storageengine/load/TsFileWriterManager.java | 956 ++++
.../load/memory/LoadTsFileAbstractMemoryBlock.java | 8 +
.../load/memory/LoadTsFileMemoryBlock.java | 20 +-
.../load/memory/LoadTsFileParserMemoryManager.java | 5 +-
.../load/memory/LoadTsFileSubMemoryBlock.java | 101 +
.../load/metrics/ActiveLoadingFilesMetricsSet.java | 6 +
.../ActiveLoadingFilesNumberMetricsSet.java | 16 +-
.../load/metrics/LoadPointCountMetrics.java | 86 +
.../load/metrics/LoadTsFileMemMetricSet.java | 19 +-
.../load/splitter/AlignedChunkData.java | 684 ++-
.../splitter/BatchedAlignedValueChunkData.java | 241 +-
.../db/storageengine/load/splitter/ChunkData.java | 150 +-
.../load/splitter/ChunkPayloadRef.java | 205 +
.../splitter/ChunkPayloadUnavailableException.java | 31 +-
.../storageengine/load/splitter/DeletionData.java | 11 +
.../load/splitter/NonAlignedChunkData.java | 429 +-
.../load/splitter/SerializedSizes.java | 78 +
.../db/storageengine/load/splitter/TsFileData.java | 28 +-
.../load/splitter/TsFileSplitter.java | 30 +-
.../iotdb/db/storageengine/load/util/LoadUtil.java | 9 +-
.../rescon/memory/PrimitiveArrayManager.java | 89 +-
.../agent/SubscriptionBrokerAgent.java | 30 +-
.../agent/SubscriptionConsumerAgent.java | 211 +-
.../agent/SubscriptionReceiverAgent.java | 12 +
.../agent/SubscriptionRuntimeAgent.java | 2 +
.../subscription/agent/SubscriptionTopicAgent.java | 52 +
.../broker/ConsensusSubscriptionBroker.java | 78 +-
.../subscription/broker/ISubscriptionBroker.java | 3 +
.../db/subscription/broker/SubscriptionBroker.java | 14 +-
.../broker/SubscriptionPrefetchingQueue.java | 118 +-
.../broker/SubscriptionPrefetchingQueueStates.java | 28 +-
.../TsFileDeduplicationBlockingPendingQueue.java | 11 +-
.../consensus/ConsensusLogToTabletConverter.java | 126 +-
.../consensus/ConsensusPrefetchingQueue.java | 2164 +++++++-
.../ConsensusSubscriptionCommitManager.java | 169 +-
.../ConsensusSubscriptionSetupHandler.java | 340 +-
.../ConsensusSubscriptionWalRetention.java | 163 +
.../broker/consensus/ProgressWALIterator.java | 458 +-
.../consensus/SubscriptionQueueTimeTracker.java | 119 +
.../columnfilter/TreeViewTabletProjector.java | 1 -
.../db/subscription/event/SubscriptionEvent.java | 84 +-
.../batch/SubscriptionPipeTabletEventBatch.java | 21 +-
.../cache/CachedSubscriptionPollResponse.java | 1 +
.../event/cache/SubscriptionPollResponseCache.java | 32 +-
.../response/SubscriptionEventSingleResponse.java | 15 +-
.../response/SubscriptionEventTabletResponse.java | 8 +-
.../response/SubscriptionEventTsFileResponse.java | 8 +-
...nsensusSubscriptionPrefetchingQueueMetrics.java | 182 +-
.../subscription/metric/SubscriptionMetrics.java | 34 +
.../SubscriptionPrefetchingQueueMetrics.java | 55 +-
.../receiver/SubscriptionReceiver.java | 5 +
.../receiver/SubscriptionReceiverV1.java | 125 +-
.../resource/SubscriptionMemoryManager.java | 368 +-
.../ConsensusSubscriptionPrefetchExecutor.java | 10 +
.../task/subtask/ConsensusPrefetchSubtask.java | 12 +
.../java/org/apache/iotdb/db/tools/ImportWAL.java | 1781 ++++++
.../iotdb/db/tools/TableWALDeleteConverter.java | 226 +
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 45 +-
.../org/apache/iotdb/db/tools/TsFileSplitTool.java | 33 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 157 +-
.../iotdb/db/utils/EncodingInferenceUtils.java | 30 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 9 +
.../apache/iotdb/db/utils/ModificationUtils.java | 20 +-
.../org/apache/iotdb/db/utils/ObjectWriter.java | 2 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 446 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 166 +-
.../org/apache/iotdb/db/utils/TabletDecoder.java | 80 +-
.../apache/iotdb/db/utils/TimeValuePairUtils.java | 67 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 31 +-
.../org/apache/iotdb/db/utils/TypeServices.java | 4524 ++++++++++++++++
.../db/utils/datastructure/AlignedTVList.java | 719 +--
.../iotdb/db/utils/datastructure/BinaryTVList.java | 7 +-
.../db/utils/datastructure/BooleanTVList.java | 7 +-
.../iotdb/db/utils/datastructure/DoubleTVList.java | 8 +-
.../iotdb/db/utils/datastructure/FloatTVList.java | 6 +-
.../iotdb/db/utils/datastructure/IntTVList.java | 7 +-
.../iotdb/db/utils/datastructure/LongTVList.java | 7 +-
.../MergeSortMultiAlignedTVListIterator.java | 62 +-
.../MergeSortMultiTVListIterator.java | 49 +-
.../datastructure/MultiAlignedTVListIterator.java | 71 +-
.../utils/datastructure/MultiTVListIterator.java | 129 +-
.../iotdb/db/utils/datastructure/TVList.java | 334 +-
.../db/utils/windowing/window/WindowImpl.java | 75 +-
.../write/TsFilePrecalculatedChunkWriter.java | 553 ++
.../org/apache/iotdb/db/auth/entity/RoleTest.java | 84 -
.../org/apache/iotdb/db/auth/entity/UserTest.java | 53 -
.../LoadTsFileSplitPartitionMaxSizeConfigTest.java | 59 +
.../dataregion/DataRegionStateMachineTest.java | 53 +-
.../dataregion/IoTConsensusShutdownTest.java | 894 +++
.../schemaRegion/SchemaRegionAliasAndTagTest.java | 62 +
.../schemaRegion/SchemaRegionManagementTest.java | 38 +-
.../SchemaRegionSimpleRecoverTest.java | 76 +
.../task/connection/PipeEventCollectorTest.java | 4 +-
.../PipeProcessorSubtaskExecutionGuardTest.java | 10 +-
.../processor/PipeProcessorSubtaskTest.java | 87 +
.../processor/PipeProcessorSubtaskWorkerTest.java | 162 +
.../subtask/sink/PipeSinkSubtaskManagerTest.java | 3 +-
.../pipe/event/PipeTabletInsertionEventTest.java | 36 +-
.../common/heartbeat/PipeHeartbeatEventTest.java | 92 +
.../db/pipe/event/common/row/PipeRowTest.java | 115 +
.../db/pipe/metric/PipeMetricsRestartTest.java | 426 ++
.../PipeDataNodeCompletionOperatorTest.java | 248 +
.../PipeDataNodeSinglePipeMetricsTest.java | 221 +
.../PipeSchemaRegionListenerMetricsTest.java | 116 +
.../metric/sink/PipeDataRegionSinkMetricsTest.java | 98 +
.../pattern/CachedSchemaPatternMatcherTest.java | 84 +
.../aggregate/TimeSeriesRuntimeStateTest.java | 76 +
.../protocol/airgap/IoTDBAirGapReceiverTest.java | 63 +
.../protocol/thrift/IoTDBDataNodeReceiverTest.java | 70 +
.../memory/PipeMemoryManagerResizeTest.java | 332 +-
.../resource/memory/PipeMemoryManagerTest.java | 30 +
.../apache/iotdb/db/pipe/sink/PipeSinkTest.java | 93 -
.../airgap/IoTDBDataRegionAirGapSinkTest.java | 34 +-
.../thrift/async/IoTDBDataRegionAsyncSinkTest.java | 49 +
...peTransferTabletInsertNodeEventHandlerTest.java | 105 +
.../PipeTransferTsFileHandlerCleanupTest.java | 56 +
.../sink/util/cacher/LeaderCacheUtilsTest.java | 89 +
.../db/pipe/source/PipeRealtimeExtractTest.java | 1292 ++++-
.../realtime/PipeRealtimeDataRegionSourceTest.java | 25 +
.../assigner/PipeDataRegionAssignerTest.java | 88 +
.../PipeInsertionDataNodeListenerTest.java | 66 +
.../db/protocol/session/QueryOwnershipTest.java | 343 ++
.../DataNodeInternalRPCServiceImplDiskTest.java | 43 +-
...eInternalRPCServiceImplSetSystemStatusTest.java | 91 +
.../queryengine/execution/ConfigExecutionTest.java | 27 +
.../SinkChannelFailurePropagationTest.java | 12 +-
.../execution/exchange/SourceHandleTest.java | 80 +
.../executor/RegionWriteExecutorTest.java | 268 +
.../fragment/FileReaderReferenceLifecycleTest.java | 189 +
.../fragment/FragmentInstanceExecutionTest.java | 10 +-
.../RegionQueryInitializationLockTest.java | 280 +
.../fragment/RegionScanTimeSliceTest.java | 96 +
.../execution/memory/MemoryPoolTest.java | 128 +
.../operator/LastQueryCollectOperatorTest.java | 140 +
.../process/TableStreamSortOperatorTest.java | 63 +
.../process/fill/GroupedFillOperatorTest.java | 174 +
.../process/window/TopKRankingOperatorTest.java | 75 +-
.../source/DeviceBlackListConstructorTest.java | 120 +
.../source/SeriesScanUtilCancellationTest.java | 172 +-
.../schedule/DefaultDriverSchedulerTest.java | 81 +
.../queryengine/plan/analyze/AnalyzeUtilsTest.java | 174 +
.../plan/analyze/cache/PartitionCacheTest.java | 12 +
.../metadata/ShowClusterDetailsTaskTest.java | 172 +
.../config/metadata/ShowClusterTaskTest.java | 168 +
.../config/metadata/ShowConfigNodesTaskTest.java | 121 +
.../config/metadata/ShowDataNodesTaskTest.java | 114 +
.../relational/ShowCreateViewTaskTest.java | 91 +
.../ConvertPredicateToFilterVisitorTest.java | 104 +
.../plan/planner/LastQueryCacheTest.java | 236 +
.../plan/planner/node/load/LoadTsFileNodeTest.java | 4 +-
.../node/write/InsertTabletNodeSerdeTest.java | 71 +
.../node/load/LoadTsFileConsensusNodeTest.java | 277 +
.../node/write/RelationalDeleteDataNodeTest.java | 22 +
.../plan/relational/analyzer/AnalyzerTest.java | 147 +
.../analyzer/EvaluateEmptyIntersectTest.java | 25 +-
.../analyzer/RemoveEmptyExceptBranchesTest.java | 82 +-
.../relational/analyzer/UnionOptimizeTest.java | 28 +-
.../plan/relational/planner/PlanTester.java | 6 +-
.../planner/WindowFunctionOptimizationTest.java | 12 +-
.../OrderingPropertyPropagationTest.java | 481 ++
.../optimizations/TableFunctionSortTest.java | 263 +
.../sql/parser/CreateViewPrefixPathTest.java | 47 +
.../relational/sql/parser/ShowPipeMemoryTest.java | 63 +
.../scheduler/load/DataPartitionRouterTest.java | 171 +
.../scheduler/load/LoadConsensusSubmitterTest.java | 249 +
.../load/LoadTsFileDispatcherImplTest.java | 4 +-
.../scheduler/load/LoadTsFileSchedulerTest.java | 148 +-
.../TwoPhaseConsensusLoadStrategyAbortTest.java | 469 ++
.../crud/InsertStatementPartialInsertTest.java | 28 +
.../dag/adapter/RowGetDoubleTest.java | 98 +
.../dag/input/ConstantInputReaderTest.java | 78 +
.../dag/util/TransformUtilsTest.java | 117 +
.../iotdb/db/schemaengine/SchemaEngineTest.java | 57 +
.../metric/SchemaMemMetricTableTest.java | 133 +
.../attribute/DeviceAttributeStoreTest.java | 129 +
.../mtree/impl/mem/MTreeBelowSGMemoryImplTest.java | 143 +
.../impl/pbtree/MTreeBelowSGCachedImplTest.java | 18 +-
.../tag/TagManagerPerformanceTest.java | 258 +
.../schemaregion/tag/TagManagerTest.java | 64 +
.../schemaengine/table/DataNodeTableCacheTest.java | 114 +
.../metrics/DataNodeMetricsRestartTest.java | 290 +
.../db/service/metrics/file/TsFileMetricsTest.java | 148 +
.../buffer/TimeSeriesMetadataCacheTest.java | 4 +-
.../storageengine/dataregion/DataRegionTest.java | 357 +-
.../dataregion/DatabaseMemMetricsTest.java | 144 +
.../compaction/AbstractCompactionTest.java | 121 +-
.../CompactionDataTypeAlterTableTest.java | 37 +-
.../utils/writer/AbstractCompactionWriterTest.java | 125 +-
.../InnerSeqCompactionWithFastPerformerTest.java | 3 +-
...nerSeqCompactionWithReadChunkPerformerTest.java | 7 +-
.../AbstractTableModelCompactionTest.java | 84 +
.../tablemodel/CompactionWithAllNullRowsTest.java | 3 +-
.../TableModelCompactionWithTTLTest.java | 11 +-
.../TableModelFastCompactionPerformerTest.java | 61 +-
...TableModelReadChunkCompactionPerformerTest.java | 155 +-
...TableModelReadPointCompactionPerformerTest.java | 61 +-
.../compaction/utils/CompactionCheckerUtils.java | 9 +-
.../compaction/utils/CompactionUtilsTest.java | 44 +-
...ignedBitmapMemoryAccountingPerformanceTest.java | 7 +-
...gnedFlushDuplicateTimeCheckPerformanceTest.java | 238 +
.../memtable/AlignedWritableMemChunkTest.java | 216 +
.../memtable/MemChunkDeserializeTest.java | 12 +-
.../dataregion/memtable/MemTableFlushTaskTest.java | 107 +-
.../dataregion/memtable/PrimitiveMemTableTest.java | 50 +-
.../TabletDeviceRangeReusePerformanceTest.java | 283 +
.../dataregion/memtable/TsFileProcessorTest.java | 331 ++
...FileTableSchemaRegistrationPerformanceTest.java | 230 +
.../memtable/WritableMemChunkRegionScanTest.java | 9 +-
.../control/FileReaderManagerConcurrencyTest.java | 871 +++
.../read/reader/common/AscFakedSeriesReader.java | 8 +-
.../read/reader/common/DescFakedSeriesReader.java | 8 +-
.../dataregion/snapshot/IoTDBSnapshotTest.java | 10 +-
.../dataregion/tsfile/TsFileLockTest.java | 108 +
.../dataregion/utils/TableDiskUsageTest.java | 8 +
.../dataregion/wal/buffer/WALBufferCommonTest.java | 27 +
.../wal/buffer/WALBufferRollRecoveryTest.java | 4 +-
.../dataregion/wal/io/WALFileTest.java | 274 +-
.../wal/recover/WALRepairWriterTest.java | 140 +-
.../wal/recover/file/TsFilePlanRedoerTest.java | 52 +
.../storageengine/load/LoadTsFileCleanerTest.java | 326 ++
.../load/LoadTsFileManagerDeletionTest.java | 445 ++
.../load/LoadTsFileManagerSplitCoverageTest.java | 1839 +++++++
.../storageengine/load/LoadTsFileManagerTest.java | 1150 ++++
.../storageengine/load/LoadTsFileProgressTest.java | 192 +
.../storageengine/load/LoadTsFileResumeTest.java | 378 ++
.../storageengine/load/LoadTsFileSnapshotTest.java | 544 ++
.../load/LoadTsFileTableSchemaTest.java | 181 +
.../load/memory/LoadTsFileMemoryManagerTest.java | 2 +-
.../load/memory/LoadTsFileSubMemoryBlockTest.java | 113 +
.../load/splitter/ChunkDataDirectWriteTest.java | 675 ++-
.../load/splitter/SerializedSizesTest.java | 70 +
.../db/storageengine/load/util/LoadUtilTest.java | 19 +
.../rescon/disk/FolderManagerTest.java | 57 +-
.../agent/SubscriptionConsumerAgentTest.java | 114 +
.../agent/SubscriptionReceiverAgentTest.java | 51 +
.../agent/SubscriptionTopicAgentTest.java | 116 +
...onsensusSubscriptionBrokerPayloadLimitTest.java | 67 +
.../SubscriptionBrokerAgentPayloadLimitTest.java | 14 +
...riptionPrefetchingQueueRecycleIntervalTest.java | 160 +
...sFileDeduplicationBlockingPendingQueueTest.java | 68 +
.../ConsensusLogToTabletConverterTest.java | 140 +
...onsensusPrefetchingQueueDataNodeMemoryTest.java | 584 +-
.../ConsensusPrefetchingQueueDeliveryTest.java | 786 +++
...onsensusPrefetchingQueueInitializationTest.java | 254 +
.../ConsensusPrefetchingQueueSeekTest.java | 272 +
.../consensus/ConsensusPrefetchingQueueTest.java | 1738 +++++-
...nsensusPrefetchingQueueWalBackpressureTest.java | 736 ++-
...onsensusPrefetchingQueueWriterOrderingTest.java | 521 ++
.../ConsensusSubscriptionCommitStateTest.java | 55 +
.../ConsensusSubscriptionSetupHandlerTest.java | 47 +
.../ConsensusSubscriptionWalRetentionTest.java | 102 +
.../broker/consensus/ProgressWALIteratorTest.java | 576 +-
.../SubscriptionWalPrefetchPerformanceTest.java | 380 ++
.../SubscriptionPipeTabletEventBatchTest.java | 256 +
.../cache/SubscriptionPollResponseCacheTest.java | 60 +
...susSubscriptionPrefetchingQueueMetricsTest.java | 88 +
.../metric/SubscriptionMetricsRestartTest.java | 275 +
.../receiver/SubscriptionReceiverV1Test.java | 155 +-
.../resource/SubscriptionMemoryManagerTest.java | 122 +
.../org/apache/iotdb/db/tools/ImportWALTest.java | 2115 ++++++++
.../db/tools/TableWALDeleteConverterTest.java | 318 ++
.../apache/iotdb/db/utils/ObjectWriterTest.java | 84 +
.../iotdb/db/utils/QueryDataSetUtilsTest.java | 109 +-
.../apache/iotdb/db/utils/SerializeUtilsTest.java | 132 +-
.../utils/TSDataTypeSwitchArchitectureTest.java} | 24 +-
.../iotdb/db/utils/TSDataTypeSwitchRule.java | 182 +
.../iotdb/db/utils/TSDataTypeSwitchRuleTest.java | 186 +
.../apache/iotdb/db/utils/TypeServicesTest.java | 305 ++
.../db/utils/datastructure/AlignedTVListTest.java | 156 +
.../src/test/resources/iotdb-system.properties | 3 +
.../iotdb/metrics/metricsets/jvm/JvmGcMetrics.java | 86 +-
.../metrics/metricsets/system/SystemMetrics.java | 13 +-
.../reporter/iotdb/IoTDBSessionReporter.java | 1 +
.../resources/conf/edge/iotdb-system.properties | 1 +
.../conf/iotdb-system.properties.template | 131 +-
.../apache/iotdb/commons/i18n/CommonMessages.java | 6 +
.../apache/iotdb/commons/i18n/LBACMessages.java | 32 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 2 -
.../apache/iotdb/commons/i18n/ServiceMessages.java | 2 +
.../apache/iotdb/commons/i18n/CommonMessages.java | 6 +
.../apache/iotdb/commons/i18n/LBACMessages.java | 32 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 2 -
.../apache/iotdb/commons/i18n/ServiceMessages.java | 2 +
.../org/apache/iotdb/commons/auth/entity/Role.java | 66 +-
.../org/apache/iotdb/commons/auth/entity/User.java | 64 -
.../commons/auth/role/LocalFileRoleAccessor.java | 71 +-
.../commons/auth/user/LocalFileUserAccessor.java | 6 +-
.../commons/client/AbstractConfigNodeClient.java | 18 +-
.../client/property/ClientPoolProperty.java | 5 +-
.../apache/iotdb/commons/cluster/NodeStatus.java | 102 +-
.../apache/iotdb/commons/cluster/RegionStatus.java | 5 +
.../commons/concurrent/ThreadPoolMetrics.java | 74 +-
.../WrappedScheduledExecutorService.java | 4 +-
.../WrappedSingleThreadExecutorService.java | 4 +-
.../WrappedSingleThreadScheduledExecutor.java | 4 +-
.../threadpool/WrappedThreadPoolExecutor.java | 4 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 63 +-
.../iotdb/commons/conf/CommonDescriptor.java | 16 +-
.../consensus/index/impl/StateProgressIndex.java | 5 +-
.../apache/iotdb/commons/disk/FolderManager.java | 14 +-
.../commons/disk/strategy/DirectoryStrategy.java | 4 +-
.../strategy/RandomOnDiskUsableSpaceStrategy.java | 2 +-
.../commons/enums/HandleSystemErrorStrategy.java | 6 +-
.../exception/table/TableInDeletionException.java | 47 +-
.../commons/lbac/LBACAccessDeniedException.java | 56 +
.../iotdb/commons/lbac/LBACRuntimeException.java | 26 +-
.../apache/iotdb/commons/lbac/RequiredLabels.java | 79 +
.../commons/lbac/operation/LabelAccessType.java | 9 +-
.../iotdb/commons/model/ModelHyperparameter.java | 2 +-
.../org/apache/iotdb/commons/path/AlignedPath.java | 4 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 2 +-
.../apache/iotdb/commons/path/PathPatternNode.java | 35 +-
.../apache/iotdb/commons/path/PathPatternUtil.java | 6 +-
.../agent/plugin/builtin/BuiltinPipePlugin.java | 53 +-
.../pipe/agent/task/meta/PipeStaticMeta.java | 33 +
.../commons/pipe/agent/task/meta/PipeTaskMeta.java | 17 +-
.../task/progress/PipeEventCommitManager.java | 15 +
.../pipe/config/constant/PipeSinkConstant.java | 7 +-
.../pipe/config/constant/PipeSourceConstant.java | 5 +
.../iotdb/commons/pipe/event/EnrichedEvent.java | 14 +
.../commons/pipe/event/ProgressReportEvent.java | 5 +
.../pipe/metric/PipeEventCommitMetrics.java | 20 +-
.../IoTConsensusV2TransferFileSealWithModReq.java | 10 +-
.../thrift/request/PipeTransferFileSealReqV2.java | 8 +-
.../thrift/request/PipeTransferHandshakeV2Req.java | 4 +-
.../commons/queryengine/common/SessionInfo.java | 23 +-
.../execution/MemoryEstimationHelper.java | 13 +
.../plan/planner/plan/node/PlanNodeType.java | 1 +
.../function/TableBuiltinTableFunction.java | 34 +-
.../plan/relational/metadata/ColumnSchema.java | 13 +-
.../planner/rowpattern/LogicalIndexPointer.java | 4 +-
.../plan/relational/sql/ast/InListExpression.java | 2 +-
.../plan/relational/type/InternalTypeManager.java | 67 +-
.../iotdb/commons/request/IConsensusRequest.java | 13 +
.../schema/column/ColumnHeaderConstant.java | 21 +
.../multichildren/AbstractMultiChildrenFilter.java | 2 +-
.../schema/filter/impl/values/InFilter.java | 4 +-
.../table/AlterOrDropTableOperationType.java | 5 +-
.../commons/schema/table/InformationSchema.java | 104 +
.../apache/iotdb/commons/schema/table/TsTable.java | 2 +
.../multi/FunctionViewExpression.java | 4 +-
.../service/metric/JvmGcMonitorMetrics.java | 38 +-
.../commons/service/metric/MetricService.java | 13 +-
.../iotdb/commons/service/metric/enums/Metric.java | 32 +
.../iotdb/commons/service/metric/enums/Tag.java | 1 +
.../meta/consumer/CommitProgressKeeper.java | 69 +-
.../meta/consumer/ConsumerGroupMeta.java | 37 +-
.../iotdb/commons/udf/builtin/TypeServices.java | 671 +++
.../apache/iotdb/commons/udf/builtin/UDTFAbs.java | 106 +-
.../iotdb/commons/udf/builtin/UDTFBottomK.java | 105 +-
.../commons/udf/builtin/UDTFChangePoints.java | 178 +-
.../commons/udf/builtin/UDTFCommonDerivative.java | 41 +-
.../udf/builtin/UDTFCommonValueDifference.java | 42 +-
.../iotdb/commons/udf/builtin/UDTFConst.java | 267 +-
.../udf/builtin/UDTFContinuouslySatisfy.java | 79 +-
.../iotdb/commons/udf/builtin/UDTFDerivative.java | 11 +
.../udf/builtin/UDTFEqualSizeBucketAggSample.java | 53 +-
.../udf/builtin/UDTFEqualSizeBucketM4Sample.java | 39 +-
.../builtin/UDTFEqualSizeBucketOutlierSample.java | 53 +-
.../builtin/UDTFEqualSizeBucketRandomSample.java | 40 +-
.../iotdb/commons/udf/builtin/UDTFInRange.java | 162 +-
.../apache/iotdb/commons/udf/builtin/UDTFM4.java | 36 +-
.../apache/iotdb/commons/udf/builtin/UDTFMath.java | 149 +-
.../udf/builtin/UDTFNonNegativeDerivative.java | 48 +-
.../builtin/UDTFNonNegativeValueDifference.java | 49 +-
.../iotdb/commons/udf/builtin/UDTFOnOff.java | 153 +-
.../iotdb/commons/udf/builtin/UDTFSelectK.java | 136 +-
.../apache/iotdb/commons/udf/builtin/UDTFTopK.java | 65 +-
.../commons/udf/builtin/UDTFValueDifference.java | 12 +
.../iotdb/commons/udf/builtin/UDTFValueTrend.java | 42 +-
.../iotdb/commons/udf/utils/MasterRepairUtil.java | 32 +-
.../commons/udf/utils/UDFDataTypeTransformer.java | 107 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 2 +-
.../commons/utils/BasicStructureSerDeUtil.java | 15 +-
.../apache/iotdb/commons/utils/SerializeUtils.java | 371 +-
.../AbstractConfigNodeClientConnectionTest.java | 340 ++
.../client/AbstractConfigNodeClientTest.java | 312 ++
.../iotdb/commons/cluster/NodeStatusTest.java | 91 +
.../commons/concurrent/ThreadPoolMetricsTest.java | 157 +
.../iotdb/commons/conf/CommonConfigTest.java | 230 +-
...ubscriptionCacheMemoryUsagePercentageTest.java} | 30 +-
.../iotdb/commons/path/PathPatternNodeTest.java | 71 +
.../pipe/metric/PipeEventCommitMetricsTest.java | 99 +
.../iotdb/commons/pipe/task/PipeMetaDeSerTest.java | 74 +
.../relational/type/InternalTypeManagerTest.java | 61 +
.../service/metric/JvmGcMonitorMetricsTest.java | 72 +
.../service/metric/MetricServiceRestartTest.java | 218 +
.../consumer/ConsumerGroupDeSerTest.java | 39 +
.../meta/consumer/CommitProgressKeeperTest.java | 45 +
.../commons/udf/utils/MasterRepairUtilTest.java | 94 +
.../udf/utils/UDFDataTypeTransformerTest.java | 71 +
.../iotdb/rpc/ClientPoolIdleEvictionTest.java | 326 ++
.../db/relational/grammar/sql/RelationalSql.g4 | 8 +-
.../src/main/thrift/confignode.thrift | 38 +-
.../src/main/thrift/datanode.thrift | 19 +
.../opc-ua-sink-example}/pom.xml | 21 +-
.../java/org/apache/iotdb/opcua/ClientExample.java | 0
.../apache/iotdb/opcua/ClientExampleRunner.java | 0
.../java/org/apache/iotdb/opcua/ClientTest.java | 0
.../iotdb/opcua/IoTDBKeyStoreLoaderClient.java | 0
library-pipe/opc-ua-sink/README.md | 82 +
.../consensus => library-pipe/opc-ua-sink}/pom.xml | 169 +-
.../iotdb/pipe/plugin/sink}/opcua/OpcUaSink.java | 91 +-
.../plugin/sink}/opcua/client/ClientRunner.java | 2 +-
.../opcua/client/IoTDBKeyStoreLoaderClient.java | 2 +-
.../sink}/opcua/client/IoTDBOpcUaClient.java | 10 +-
.../sink}/opcua/server/OpcUaKeyStoreLoader.java | 2 +-
.../plugin/sink}/opcua/server/OpcUaNameSpace.java | 143 +-
.../sink}/opcua/server/OpcUaServerBuilder.java | 2 +-
.../sink/opcua/server/OpcUaTypeServices.java | 145 +
.../pipe/plugin/sink/opcua/OpcUaSinkTest.java | 242 +
.../sink}/opcua/OpcUaSinkTsFileMetadataTest.java | 2 +-
.../opcua/OpcUaSinkTsFilePerformanceTest.java | 6 +-
.../sink}/opcua/client/ClientRunnerTest.java | 2 +-
.../sink}/opcua/client/IoTDBOpcUaClientTest.java | 9 +-
.../opcua/server/OpcUaNameSpaceMetadataTest.java | 9 +-
.../sink}/opcua/server/OpcUaServerBuilderTest.java | 2 +-
.../server/OpcUaTcpNoneCompatibilityTest.java | 2 +-
.../sink/opcua/server/OpcUaTypeServicesTest.java | 29 +-
library-pipe/pom.xml | 68 +
library-udf/pom.xml | 5 +
.../iotdb/library/i18n/LibraryUdfMessages.java | 15 +
.../iotdb/library/i18n/LibraryUdfMessages.java | 12 +
.../apache/iotdb/library/anomaly/UDTFKSigma.java | 62 +-
.../apache/iotdb/library/anomaly/UDTFRange.java | 53 +-
.../iotdb/library/anomaly/UDTFTwoSidedFilter.java | 38 +-
.../iotdb/library/dprofile/UDAFPercentile.java | 218 +-
.../iotdb/library/dprofile/UDAFQuantile.java | 137 +-
.../apache/iotdb/library/dprofile/UDAFSpread.java | 99 +-
.../iotdb/library/dprofile/UDTFDistinct.java | 299 +-
.../apache/iotdb/library/dprofile/UDTFSample.java | 50 +-
.../apache/iotdb/library/dprofile/UDTFSegment.java | 2 +-
.../dprofile/util/ExactOrderStatistics.java | 210 +-
.../iotdb/library/drepair/UDTFTimestampRepair.java | 36 +-
.../iotdb/library/drepair/UDTFValueFill.java | 36 +-
.../iotdb/library/drepair/UDTFValueRepair.java | 37 +-
.../library/frequency/UDFEnvelopeAnalysis.java | 45 +-
.../iotdb/library/match/PatternExecutor.java | 6 +-
.../apache/iotdb/library/match/UDAFDTWMatch.java | 26 +-
.../iotdb/library/match/UDAFPatternMatch.java | 25 +-
.../apache/iotdb/library/util/TypeServices.java | 317 ++
.../java/org/apache/iotdb/library/util/Util.java | 79 +-
.../org/apache/iotdb/library/UDFEnvelopeTest.java | 23 +
licenses/Bouncy Castle Licence | 17 +
pom.xml | 64 +-
scripts/sbin/windows/stop-datanode.bat | 5 +-
scripts/tools/README.md | 156 +
.../tools/import-wal.sh | 65 +-
scripts/tools/windows/import-wal.bat | 43 +
1288 files changed, 108927 insertions(+), 32313 deletions(-)
create mode 100644 architecture-test/pom.xml
copy iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/cache/ConsensusGroupCacheTest.java => architecture-test/src/test/java/org/apache/iotdb/db/utils/TSDataTypeSwitchArchitectureTest.java (56%)
create mode 100644 architecture-test/src/test/java/org/apache/iotdb/db/utils/TSDataTypeSwitchRule.java
create mode 100644 architecture-test/src/test/java/org/apache/iotdb/db/utils/TSDataTypeSwitchRuleTest.java
create mode 100644 distribution/src/assembly/library-pipe.xml
create mode 100644 external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/utils/TypeServices.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/cluster/IoTDBNodeStatusFailoverIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/cluster/IoTDBNodeStatusPersistenceIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/cluster/NodeStatusTestAgent.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBProactiveRegionGroupDistributionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBProactiveRegionGroupExtensionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/removeconfignode/IoTDBRemoveConfigNodeSchemaPartitionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBLoadTsFileClusterIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBRecreatedTimeseriesCompactionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBShowPipeMemoryIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/last/IoTDBLastQueryVirtualRegionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/utils/IoTDBTestUtilsIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBDeletionTableClusterIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBOrderingPropertyIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBDropTableModProgressIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/tablemodel/IoTDBConsensusSubscriptionUnsubscribeTableIT.java
create mode 100644 iotdb-client/client-py/tests/unit/test_session_query_ids.py
create mode 100644 iotdb-client/isession/src/main/java/org/apache/iotdb/isession/TypeServices.java
delete mode 100644 iotdb-client/jdbc/osgi.bnd
delete mode 100644 iotdb-client/jdbc/src/main/feature/feature.xml
delete mode 100644 iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/Activator.java
delete mode 100644 iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBDataSourceFactory.java
create mode 100644 iotdb-client/jdbc/src/main/resources/META-INF/services/java.sql.Driver
copy iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/cache/ConsensusGroupCacheTest.java => iotdb-client/jdbc/src/test/java/org/apache/iotdb/jdbc/DriverServiceRegistrationTest.java (51%)
create mode 100644 iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/TypeServices.java
create mode 100644 iotdb-client/service-rpc/src/test/java/org/apache/iotdb/rpc/IoTDBJDBCDataSetTest.java
create mode 100644 iotdb-client/service-rpc/src/test/java/org/apache/iotdb/rpc/TElasticFramedTransportReadTest.java
create mode 100644 iotdb-client/session/src/main/java/org/apache/iotdb/session/util/SessionTypeServices.java
create mode 100644 iotdb-client/session/src/test/java/org/apache/iotdb/session/BrokenSessionConnectionTest.java
create mode 100644 iotdb-client/subscription/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeSliceReq.java
create mode 100644 iotdb-client/subscription/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeSliceReqBuilder.java
create mode 100644 iotdb-client/subscription/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeSliceReqHandler.java
create mode 100644 iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/payload/TypeServices.java
create mode 100644 iotdb-client/subscription/src/test/java/org/apache/iotdb/rpc/subscription/payload/request/PipeSubscribeSliceReqTest.java
create mode 100644 iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/base/SubscriptionConsumerHeartbeatIsolationTest.java
create mode 100644 iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/base/SubscriptionProviderSlicingTest.java
create mode 100644 iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/payload/TypeServicesTest.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/utils/TypeServices.java
create mode 100644 iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/LastDescendingInputTest.java
create mode 100644 iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/NumericBatchAggregationTest.java
create mode 100644 iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/NumericMomentBatchTest.java
create mode 100644 iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/SumAccumulatorTest.java
create mode 100644 iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/VarianceAccumulatorTest.java
create mode 100644 iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/GroupedApproxCountDistinctMaskTest.java
create mode 100644 iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/RateBatchInputTest.java
create mode 100644 iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/transformation/dag/column/unary/scalar/NumericCastBatchTest.java
create mode 100644 iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/utils/TypeServicesTest.java
create mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/GetDropTableModProgressRPCHandler.java
create mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/confignode/UpdateNodeStatusPlan.java
create mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/table/SetTableColumnPropertiesPlan.java
copy iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/{SetTablePropertiesProcedure.java => AbstractSetPropertiesProcedure.java} (76%)
create mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/SetTableColumnPropertiesProcedure.java
create mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/client/async/CnToDnInternalServiceAsyncRequestManagerTest.java
create mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/client/async/handlers/heartbeat/DataNodeHeartbeatHandlerTest.java
create mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/conf/RegionGroupExtensionPolicyConfigTest.java
create mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/ConfigManagerRegionGroupPolicyReloadTest.java
create mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/ConfigManagerShutdownReportTest.java
delete mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/ProcedureManagerReconstructRegionTest.java
create mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/ProcedureManagerRegionOperationTest.java
create mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/ProcedureManagerTableTaskTest.java
create mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/RetryFailedTasksThreadTest.java
create mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/RegionBalancerTest.java
create mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/partition/DataPartitionPolicyTableProactiveTest.java
create mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/cache/LoadCacheNodeStatusTest.java
create mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/cache/LoadCachePersistedNodeStatusTest.java
create mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/node/NodeManagerStatusReasonTest.java
create mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/partition/PartitionManagerProactiveExtensionTest.java
create mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/metric/PipeConfigNodeMetricsRestartTest.java
create mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/subscription/runtime/SubscriptionRuntimeCoordinatorTest.java
create mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/env/ConfigNodeProcedureEnvTest.java
create mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/env/RegionMaintainHandlerTest.java
create mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/node/RemoveDataNodePersistenceTest.java
create mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/schema/SchemaUtilsTest.java
create mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/service/ConfigNodeShutdownHookTest.java
create mode 100644 iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/subscription/SubscriptionQueueAdmission.java
create mode 100644 iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/subscription/SubscriptionQueueRejectionReason.java
create mode 100644 iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/common/request/IndexedConsensusRequestTest.java
create mode 100644 iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/logdispatcher/LogDispatcherThreadMetricsTest.java
create mode 100644 iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/pipe/metric/IoTConsensusV2ServerMetricsTest.java
create mode 100644 iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/ratis/metrics/RatisMetricSetTest.java
create mode 100644 iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/ImportWALMessages.java
create mode 100644 iotdb-core/datanode/src/main/i18n/zh/org/apache/iotdb/db/i18n/ImportWALMessages.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/lbac/AllowAllLBACAccessControl.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/lbac/ILBACAccessControl.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/overview/PipeDataNodeCompletionOperator.java
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/memory/{PipeTsFileMemoryBlock.java => PipeMemoryBlockCategory.java} (54%)
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/util/PipeTabletEventTransferUtils.java
rename iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/sink/opcua/OpcUaSink.java => datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceFinishedException.java} (52%)
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/AlterTableSetColumnPropertiesTask.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/load/LoadPieceConsensusRequest.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/load/LoadTsFileConsensusNode.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/load/LoadTsFileConsensusOp.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/information/AdditionalInformationSchemaProvider.java
copy iotdb-core/{calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/rowpattern/expression/NaryComputation.java => datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/information/AdditionalInformationSchemaProviderRegistry.java} (57%)
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/TableFunctionOrdering.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/SetColumnProperties.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/ChunkOffsetCalculator.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/DataPartitionBatchFetcher.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/DataPartitionResolver.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/DataPartitionRouter.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LoadConsensusSubmitter.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LoadFallbackHandler.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LocalLoadStrategy.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/MemoryBoundedBuffer.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/PieceDispatcher.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/TsFileLoadStrategy.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/TsFileSplitConsumer.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/TwoPhaseConsensusLoadStrategy.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/ShowPipeMemoryStatement.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/modification/DropTableModProgress.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadConsensusCompat.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadStagingDirs.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTaskRetention.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTsFileCleaner.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTsFileProgress.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTsFileSnapshot.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/TsFileWriterManager.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileSubMemoryBlock.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/metrics/LoadPointCountMetrics.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/splitter/ChunkPayloadRef.java
copy iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/NonOpenTransport.java => iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/splitter/ChunkPayloadUnavailableException.java (54%)
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/splitter/SerializedSizes.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusSubscriptionWalRetention.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/SubscriptionQueueTimeTracker.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/ImportWAL.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/TableWALDeleteConverter.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/TypeServices.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/tsfile/write/TsFilePrecalculatedChunkWriter.java
delete mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/auth/entity/RoleTest.java
delete mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/auth/entity/UserTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/conf/LoadTsFileSplitPartitionMaxSizeConfigTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/consensus/statemachine/dataregion/IoTConsensusShutdownTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/subtask/processor/PipeProcessorSubtaskTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/common/heartbeat/PipeHeartbeatEventTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/common/row/PipeRowTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/metric/PipeMetricsRestartTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/metric/overview/PipeDataNodeCompletionOperatorTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/metric/overview/PipeDataNodeSinglePipeMetricsTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/metric/schema/PipeSchemaRegionListenerMetricsTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/metric/sink/PipeDataRegionSinkMetricsTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/processor/aggregate/TimeSeriesRuntimeStateTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/async/handler/PipeTransferTabletInsertNodeEventHandlerTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/assigner/PipeDataRegionAssignerTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/listener/PipeInsertionDataNodeListenerTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/session/QueryOwnershipTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/thrift/impl/DataNodeInternalRPCServiceImplSetSystemStatusTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/fragment/FileReaderReferenceLifecycleTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/fragment/RegionQueryInitializationLockTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/fragment/RegionScanTimeSliceTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/LastQueryCollectOperatorTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/fill/GroupedFillOperatorTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/schema/source/DeviceBlackListConstructorTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ShowClusterDetailsTaskTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ShowClusterTaskTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ShowConfigNodesTaskTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ShowDataNodesTaskTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/ShowCreateViewTaskTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/predicate/ConvertPredicateToFilterVisitorTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/LastQueryCacheTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/load/LoadTsFileConsensusNodeTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/OrderingPropertyPropagationTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/TableFunctionSortTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/sql/parser/CreateViewPrefixPathTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/sql/parser/ShowPipeMemoryTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/DataPartitionRouterTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LoadConsensusSubmitterTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/TwoPhaseConsensusLoadStrategyAbortTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/adapter/RowGetDoubleTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/input/ConstantInputReaderTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/util/TransformUtilsTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/SchemaEngineTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/metric/SchemaMemMetricTableTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/schemaengine/schemaregion/tag/TagManagerPerformanceTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/service/metrics/DataNodeMetricsRestartTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/service/metrics/file/TsFileMetricsTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/DatabaseMemMetricsTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tablemodel/AbstractTableModelCompactionTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/AlignedFlushDuplicateTimeCheckPerformanceTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/AlignedWritableMemChunkTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TabletDeviceRangeReusePerformanceTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileTableSchemaRegistrationPerformanceTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/control/FileReaderManagerConcurrencyTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/TsFileLockTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFileCleanerTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFileManagerDeletionTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFileManagerSplitCoverageTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFileManagerTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFileProgressTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFileResumeTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFileSnapshotTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFileTableSchemaTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileSubMemoryBlockTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/splitter/SerializedSizesTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingQueueRecycleIntervalTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/TsFileDeduplicationBlockingPendingQueueTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueueDeliveryTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueueInitializationTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueueSeekTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueueWriterOrderingTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusSubscriptionWalRetentionTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/consensus/SubscriptionWalPrefetchPerformanceTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTabletEventBatchTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/event/cache/SubscriptionPollResponseCacheTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/metric/SubscriptionMetricsRestartTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/tools/ImportWALTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/tools/TableWALDeleteConverterTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/ObjectWriterTest.java
copy iotdb-core/{confignode/src/test/java/org/apache/iotdb/confignode/manager/load/cache/ConsensusGroupCacheTest.java => datanode/src/test/java/org/apache/iotdb/db/utils/TSDataTypeSwitchArchitectureTest.java} (50%)
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/TSDataTypeSwitchRule.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/TSDataTypeSwitchRuleTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/TypeServicesTest.java
create mode 100644 iotdb-core/node-commons/src/main/i18n/en/org/apache/iotdb/commons/i18n/LBACMessages.java
create mode 100644 iotdb-core/node-commons/src/main/i18n/zh/org/apache/iotdb/commons/i18n/LBACMessages.java
copy integration-test/src/main/java/org/apache/iotdb/it/env/remote/config/RemoteConfigNodeConfig.java => iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/table/TableInDeletionException.java (51%)
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/lbac/LBACAccessDeniedException.java
copy iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/NonOpenTransport.java => iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/lbac/LBACRuntimeException.java (65%)
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/lbac/RequiredLabels.java
rename iotdb-client/jdbc/src/main/resources/services/META-INF/java.sql.Driver => iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/lbac/operation/LabelAccessType.java (88%)
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/TypeServices.java
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/client/AbstractConfigNodeClientConnectionTest.java
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/client/AbstractConfigNodeClientTest.java
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/cluster/NodeStatusTest.java
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/concurrent/ThreadPoolMetricsTest.java
copy iotdb-core/{confignode/src/test/java/org/apache/iotdb/confignode/manager/load/cache/ConsensusGroupCacheTest.java => node-commons/src/test/java/org/apache/iotdb/commons/conf/CommonDescriptorSubscriptionCacheMemoryUsagePercentageTest.java} (54%)
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/path/PathPatternNodeTest.java
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/metric/PipeEventCommitMetricsTest.java
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/queryengine/plan/relational/type/InternalTypeManagerTest.java
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/service/metric/JvmGcMonitorMetricsTest.java
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/service/metric/MetricServiceRestartTest.java
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/udf/utils/MasterRepairUtilTest.java
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/udf/utils/UDFDataTypeTransformerTest.java
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/rpc/ClientPoolIdleEvictionTest.java
rename {example/pipe-opc-ua-sink => library-pipe/opc-ua-sink-example}/pom.xml (82%)
rename {example/pipe-opc-ua-sink => library-pipe/opc-ua-sink-example}/src/main/java/org/apache/iotdb/opcua/ClientExample.java (100%)
rename {example/pipe-opc-ua-sink => library-pipe/opc-ua-sink-example}/src/main/java/org/apache/iotdb/opcua/ClientExampleRunner.java (100%)
rename {example/pipe-opc-ua-sink => library-pipe/opc-ua-sink-example}/src/main/java/org/apache/iotdb/opcua/ClientTest.java (100%)
rename {example/pipe-opc-ua-sink => library-pipe/opc-ua-sink-example}/src/main/java/org/apache/iotdb/opcua/IoTDBKeyStoreLoaderClient.java (100%)
create mode 100644 library-pipe/opc-ua-sink/README.md
copy {iotdb-core/consensus => library-pipe/opc-ua-sink}/pom.xml (50%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol => library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink}/opcua/OpcUaSink.java (91%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol => library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink}/opcua/client/ClientRunner.java (99%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol => library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink}/opcua/client/IoTDBKeyStoreLoaderClient.java (98%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol => library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink}/opcua/client/IoTDBOpcUaClient.java (98%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol => library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink}/opcua/server/OpcUaKeyStoreLoader.java (98%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol => library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink}/opcua/server/OpcUaNameSpace.java (85%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol => library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink}/opcua/server/OpcUaServerBuilder.java (99%)
create mode 100644 library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink/opcua/server/OpcUaTypeServices.java
create mode 100644 library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink/opcua/OpcUaSinkTest.java
rename {iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol => library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink}/opcua/OpcUaSinkTsFileMetadataTest.java (99%)
rename {iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol => library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink}/opcua/OpcUaSinkTsFilePerformanceTest.java (98%)
rename {iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol => library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink}/opcua/client/ClientRunnerTest.java (98%)
rename {iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol => library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink}/opcua/client/IoTDBOpcUaClientTest.java (97%)
rename {iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol => library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink}/opcua/server/OpcUaNameSpaceMetadataTest.java (95%)
rename {iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol => library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink}/opcua/server/OpcUaServerBuilderTest.java (99%)
rename {iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol => library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink}/opcua/server/OpcUaTcpNoneCompatibilityTest.java (98%)
copy iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/cache/ConsensusGroupCacheTest.java => library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink/opcua/server/OpcUaTypeServicesTest.java (52%)
create mode 100644 library-pipe/pom.xml
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/util/TypeServices.java
create mode 100644 licenses/Bouncy Castle Licence
create mode 100644 scripts/tools/README.md
copy docker/src/main/Dockerfile-1.0.0-standalone => scripts/tools/import-wal.sh (50%)
create mode 100644 scripts/tools/windows/import-wal.bat