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/15 07:50:59 UTC
(iotdb) branch config-bug updated (a12b657154c -> 03b8d95a299)
This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch config-bug
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from a12b657154c Fix NodeManager Sonar issues
add 17e4efb6922 Record audit logs when revoke failed (#18352)
add 3a06ed41d5d Disable multi-node REMOVE statements (#18360)
add 647e5363152 Remove Ratis region migration rate limiting (#18365)
add 71700468942 [Pipe] Fix historical TsFile schema recovery race (#18314)
add 6559aa52ba9 Pipe: Handle hybrid meta progress indexes (#18331)
add a321fa34d5d Subscription: preserve topic updates during owner transfer (#18353)
add 154644107a8 Pipe: Respect history enable with source time range (#18362)
add 75eaa40744b Fix race condition in ExternalTsFileQueryResource reference counting (#18371)
add 09252d40064 feat(load): reject managed TsFile directories (#18271)
add d82806fa208 Subscription: Rename topic modes to initial and incremental (#18370)
add 157efaef283 Use provider-compatible file deletion and truncation APIs (#18349)
add cc583ca61b0 Fix query analyze metric of TableModel
add 83d536aa17d [Fix] Keep heartbeat alive when metadata lease is fenced (#18343)
add e23500e1a10 Support rate family aggregation functions in table model (#18334)
add cde1601d17d [Pipe] Batch OPC UA sink writes (#18380) (#18384)
add bee70a863b4 Fix IndexOutOfBoundsException caused by concurrent sort and delete on TVList (#18389)
add f6a844d8191 Query: Optimize schema traversal for non-leading tag IN predicates (#18369)
add 303686e8604 Pipe: Add receiver session authentication integration tests (#18395)
add c46c0732bb3 Record audit logs for normal and failed role grants and revokes (#18355)
add f49370013af Fix config event race in pipe idempotent table IT (#18403)
add 346abc37df2 Fix DataNode restart during database deletion (#18407)
add a0543f5aa21 [ConfigNode] Revert procedure-based RegionGroup cleanup and fix RegionMaintainer retries (#18404)
add 14ecc9f212a [Performance] Reduce allocations on aligned tablet writes (#18358)
add 6a253567b08 Fix write-back sink tree target database case (#18398)
add 9fe55fce9a9 Fix table UDF result block splitting (#18333)
add 84c4bafa38d [Subscription] Reduce consensus WAL replay and ACK contention (#18402)
add 513a093f6dc Fix silent deduplication of duplicate tag columns in COPY TO statement (#18408)
add c6afaf54957 Fix table model set configuration audit logging (#18412)
add ec473f7fd1d [Subscription] Isolate tree and table topics (#18397)
add 0d94b765427 Optimize aligned memtable flush without deleted measurements (#18406)
add feba0c62b8a feat(load): reject active load listening dirs under data directory (#18405)
add 5be170d6a1f Fix pipe tablet memory resize admission limit (#18413)
add 7e2c453fbd1 fix(load): use buffered input when splitting TsFiles (#18388)
add 81c2b05c67f Bump tsfile to 2.4.1-260806-SNAPSHOT and add COPY_TO_WRITE_ERROR for COPY TO write failures (#18414)
add fcaa2f82267 Pipe: Reuse clusters across related integration tests (#18400)
add c4616685b1a Fix SHOW QUERIES and KILL QUERY privilege filtering (#18359)
add e281a308851 Reduce AirGap receiver log noise (#18424)
add d1f362d3ca3 Pipe: Handle transient resource failures locally (#18381)
add bc5b6a2d162 Fix subscription topic authorization bypass (#18418)
add 85442f00f85 [Load] Isolate reused TsFile parser memory from Pipe pool (#18419)
add 10950e13ea9 Pipe: dynamically share idle floating memory (#18422)
add 50a2e83eb65 fix: validate internal tsfile paths for files only (#18417)
add 5d163835737 Support high availability for the authority module (#18425)
add 4b237744707 modify the deal strategy for metadata lease exception in DataDriver and ErrorHandlingUtils (#18438)
add ab881319f22 Fix fragment failure race with concurrent cancellation (#18439)
add 02f43e73f47 Upgrade Eclipse Milo to 1.1.6 (#18431)
add 3c0c7fef006 [Pipe] Fix processor worker starvation on pipe stop (#18396)
add 17e3b4e9460 clone partial columns of aligned tvlist for query (#18409)
add ef0a792a3aa fix(pipe): reuse safe local progress on alter (#18423)
add 6ca8850a25b [Pipe] Support configurable TsFile parser (#18440)
add 2479dc63531 Subscription: clean up consumers after abrupt disconnect (#18434)
add e1030c5e00e fix: reuse pre-computed ArrayList instance size in AlignedTVList ram cost (#18452)
add e509114c515 fix: retry SyncStatus batch memory reservation (#18453)
add 0ea96b543ea Bump ratis to 3.3.0 (#18320)
add 96c905e8146 [SQL] Add STREAM and STREAMS as reserved keywords (#18458)
add 27e9920399b feat: cache sorted WAL file lists (#18456)
add ab7a911fdb2 [Subscription] Fix pending consensus request memory leak (#18429)
add 8b0abccd89a [Subscription] Exclude audit database from subscriptions (#18451)
add a110cc024f9 fix flush average points num may be mixed in one region (#18460)
add 9b2784c3ad4 Fix data exchange failure propagation (#18468)
add cec4f9b111b Fix audit database filtering for consensus pipes (#18476)
add dc2e7c861b6 [Pipe] Optimize OPC UA TsFile last-value transfer (#18433)
add 5db9f416143 fix(subscription): avoid per-provider poll backoff (#18448)
add 4eff4c1654c [Pipe] Support receiver-side async takeover for TsFile conversion (#18421)
add dc47a3baa0a Stabilize air-gap batch compression IT
add ada62cb1048 [Pipe] Fix conversion task ID collision after leader switch (#18494)
add 5221cf49ed0 fix: make CompactionWorkerTest UT deterministic by using CountDownLatch instead of fixed 2s sleep to wait for task drop status reset (#18498)
add c63d0e82efc [DOC] Clarify internal RPC trust boundary in threat model (#18504)
add c8e73f30ac3 Add the setting for JAVA_HOME in the start-cli.bat file (#18503)
add 541b9a32d8e Fix unsolicited AirGap responses on idle timeout (#18502)
add 41c0e2d4ee8 [Subscription] Isolate tree and table consensus topics (#18469)
add e591e66c0f5 Fix IoTConsensus batch accumulation and config reload (#18501)
add fdce12d7972 Fix subscription event loss on poll payload overflow (#18471)
add a4e56ce5c2f [Subscription] Fix WAL replay after leader failover (#18474)
add 0a9fda0a4c3 [Subscription] Reduce consensus commit warning log noise (#18450)
add c0c1d562aa0 [Pipe] Reject operations while pipe is being dropped (#18485)
add 429587f629a Load: preserve pending tablets when parser fails (#18487)
add 91a44fd8c00 [Pipe] Split OPC UA sink requests by advertised server limits (#18486)
add 20ce15e04a5 Fix fail-open authorization for pipe config plans (#18488)
add 6be80261199 Supported "need last cache" semantic for table/database schema (#15538)
add 83f6303c253 Add TLS channel failure reporting hooks (#18299)
add ae163537785 [Subscription] Protect retained WAL by committed progress (#18399)
add 593c3bc5c33 [Subscription] Skip runtime when subscription is disabled (#18465)
add 2686348c031 Avoid duplicate DataNode memory configuration initialization (#18467)
add 9ebbaaa458d Fix snapshot pipe auto-drop when some DataNodes fail to initialize (#18512)
add c520debda0b Subscription: improve WAL replay gap observability (#18377)
add 930e9bc0cf7 Fix DataNode status handling for Pipe receiver disk failures (#18484)
add 206f1fc4c29 Move PipelineMemoryEstimator to calc-commons (#18520)
add 079d2ee66de Fix snapshot pipe completion wait on unmatched DataRegions and add IT (#18523)
add 89d4fbbcd9c Add consensus subscription progress observability (#18521)
add ce3ef055652 Fix schema recovery for single device attribute match (#18490)
add 0280aa7b51a Implement FFT table function for table model
add 7c656815b46 fix: fix `RPCTransportFactory` setting bug (#18497)
add a8950536244 [Subscription] Disable subscription by default (#18457)
add a10bc6ba7e7 Revert "Fix IoTConsensus batch accumulation and config reload (#18501)" (#18535)
add 6aec4b872a1 Fix IoTConsensus reconstruction IT follower synchronization (#18536)
add 621f9868a62 [DOC] Point the contributing documents section to apache/iotdb-docs (#18542)
add c30554f743c Fix fragment failure propagation race (#18543)
add 011616824b9 Pipe: Fix TsFile reference races and improve result set diffs (#18376)
add 5ce27404e87 Filter all-null FIELD columns before tablet insert in Java/C++/Python… (#18533)
add b9683c0c106 fix(load): validate TsFile before async move (#18531)
add 76ee6f08165 Fix finite pipe auto-drop without DataRegions (#18540)
add 1106d858f10 Add IoTDB Edge distribution: ConfigNode + DataNode merged in one JVM (#18538)
add ebd9c2072e3 Fix IoTConsensus batch accumulation latency (#18522)
add 60833764d31 Fix pipe historical extraction when device metadata is unavailable (#18541)
add a9f1d5258e1 Fix pipe sink isolation between pipes (#18549)
add b3b2e95f52e Fix LOAD replica set order comparison (#18551)
add 8c50293d308 Add daemon and cleanup tools for IoTDB Edge (#18552)
add 7a38e7e225f Add DataNodeExceptionMetrics with suspected disk exception counter (#18554)
add e096f6316e6 Fix flaky PARTIAL/FINAL plan assertion in rateFunctionsNormalTest (#18556)
add a185d9c7e94 Extend the monitoring framework to support multiple node types (#18470)
add 8df29019a69 Bump Netty to 4.1.137.Final, Reactor Netty to 1.2.18, and Thrift to 0.24.0 (#18559)
add 05a97b91102 Tune Edge compaction and TsFile defaults (#18566)
add 6b0354f4f15 Suppress pull commit progress log when subscription is disabled (#18564)
add 18ec5f0a393 [Pipe] Preserve downstream sink error messages (#18553)
add d21169f10fb Update pipe config for edge version (#18568)
add 829837237aa Bump C++ client bundled Thrift from 0.23.0 to 0.24.0 (#18567)
add 6a236ff51d6 Implementation of LowPass, HighPass, and XCorr Table Functions (#18539)
add d1302398148 Extend suspicious disk exception recording to SyncFailedException and disk-error IOExceptions (#18572)
add d6b3afbb2b6 Add audit hooks for inter-node user data transfers (#18569)
add e816bc1a2b8 Refactor ConfigNode client/info and DirectoryChecker into node-common… (#18561)
add 4697c42183c Change default edge ratis configuration (#18576)
add fd398988672 Bound PartitionInfo snapshot buffers via config_node_snapshot_buffer_size_max (#18580)
add 2c0c307c3d6 Harden timestamp arithmetic and boundary handling across IoTDB (#17893)
add dc7346933be Support spill of devce entry in query process (#18493)
add 219332dacb8 add dailyIT for device entry spilling to disk (#18583)
add 57ce0d0e8fe remove some stack print (#18585)
add 9d912452c5a Make Edge query and load-event thread pools configurable (#18584)
add e9dd92d13b6 Optimize Prometheus reporter snapshot updates (#18562)
add ce9b3df5b39 Stabilize pipe TsFile decomposition mods IT (#18571)
add c41838e1386 Fix IoTConsensus batch accumulation by byte size (#18560)
add e9bbc8e7944 Fix table-model Pipe batch isolation (#18577)
add 8a789d09a60 [Pipe] Allow startup when a plugin JAR is unavailable (#18496)
add d61ef998215 Add several verifications for filtering out databases of the table model (#18592)
add 31e75348112 [Pipe] Fix tablet type conversion for failed columns (#18595)
add f763ad427cf Pipe: Load TsFile classes from parent class loader (#18578)
add 448a805c7b6 Revert IoTConsensus batch accumulation changes (#18598)
add 25ab7941ceb Limit Edge query threads and remove unused binary allocator (#18587)
add 2a654e66745 Fix deleteDirectoryIfExists when root Path is not exist (#18593)
add 6343e1fe7a0 Restrict COPY TO export paths (#18573)
add 47844ddc737 Optimize aligned memtable encoding for null values (#18610)
add 6c2b747ede6 [Pipe] Fix batch and async resource lifecycle leaks (#18582)
add c2ead3be72f Fix Java client time column access throwing ArrayIndexOutOfBoundsException (#17407) (#17408)
add 6a3c8d667f0 [Load] Preserve invalid device path failures during tablet conversion (#18614)
add b1a046211b1 [AINode] Replace DiT-derived Sundial conditioning head (#18616)
add 55736e2ee28 Add MOMENT license and copyright notice (#18611)
add ab6f8a214e1 [AINode] Add third-party attributions to binary package (#18620)
add 320f0d5a839 [Subscription] Suppress expected commit progress warnings (#18615)
add 510c8cddd2b Fix pipe visibility and mask credentials in show create (#18617)
add 3ea1fc666ac Delete empty TsFile sidecars after LOAD (#18599)
add 31621ef2602 Fix metric about device entry disk io- #18609
add c05881ba28c bump tsfile version (#18629)
add 0f9f1ebb300 Change schema region sync logs to debug (#18632)
add a467cf3d430 [Pipe] Honor SECURITY privilege for relational auth synchronization (#18624)
add 63ae0f35e0e Add SHOW RECEIVERS support (#17869)
add 280c0189aa5 Support standard TLS and mTLS in the C++ client (#18601)
add 37e3e6630e2 [Pipe] Stabilize IoTDBPipeAutoSplitIT for auto-dropped history pipe (#18621)
add a05c63e0abb Fix aligned flush values after time deletion (#18634)
add 7c8e4cbc27d Fix flaky IoTDBAutoRegionGroupExtension2IT during DataNode shutdown (#18642)
add 0f64600571b Optimize Python session result decoding (#18638)
add e2ac222343b [Pipe] Restore sink progress under memory pressure (#18640)
add 2838c35317f [Pipe] Stabilize receiver and compression integration tests (#18644)
add 34528ad93d3 Stop publishing standalone CLI and node distributions (#18622)
add 1151ba762ff Fix TVList iterator state across memtable page switches (#18647)
add 11470dafb6f Fix WAL roll recovery after closed channel (#18653)
add fefbbbcf0fa [Subscription] Balance consensus ownership and report WAL backlog (#18641)
add e967831ca2a [Pipe] Drop builtin sinks synchronously (#18646)
add 016d58b47fb [Subscription] Relax group credentials and report connection failures (#18658)
add 76796db4782 [Subscription] Bound consumer close when server is unresponsive (#18659)
add 25bf38eba0c [Query] Fix result-column OOM diagnostics (#18661)
add 2b6d628e022 [Pipe] Fix deletion buffer close flush race (#18662)
add 5b9e8868c47 [ConfigNode] Skip non-existent and duplicate region IDs during reconstruction (#18664)
add 5d67dae28c8 Fix init of DeviceEntryBatchSizeInBytes config when there is no properties file (#18660)
add c611a389e7d Fix table model JDBC example TTL retrieval (#18669)
add 87a6d198a90 Allow removing regions from read-only DataNodes (#18670)
add 7310b2bc0eb Fix oversized Load TsFile piece dispatch (#18627)
add 6709dfa9494 Fix concurrent subscription consumer handshakes (#18654)
add 0862ecb1d1c Fix Surefire fork port isolation (#18676)
add 957204481d9 Fragment large TsBlocks in MPP DataExchange responses (#18645)
add d2fcb5383ab Fix delayed query cleanup during file metadata scans (#18679)
add 61f2014ded8 Fix client manager metrics and JMX lifecycle races (#18681)
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 03b8d95a299 Merge origin/master into config-bug
No new revisions were added by this update.
Summary of changes:
.github/scripts/test-edge-ops.py | 464 ++
.github/scripts/test-edge-windows.ps1 | 222 +
.github/workflows/client-cpp-package.yml | 38 +-
.github/workflows/daily-it.yml | 391 +-
.github/workflows/edge-it.yml | 98 +
.github/workflows/multi-language-client.yml | 19 +-
.github/workflows/pipe-it.yml | 350 --
.mvn/extensions.xml | 2 +-
CLAUDE.md | 13 +
CONTRIBUTING.md | 22 +-
LICENSE | 56 +
LICENSE-binary | 47 +-
NOTICE | 10 +-
README.md | 12 +
README_ZH.md | 13 +
THREAT_MODEL.md | 41 +-
architecture-test/pom.xml | 284 +
.../db/utils/TSDataTypeSwitchArchitectureTest.java | 23 +-
.../iotdb/db/utils/TSDataTypeSwitchRule.java | 182 +
.../iotdb/db/utils/TSDataTypeSwitchRuleTest.java | 186 +
dependencies.json | 20 +-
distribution/pom.xml | 17 +-
distribution/src/assembly/ainode-common-files.xml | 52 +
distribution/src/assembly/ainode.xml | 2 +-
distribution/src/assembly/all.xml | 8 +
distribution/src/assembly/cli.xml | 74 -
distribution/src/assembly/confignode.xml | 89 -
distribution/src/assembly/datanode.xml | 90 -
distribution/src/assembly/{all.xml => edge.xml} | 67 +-
distribution/src/assembly/library-pipe.xml | 51 +
.../assembly/resources/conf-edge/logback-edge.xml | 244 +
docker/ReadMe.md | 21 +-
docker/src/main/DockerCompose/do-docker-build.sh | 6 +-
docker/src/main/Dockerfile-1.0.0-confignode | 4 +-
docker/src/main/Dockerfile-1.0.0-datanode | 7 +-
docker/src/main/Dockerfile-1.0.0-standalone | 2 +-
docker/src/main/Dockerfile-1c1d | 2 +-
.../org/apache/iotdb/TableModelJDBCExample.java | 8 +-
example/pom.xml | 1 -
.../ConsensusSubscriptionWalFileAnalyzer.java | 5 +-
.../org/apache/iotdb/DataMigrationExample.java | 64 +-
.../main/java/org/apache/iotdb/TabletExample.java | 56 +-
.../iotdb/ConsensusSubscriptionSessionExample.java | 2 +-
...sensusTableModelSubscriptionSessionExample.java | 2 +-
example/udf/pom.xml | 6 +
.../java/org/apache/iotdb/udf/UDAFExample.java | 106 +-
external-service-impl/rest/pom.xml | 4 +
.../java/org/apache/iotdb/rest/RestService.java | 4 +
.../rest/TrustedChannelAuditHandshakeListener.java | 75 +
.../rest/protocol/filter/AuthorizationFilter.java | 7 +-
.../protocol/handler/AuthorizationHandler.java | 16 +-
.../v1/handler/StatementConstructionHandler.java | 113 +-
.../rest/protocol/utils/InsertRowDataUtils.java | 109 +-
.../iotdb/rest/protocol/utils/TypeServices.java | 162 +
.../v1/handler/StatementConstructionHandler.java | 113 +-
.../rest/protocol/v1/impl/RestApiServiceImpl.java | 3 +-
.../v2/handler/StatementConstructionHandler.java | 113 +-
.../rest/protocol/v2/impl/RestApiServiceImpl.java | 3 +-
.../TrustedChannelAuditHandshakeListenerTest.java | 96 +
.../protocol/v2/handler/FastLastHandlerTest.java | 5 +-
integration-test/pom.xml | 27 +
integration-test/src/assembly/mpp-test.xml | 3 +
.../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 +-
.../relational/LargeResultTableFunction.java | 120 +-
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 21 +-
.../it/env/cluster/config/MppCommonConfig.java | 6 -
.../it/env/cluster/config/MppConfigNodeConfig.java | 6 +
.../it/env/cluster/config/MppDataNodeConfig.java | 21 +
.../env/cluster/config/MppSharedCommonConfig.java | 7 -
.../iotdb/it/env/cluster/env/AbstractEnv.java | 15 +-
.../it/env/remote/config/RemoteCommonConfig.java | 5 -
.../env/remote/config/RemoteConfigNodeConfig.java | 5 +
.../it/env/remote/config/RemoteDataNodeConfig.java | 16 +
.../org/apache/iotdb/itbase/category/EdgeIT.java | 4 +-
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 -
.../apache/iotdb/itbase/env/ConfigNodeConfig.java | 2 +
.../apache/iotdb/itbase/env/DataNodeConfig.java | 6 +
.../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 31 +-
.../it/cluster/IoTDBClusterNodeShutdownHookIT.java | 60 +-
.../it/cluster/IoTDBNodeStatusFailoverIT.java | 744 +++
.../it/cluster/IoTDBNodeStatusPersistenceIT.java | 379 ++
.../confignode/it/cluster/NodeStatusTestAgent.java | 203 +
.../load/IoTDBRegionGroupLeaderDistributionIT.java | 3 +-
...ataPartitionTableIntegrityCheckProcedureIT.java | 127 +-
.../IoTDBAutoRegionGroupExtension2IT.java | 4 +-
.../it/partition/IoTDBPartitionCreationIT.java | 58 +-
.../it/partition/IoTDBPartitionDurableIT.java | 49 +-
.../IoTDBProactiveRegionGroupDistributionIT.java | 1471 +++++
.../IoTDBProactiveRegionGroupExtensionIT.java | 368 ++
.../commit/IoTDBMigrateMultiRegionForIoTV1IT.java | 9 +-
.../IoTDBRegionGroupExpandAndShrinkForIoTV1IT.java | 123 +-
.../commit/IoTDBRegionReconstructForIoTV1IT.java | 108 +-
.../IoTDBRemoveConfigNodeSchemaPartitionIT.java | 262 +
.../IoTDBRemoveDataNodeNormalIT.java | 7 -
.../apache/iotdb/db/it/IoTDBLoadTsFileAuthIT.java | 29 +
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 49 +
.../it/IoTDBRecreatedTimeseriesCompactionIT.java | 125 +
.../apache/iotdb/db/it/IoTDBShowPipeMemoryIT.java | 246 +
.../org/apache/iotdb/db/it/IoTDBShowQueriesIT.java | 155 +
.../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 +
.../org/apache/iotdb/db/it/utils/TestUtils.java | 54 +-
.../org/apache/iotdb/edge/it/IoTDBEdgeBasicIT.java | 625 +++
.../basic/IoTDBPipeRelationalSecurityIT.java | 162 +
.../IoTDBPipeTsFileDecompositionWithModsIT.java | 45 +
.../manual/enhanced/IoTDBPipeIdempotentIT.java | 7 +-
.../treemodel/auto/basic/IoTDBPipeAlterIT.java | 48 +
.../treemodel/auto/basic/IoTDBPipeAutoSplitIT.java | 19 +-
.../treemodel/auto/basic/IoTDBPipeSourceIT.java | 60 +
.../auto/basic/IoTDBShowReceiversLifecycleIT.java | 366 ++
.../auto/enhanced/IoTDBPipeAutoConflictIT.java | 5 +
.../auto/enhanced/IoTDBPipeAutoDropIT.java | 194 +
.../auto/enhanced/IoTDBPipeSinkCompressionIT.java | 16 +-
.../manual/IoTDBPipeManualConflictIT.java | 70 +-
.../treemodel/manual/IoTDBPipePermissionIT.java | 147 +-
.../treemodel/manual/IoTDBPipeWriteBackSinkIT.java | 24 +-
.../iotdb/pipe/it/single/AbstractPipeSingleIT.java | 70 +-
.../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 50 +-
.../it/single/IoTDBPipeOperationDiagnosticsIT.java | 395 ++
.../pipe/it/single/IoTDBPipePermissionIT.java | 75 +-
.../iotdb/pipe/it/single/IoTDBShowReceiversIT.java | 719 +++
.../pipe/it/triple/IoTDBShowReceiversTripleIT.java | 287 +
.../it/db/it/IoTDBDeletionTableClusterIT.java | 152 +
.../relational/it/db/it/IoTDBDeletionTableIT.java | 77 +
.../it/db/it/IoTDBFFTTableFunctionIT.java | 293 +
.../relational/it/db/it/IoTDBInsertTableIT.java | 117 +
.../db/it/IoTDBMultiTAGsWithAttributesTableIT.java | 10 +-
.../it/db/it/IoTDBOrderingPropertyIT.java | 486 ++
.../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 | 359 ++
.../db/it/udf/IoTDBUserDefinedTableFunctionIT.java | 80 +
.../it/query/old/IoTDBSimpleQueryTableIT.java | 24 +
...AbstractIoTDBMPPDataExchangeLargeTsBlockIT.java | 98 +
.../it/query/recent/IoTDBDeviceEntrySpillIT.java | 146 +
.../IoTDBMPPDataExchangeLargeTsBlock128KIT.java} | 40 +-
.../it/query/recent/IoTDBTableAggregationIT.java | 584 +-
...ableAggregationQueryWithNetworkPartitionIT.java | 5 +-
.../query/recent/copyto/IoTDBCopyToTsFileIT.java | 124 +-
.../query/view/recent/IoTDBTableViewQueryIT.java | 11 +-
.../IoTDBTableViewQueryWithCachedDeviceIT.java | 3 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 219 +-
.../iotdb/relational/it/schema/IoTDBDeviceIT.java | 57 +-
.../it/schema/IoTDBDropTableModProgressIT.java | 105 +
.../relational/it/schema/IoTDBTableAuthHAIT.java | 670 +++
.../relational/it/schema/IoTDBTableDDLHAIT.java | 37 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 196 +-
.../it/session/IoTDBSessionRelationalIT.java | 24 +-
.../iotdb/session/it/IoTDBConnectionsIT.java | 53 +-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 5 +-
.../iotdb/session/it/pool/SessionPoolIT.java | 21 +-
.../IoTDBSubscriptionTopicOwnerPartitionIT.java | 1 -
.../local/ConsensusSubscriptionITSupport.java | 2 +-
.../ConsensusSubscriptionTableITSupport.java | 2 +-
...ConsensusSubscriptionColumnFilterClusterIT.java | 3 +-
...ensusSubscriptionConsumerDisconnectTableIT.java | 298 +
...TDBConsensusSubscriptionUnsubscribeTableIT.java | 253 +
.../IoTDBSubscriptionColumnFilterIT.java | 5 +-
.../it/local/AbstractSubscriptionLocalIT.java | 2 -
.../it/local/IoTDBSubscriptionTopicOwnerIT.java | 1 -
.../tablemodel/IoTDBSubscriptionIsolationIT.java | 161 +-
.../tablemodel/IoTDBSubscriptionPermissionIT.java | 2 +-
.../IoTDBAllTsDatasetPullConsumerIT.java | 2 +-
.../IoTDBAllTsTsfilePullConsumerIT.java | 2 +-
.../IoTDBPathDeviceDataSetPullConsumerIT.java | 2 +-
.../IoTDBPathDeviceTsfilePullConsumerIT.java | 2 +-
.../IoTDBTimeTsDatasetPullConsumerIT.java | 2 +-
.../IoTDBTimeTsTsfilePullConsumerIT.java | 2 +-
.../IoTDBLooseAllTsDatasetPushConsumerIT.java | 4 +-
.../IoTDBLooseAllTsfilePushConsumerIT.java | 4 +-
.../IoTDBPathLooseDeviceTsfilePushConsumerIT.java | 2 +-
.../IoTDBPathLooseTsDatasetPushConsumerIT.java | 2 +-
.../IoTDBPathLooseTsfilePushConsumerIT.java | 2 +-
.../IoTDBPathTsLooseDatasetPushConsumerIT.java | 2 +-
.../IoTDBTimeLooseTsDatasetPushConsumerIT.java | 4 +-
.../IoTDBTimeLooseTsTsfilePushConsumerIT.java | 4 +-
.../IoTDBTimeLooseTsfilePushConsumerIT.java | 2 +-
.../IoTDBTimeTsLooseDatasetPushConsumerIT.java | 4 +-
.../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/CMakeLists.txt | 18 +-
iotdb-client/client-cpp/README.md | 63 +-
iotdb-client/client-cpp/README_zh.md | 14 +-
.../client-cpp/cmake/FetchBuildTools.cmake | 2 +-
iotdb-client/client-cpp/cmake/FetchOpenSSL.cmake | 201 +-
.../client-cpp/cmake/InstallOpenSSLRuntime.cmake | 4 +-
iotdb-client/client-cpp/examples/CMakeLists.txt | 2 +-
iotdb-client/client-cpp/examples/README.md | 6 +-
iotdb-client/client-cpp/examples/README_zh.md | 6 +-
iotdb-client/client-cpp/pom.xml | 62 +-
.../package-metadata/third_party/DEPENDENCIES.md | 4 +-
.../src/include/AbstractSessionBuilder.h | 15 +-
iotdb-client/client-cpp/src/include/Common.h | 1 +
iotdb-client/client-cpp/src/include/Session.h | 53 +-
.../client-cpp/src/include/SessionBuilder.h | 14 +-
iotdb-client/client-cpp/src/include/SessionC.h | 15 +
iotdb-client/client-cpp/src/include/SessionPool.h | 21 +-
.../client-cpp/src/include/SslConfig.h | 19 +-
iotdb-client/client-cpp/src/include/TableSession.h | 3 +-
.../client-cpp/src/include/TableSessionBuilder.h | 14 +-
iotdb-client/client-cpp/src/rpc/NodesSupplier.cpp | 33 +-
iotdb-client/client-cpp/src/rpc/NodesSupplier.h | 13 +-
.../src/rpc/RpcSslUtils.cpp} | 33 +-
.../client-cpp/src/rpc/RpcSslUtils.h | 20 +-
.../client-cpp/src/rpc/SessionConnection.cpp | 13 +-
.../client-cpp/src/rpc/SessionConnection.h | 3 +-
iotdb-client/client-cpp/src/rpc/SessionImpl.h | 7 +-
.../client-cpp/src/rpc/ThriftConnection.cpp | 11 +-
iotdb-client/client-cpp/src/rpc/ThriftConnection.h | 6 +-
iotdb-client/client-cpp/src/session/Common.cpp | 38 +-
iotdb-client/client-cpp/src/session/Session.cpp | 208 +-
iotdb-client/client-cpp/src/session/SessionC.cpp | 69 +
.../client-cpp/src/session/SessionPool.cpp | 17 +-
.../src/session/SslConfig.cpp} | 28 +-
.../client-cpp/src/session/TableSession.cpp | 5 +-
iotdb-client/client-cpp/test/CMakeLists.txt | 43 +-
.../client-cpp/test/cpp/RpcSslIotdbE2eTest.cpp | 194 +
iotdb-client/client-cpp/test/cpp/sessionIT.cpp | 3 +-
.../client-cpp/test/cpp/sessionUtilsTest.cpp | 159 +
iotdb-client/client-cpp/test/fixtures/tls/ca.crt | 19 +
.../client-cpp/test/fixtures/tls/client.crt | 17 +
.../client-cpp/test/fixtures/tls/client.key | 28 +
.../client-cpp/test/fixtures/tls/tls-server.p12 | Bin 0 -> 2608 bytes
.../test/main_rpc_ssl.cpp} | 4 +-
.../test/main_utils.cpp} | 9 +-
.../test/scripts/configure_iotdb_ssl_it.py | 117 +
.../client-cpp/test/scripts/run_cpp_it_phases.py | 130 +
iotdb-client/client-cpp/third-party/README.md | 6 +-
iotdb-client/client-py/README.md | 6 +-
iotdb-client/client-py/iotdb/Session.py | 230 +-
iotdb-client/client-py/iotdb/utils/BitMap.py | 39 +
.../client-py/iotdb/utils/SessionDataSet.py | 30 +-
iotdb-client/client-py/iotdb/utils/SessionUtils.py | 128 +
iotdb-client/client-py/iotdb/utils/Tablet.py | 6 +
.../client-py/iotdb/utils/iotdb_rpc_dataset.py | 90 +-
.../client-py/tests/unit/test_session_query_ids.py | 132 +
.../client-py/tests/unit/test_session_utils.py | 160 +
.../org/apache/iotdb/isession/SessionDataSet.java | 39 +-
.../org/apache/iotdb/isession/TypeServices.java | 68 +
iotdb-client/jdbc/README.md | 23 -
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 +-
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 10 +-
.../apache/iotdb/jdbc/IoTDBDataSourceFactory.java | 79 -
.../java/org/apache/iotdb/jdbc/IoTDBDriver.java | 2 -
.../resources/META-INF/services/java.sql.Driver | 3 +
.../iotdb/jdbc/DriverServiceRegistrationTest.java | 33 +-
.../apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java | 90 +
.../org/apache/iotdb/jdbc/IoTDBStatementTest.java | 39 +
.../en/org/apache/iotdb/rpc/i18n/RpcMessages.java | 16 +
.../zh/org/apache/iotdb/rpc/i18n/RpcMessages.java | 11 +
.../iotdb/rpc/DeepCopyRpcTransportFactory.java | 25 +-
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 185 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 115 +-
.../org/apache/iotdb/rpc/NonOpenTransport.java | 6 +
.../rpc/TCompressedElasticFramedTransport.java | 4 +
.../apache/iotdb/rpc/TElasticFramedTransport.java | 74 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 31 +
.../java/org/apache/iotdb/rpc/TypeServices.java | 162 +
.../iotdb/rpc/stmt/PreparedParameterSerde.java | 41 +-
.../iotdb/rpc/DeepCopyRpcTransportFactoryTest.java | 62 +
.../org/apache/iotdb/rpc/IoTDBJDBCDataSetTest.java | 176 +
.../iotdb/rpc/TElasticFramedTransportReadTest.java | 266 +
.../iotdb/rpc/TElasticFramedTransportTest.java | 101 +
.../iotdb/rpc/stmt/PreparedParameterSerdeTest.java | 12 +
.../java/org/apache/iotdb/session/Session.java | 295 +-
.../apache/iotdb/session/SessionConnection.java | 56 +-
.../org/apache/iotdb/session/ThriftConnection.java | 8 +-
.../iotdb/session/util/SessionTypeServices.java | 435 ++
.../apache/iotdb/session/util/SessionUtils.java | 387 +-
.../iotdb/session/BrokenSessionConnectionTest.java | 222 +
.../iotdb/session/SessionConnectionTest.java | 19 +
.../java/org/apache/iotdb/session/SessionTest.java | 43 +
.../iotdb/session/util/SessionUtilsTest.java | 104 +
.../subscription/i18n/SubscriptionMessages.java | 10 +-
.../subscription/i18n/SubscriptionMessages.java | 10 +-
.../rpc/subscription/config/ConsumerConfig.java | 4 +
.../rpc/subscription/config/ConsumerConstant.java | 3 +-
.../iotdb/rpc/subscription/config/TopicConfig.java | 70 +-
.../rpc/subscription/config/TopicConstant.java | 26 +-
.../SubscriptionConsumerFencedException.java | 51 +
.../payload/request/PipeSubscribeRequestType.java | 1 +
.../payload/request/PipeSubscribeSliceReq.java | 169 +
.../request/PipeSubscribeSliceReqBuilder.java | 80 +
.../request/PipeSubscribeSliceReqHandler.java | 141 +
.../SubscriptionSessionConnection.java | 16 +
.../base/AbstractSubscriptionConsumer.java | 285 +-
.../base/AbstractSubscriptionConsumerBuilder.java | 2 +-
.../base/AbstractSubscriptionProvider.java | 299 +-
.../base/AbstractSubscriptionProviders.java | 185 +-
.../base/AbstractSubscriptionPullConsumer.java | 119 +-
.../base/AbstractSubscriptionPushConsumer.java | 24 +-
.../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 | 91 +
.../payload/request/PipeSubscribeSliceReqTest.java | 203 +
.../SubscriptionSessionConnectionTimeoutTest.java | 148 +
.../SubscriptionConsumerConnectionFailureTest.java | 167 +
...SubscriptionConsumerHeartbeatIsolationTest.java | 341 ++
.../base/SubscriptionConsumerLifecycleTest.java | 590 +-
.../SubscriptionConsumerMultiProviderPollTest.java | 281 +
.../base/SubscriptionProviderSlicingTest.java | 232 +
.../base/SubscriptionProviderStatusTest.java | 72 +
.../subscription/payload/TypeServicesTest.java | 69 +
iotdb-core/ainode/ainode.xml | 6 +-
.../iotdb/ainode/core/model/chronos2/__init__.py | 2 +
.../iotdb/ainode/core/model/chronos2/base.py | 3 +
.../ainode/core/model/chronos2/chronos_bolt.py | 3 +
.../iotdb/ainode/core/model/chronos2/config.py | 3 +
.../iotdb/ainode/core/model/chronos2/dataset.py | 3 +
.../iotdb/ainode/core/model/chronos2/layers.py | 3 +
.../iotdb/ainode/core/model/chronos2/model.py | 3 +
.../core/model/chronos2/pipeline_chronos2.py | 3 +
.../iotdb/ainode/core/model/chronos2/utils.py | 3 +
.../iotdb/ainode/core/model/moirai2/__init__.py | 6 +-
.../ainode/core/model/moirai2/common/torch_util.py | 5 +
.../ainode/core/model/moirai2/modeling_moirai2.py | 5 +
.../ainode/core/model/moirai2/module/attention.py | 5 +
.../iotdb/ainode/core/model/moirai2/module/ffn.py | 5 +
.../iotdb/ainode/core/model/moirai2/module/norm.py | 5 +
.../core/model/moirai2/module/packed_scaler.py | 5 +
.../core/model/moirai2/module/position/__init__.py | 5 +
.../core/model/moirai2/module/position/additive.py | 5 +
.../model/moirai2/module/position/attn_bias.py | 5 +
.../moirai2/module/position/attn_projection.py | 5 +
.../core/model/moirai2/module/transformer.py | 5 +
.../ainode/core/model/moirai2/module/ts_embed.py | 5 +
.../ainode/core/model/moirai2/transform/_base.py | 5 +
.../ainode/core/model/moirai2/transform/_mixin.py | 5 +
.../core/model/moirai2/transform/imputation.py | 5 +
.../core/model/moment/configuration_moment.py | 1 +
.../ainode/core/model/moment/modeling_moment.py | 1 +
.../ainode/core/model/moment/pipeline_moment.py | 1 +
.../iotdb/ainode/core/model/sundial/flow_loss.py | 80 +-
.../ainode/src/assembly/resources/NOTICE-binary | 65 +
.../src/assembly/resources/licenses/LICENSE-GLIDE | 21 +
.../src/assembly/resources/licenses/LICENSE-MOMENT | 21 +
iotdb-core/ainode/tests/test_sundial_flow_loss.py | 123 +
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 3 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 15 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 12 +
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 113 +
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 113 +
.../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 +-
.../fill/filter/FixedIntervalFillFilter.java | 4 +-
.../operator/process/fill/linear/LinearFill.java | 6 +-
.../process/function/TableFunctionOperator.java | 51 +-
.../process/function/partition/PartitionCache.java | 2 +-
.../process/gapfill/AbstractGapFillOperator.java | 22 +-
.../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 | 205 +-
.../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 +
.../rate/AbstractGroupedDeltaAccumulator.java | 138 +
.../rate/AbstractGroupedIncreaseAccumulator.java | 147 +
.../rate/AbstractGroupedIrateAccumulator.java | 83 +
.../rate/AbstractGroupedRateAccumulator.java | 150 +
.../grouped/rate/GroupedNaiveDeltaAccumulator.java | 140 +
.../rate/GroupedNaiveIncreaseAccumulator.java | 150 +
.../grouped/rate/GroupedNaiveIrateAccumulator.java | 119 +
.../grouped/rate/GroupedNaiveRateAccumulator.java | 150 +
.../rate/GroupedOrderedDeltaAccumulator.java | 159 +
.../rate/GroupedOrderedIncreaseAccumulator.java | 167 +
.../rate/GroupedOrderedIrateAccumulator.java | 142 +
.../rate/GroupedOrderedRateAccumulator.java | 167 +
.../grouped/rate/TimeValueBufferBigArray.java | 75 +
.../rate/AbstractDeltaTableAccumulator.java | 109 +
.../rate/AbstractIncreaseTableAccumulator.java | 118 +
.../rate/AbstractIrateTableAccumulator.java | 78 +
.../rate/AbstractRateTableAccumulator.java | 121 +
.../aggregation/rate/ExtrapolationUtil.java | 139 +
.../aggregation/rate/NaiveDeltaAccumulator.java | 154 +
.../aggregation/rate/NaiveIncreaseAccumulator.java | 170 +
.../aggregation/rate/NaiveIrateAccumulator.java | 142 +
.../aggregation/rate/NaiveRateAccumulator.java | 165 +
.../aggregation/rate/OrderedDeltaAccumulator.java | 142 +
.../rate/OrderedIncreaseAccumulator.java | 149 +
.../aggregation/rate/OrderedIrateAccumulator.java | 133 +
.../aggregation/rate/OrderedRateAccumulator.java | 149 +
.../rate/RateFunctionIntermediateStateCodec.java | 201 +
.../aggregation/rate/RateFunctionType.java} | 46 +-
.../aggregation/rate/RateFunctionValidation.java | 131 +
.../aggregation/rate/TimeValueBuffer.java | 228 +
.../relational/ColumnTransformerBuilder.java | 123 +-
.../calc/plan/planner/CommonOperatorUtils.java | 129 +-
.../calc/plan/planner/TableOperatorGenerator.java | 152 +-
.../planner/memory/MemoryReservationManager.java | 6 +
.../planner/memory/PipelineMemoryEstimator.java | 4 +-
.../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 +-
.../scalar/DateBinFunctionColumnTransformer.java | 66 +-
.../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/SerializableList.java | 28 +-
.../datastructure/row/SerializableRowList.java | 64 +-
.../datastructure/tv/SerializableTVList.java | 40 +-
.../org/apache/iotdb/calc/utils/TypeServices.java | 5675 ++++++++++++++++++++
.../iotdb/calc/utils/constant/SqlConstant.java | 4 +
.../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 +
.../rate/GroupedRateAccumulatorMemoryTest.java | 96 +
.../aggregation/rate/ExtrapolationUtilTest.java | 65 +
.../rate/RateAccumulatorFactoryTest.java | 181 +
.../aggregation/rate/RateBatchInputTest.java | 253 +
.../RateFunctionIntermediateStateCodecTest.java | 157 +
.../column/unary/scalar/NumericCastBatchTest.java | 184 +
.../apache/iotdb/calc/utils/TypeServicesTest.java | 416 ++
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 100 +-
.../iotdb/confignode/i18n/ManagerMessages.java | 44 +-
.../iotdb/confignode/i18n/ProcedureMessages.java | 32 +-
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 105 +-
.../iotdb/confignode/i18n/ManagerMessages.java | 44 +-
.../iotdb/confignode/i18n/ProcedureMessages.java | 41 +-
.../client/async/CnToDnAsyncRequestType.java | 5 +
.../CnToDnInternalServiceAsyncRequestManager.java | 26 +-
.../handlers/heartbeat/AINodeHeartbeatHandler.java | 4 +-
.../heartbeat/ConfigNodeHeartbeatHandler.java | 4 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 11 +-
.../rpc/DataNodeAsyncRequestRPCHandler.java | 9 +
.../rpc/GetDropTableModProgressRPCHandler.java | 59 +
.../subscription/PullCommitProgressRPCHandler.java | 3 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 104 +-
.../confignode/conf/ConfigNodeDescriptor.java | 14 +
.../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/subscription/topic/DropTopicPlan.java | 31 +-
.../write/table/SetTableColumnPropertiesPlan.java | 80 +
.../partition/GetRegionGroupsByTimeResp.java | 25 +
.../response/pipe/task/PipeTableResp.java | 9 +-
.../statemachine/ConfigRegionStateMachine.java | 22 +-
.../confignode/manager/ClusterQuotaManager.java | 5 +-
.../iotdb/confignode/manager/ConfigManager.java | 324 +-
.../apache/iotdb/confignode/manager/IManager.java | 21 +-
.../iotdb/confignode/manager/ProcedureManager.java | 734 +--
.../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/EventService.java | 5 +-
.../manager/load/service/StatisticsService.java | 2 +-
.../iotdb/confignode/manager/node/NodeManager.java | 25 +-
.../manager/partition/PartitionManager.java | 461 +-
.../partition/RegionGroupExtensionPolicy.java | 4 +-
.../pipe/agent/task/PipeConfigNodeSubtask.java | 21 +
.../pipe/agent/task/PipeConfigNodeTask.java | 10 +
.../pipe/agent/task/PipeConfigNodeTaskAgent.java | 17 +-
.../pipe/agent/task/PipeConfigNodeTaskStage.java | 10 +
.../runtime/PipeRuntimeCoordinator.java | 10 +-
.../runtime/heartbeat/PipeHeartbeat.java | 75 +-
.../runtime/heartbeat/PipeHeartbeatParser.java | 206 +-
.../runtime/heartbeat/PipeHeartbeatScheduler.java | 7 +-
.../pipe/coordinator/task/PipeTaskCoordinator.java | 24 +
.../PipeConfigNodeRemainingTimeMetrics.java | 20 +-
.../PipeTemporaryMetaInCoordinatorMetrics.java | 18 +-
.../metric/sink/PipeConfigRegionSinkMetrics.java | 17 +-
.../source/PipeConfigRegionSourceMetrics.java | 17 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 123 +-
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 7 +
.../sink/protocol/IoTDBConfigRegionAirGapSink.java | 1 +
.../pipe/source/ConfigRegionListeningFilter.java | 2 +
.../manager/schema/ClusterSchemaManager.java | 160 +-
.../subscription/SubscriptionCoordinator.java | 127 +-
.../runtime/SubscriptionRuntimeCoordinator.java | 9 +-
.../confignode/persistence/ProcedureInfo.java | 40 +-
.../persistence/executor/ConfigPlanExecutor.java | 82 +-
.../confignode/persistence/node/NodeInfo.java | 118 +-
.../partition/DatabasePartitionTable.java | 16 +
.../persistence/partition/PartitionInfo.java | 67 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 15 +-
.../schema/CNPhysicalPlanGenerator.java | 48 +-
.../persistence/schema/CNSnapshotFileType.java | 4 +-
.../persistence/schema/ClusterSchemaInfo.java | 40 +-
.../confignode/persistence/schema/ConfigMTree.java | 83 +-
.../persistence/schema/TemplatePreSetTable.java | 3 +-
.../persistence/schema/TemplateTable.java | 3 +-
.../persistence/subscription/SubscriptionInfo.java | 351 +-
.../iotdb/confignode/procedure/Procedure.java | 14 +
.../confignode/procedure/ProcedureExecutor.java | 121 +-
.../procedure/TimeoutExecutorThread.java | 2 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 52 +-
.../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 +-
.../DataPartitionTableIntegrityCheckProcedure.java | 16 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 5 +-
.../impl/pipe/task/AlterPipeProcedureV2.java | 96 +-
.../impl/region/CreateRegionGroupsProcedure.java | 44 +-
.../impl/region/RemoveRegionGroupProcedure.java | 389 --
.../impl/schema/DeactivateTemplateProcedure.java | 3 +-
.../impl/schema/DeleteDatabaseProcedure.java | 111 +-
.../procedure/impl/schema/SchemaUtils.java | 26 +-
.../table/AbstractAlterOrDropTableProcedure.java | 19 +
...re.java => AbstractSetPropertiesProcedure.java} | 71 +-
.../impl/schema/table/CreateTableProcedure.java | 4 +
.../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 +-
.../table/view/CreateTableViewProcedure.java | 9 +
.../runtime/CommitProgressSyncProcedure.java | 17 +-
.../SubscriptionHandleLeaderChangeProcedure.java | 2 +-
.../subscription/CreateSubscriptionProcedure.java | 5 +-
.../subscription/DropSubscriptionProcedure.java | 5 +-
.../subscription/topic/AlterTopicProcedure.java | 70 +-
.../subscription/topic/CreateTopicProcedure.java | 6 +-
.../subscription/topic/DropTopicProcedure.java | 41 +-
.../impl/sync/AuthOperationProcedure.java | 88 +-
.../state/schema/DeleteDatabaseState.java | 5 +-
.../procedure/store/ProcedureFactory.java | 22 +-
.../confignode/procedure/store/ProcedureType.java | 4 +-
.../confignode/procedure/store/ProcedureWAL.java | 10 +-
.../iotdb/confignode/service/ConfigNode.java | 2 +-
.../confignode/service/ConfigNodeShutdownHook.java | 162 +-
.../service/thrift/ConfigNodeRPCService.java | 8 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 +
.../writelog/io/SingleFileLogReader.java | 8 +-
.../main/java/org/apache/iotdb/edge/EdgeNode.java | 122 +
...ToDnInternalServiceAsyncRequestManagerTest.java | 114 +
.../heartbeat/DataNodeHeartbeatHandlerTest.java | 100 +
.../confignode/conf/ConfigNodeConfigTest.java} | 28 +-
.../conf/LoadStatisticsPublisherConfigTest.java | 85 +
.../conf/RegionGroupExtensionPolicyConfigTest.java | 106 +
.../request/ConfigPhysicalPlanSerDeTest.java | 75 +-
.../consensus/response/pipe/PipeTableRespTest.java | 19 +
.../manager/ClusterSchemaManagerTest.java | 141 +
.../ConfigManagerRegionGroupPolicyReloadTest.java | 150 +
.../manager/ConfigManagerShutdownReportTest.java | 161 +
.../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 +++
.../PartitionManagerRegionMaintainTest.java | 70 +
.../runtime/heartbeat/PipeHeartbeatParserTest.java | 383 +-
.../metric/PipeConfigNodeMetricsRestartTest.java | 184 +
.../pipe/sink/PipeConfigNodeThriftRequestTest.java | 8 +-
.../subscription/SubscriptionCoordinatorTest.java | 155 +
.../SubscriptionRuntimeCoordinatorTest.java | 119 +
.../persistence/CNPhysicalPlanGeneratorTest.java | 20 +
.../iotdb/confignode/persistence/NodeInfoTest.java | 266 +
.../confignode/persistence/PartitionInfoTest.java | 76 +-
.../persistence/schema/ClusterSchemaInfoTest.java | 119 +
.../persistence/schema/ConfigMTreeTest.java | 31 +
.../subscription/SubscriptionInfoTest.java | 191 +
.../SubscriptionInfoTopicValidationTest.java | 353 +-
.../confignode/procedure/STMProcedureTest.java | 108 +
.../procedure/env/ConfigNodeProcedureEnvTest.java | 93 +
.../procedure/env/RegionMaintainHandlerTest.java | 303 ++
.../impl/node/RemoveDataNodePersistenceTest.java | 581 ++
.../region/RemoveRegionGroupProcedureTest.java | 100 -
.../procedure/impl/schema/SchemaUtilsTest.java | 91 +
.../impl/schema/table/DropTableProcedureTest.java | 333 ++
.../runtime/CommitProgressSyncProcedureTest.java | 60 +-
.../CreateSubscriptionProcedureTest.java | 2 +-
.../DropSubscriptionProcedureTest.java | 2 +-
.../topic/AlterTopicProcedureTest.java | 82 +-
.../subscription/topic/DropTopicProcedureTest.java | 19 +
.../service/ConfigNodeShutdownHookTest.java | 346 ++
iotdb-core/consensus/pom.xml | 5 +
.../iotdb/consensus/i18n/IoTConsensusMessages.java | 7 +
.../iotdb/consensus/i18n/IoTConsensusMessages.java | 7 +
.../common/request/IndexedConsensusRequest.java | 54 +-
.../iotdb/consensus/config/ConsensusConfig.java | 60 +-
.../config/UserDataTransferAuditClassifier.java | 47 +
.../apache/iotdb/consensus/iot/IoTConsensus.java | 33 +-
.../consensus/iot/IoTConsensusServerImpl.java | 191 +-
.../consensus/iot/client/DispatchLogHandler.java | 131 +-
.../iotdb/consensus/iot/logdispatcher/Batch.java | 10 +
.../logdispatcher/IoTConsensusMemoryManager.java | 70 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 19 +-
.../logdispatcher/LogDispatcherThreadMetrics.java | 104 +-
.../consensus/iot/logdispatcher/SyncStatus.java | 13 +-
.../iot/service/IoTConsensusRPCService.java | 16 +-
.../subscription/SubscriptionQueueAdmission.java | 25 +
.../subscription/SubscriptionQueueRegistry.java | 154 +-
.../SubscriptionQueueRejectionReason.java | 42 +
.../SubscriptionWalRetentionCalculator.java | 20 +-
.../iotdb/consensus/pipe/IoTConsensusV2.java | 4 +-
.../consensus/pipe/IoTConsensusV2ServerImpl.java | 5 +
.../pipe/metric/IoTConsensusV2ServerMetrics.java | 3 -
.../pipe/service/IoTConsensusV2RPCService.java | 16 +-
.../ratis/ApplicationStateMachineProxy.java | 12 +-
.../consensus/ratis/RateLimitedGrpcFactory.java | 40 -
.../ratis/RateLimitedGrpcLogAppender.java | 76 -
.../iotdb/consensus/ratis/RatisConsensus.java | 2 -
.../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 +-
.../consensus/iot/IoTConsensusServerImplTest.java | 36 +
.../iot/client/DispatchLogHandlerTest.java | 173 +
.../IoTConsensusMemoryManagerTest.java | 78 +
.../LogDispatcherThreadMetricsTest.java | 146 +
.../iot/logdispatcher/SyncStatusTest.java | 64 +
.../SubscriptionQueueRegistryTest.java | 150 +
.../SubscriptionWalRetentionCalculatorTest.java | 114 +
.../metric/IoTConsensusV2ServerMetricsTest.java | 107 +
.../ratis/RateLimitedGrpcLogAppenderTest.java | 66 -
.../iotdb/consensus/ratis/RecoverReadTest.java | 70 +
.../apache/iotdb/consensus/ratis/TestUtils.java | 51 +-
.../ratis/metrics/RatisMetricSetTest.java | 134 +
iotdb-core/datanode/pom.xml | 49 +-
iotdb-core/datanode/src/assembly/server.xml | 1 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 106 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 197 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 143 +-
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 8 +-
.../apache/iotdb/db/i18n/ImportWALMessages.java | 163 +
.../iotdb/db/i18n/StorageEngineMessages.java | 51 +-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 99 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 190 +-
.../iotdb/db/i18n/DataNodeQueryMessages.java | 142 +-
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 8 +-
.../apache/iotdb/db/i18n/ImportWALMessages.java | 162 +
.../iotdb/db/i18n/StorageEngineMessages.java | 47 +-
.../org/apache/iotdb/db/audit/DNAuditLogger.java | 257 +
.../db/audit/DataNodeUserDataTransferAuditor.java | 135 +
.../db/audit/UserRoleModificationAuditContext.java | 184 +
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 46 +-
.../apache/iotdb/db/auth/BasicAuthorityCache.java | 9 -
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 68 +-
.../apache/iotdb/db/auth/IAuthorityFetcher.java | 2 -
.../org/apache/iotdb/db/auth/LoginLockManager.java | 20 +-
.../apache/iotdb/db/conf/DataNodeMemoryConfig.java | 47 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 217 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 185 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 283 +-
.../db/consensus/DataRegionConsensusImpl.java | 27 +
.../dataregion/DataRegionStateMachine.java | 8 +-
.../load/LoadAnalyzeInvalidPathException.java} | 9 +-
...java => DeviceEntrySpillNotFoundException.java} | 22 +-
.../query/QueryTimeoutRuntimeException.java | 7 +-
.../iotdb/db/lbac/AllowAllLBACAccessControl.java | 47 +
.../apache/iotdb/db/lbac/ILBACAccessControl.java | 74 +
.../db/partition/DataPartitionTableGenerator.java | 8 +-
.../dataregion/PipeDataRegionSinkConstructor.java | 3 -
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 167 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 24 +-
.../iotdb/db/pipe/agent/task/PipeDataNodeTask.java | 16 +
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 321 +-
.../agent/task/builder/PipeDataNodeBuilder.java | 2 +-
.../task/builder/PipeDataNodeTaskBuilder.java | 57 +-
.../agent/task/connection/PipeEventCollector.java | 48 +-
.../agent/task/stage/PipeTaskProcessorStage.java | 2 +
.../pipe/agent/task/stage/PipeTaskSinkStage.java | 19 +-
.../pipe/agent/task/stage/PipeTaskSourceStage.java | 18 +
.../subtask/processor/PipeProcessorSubtask.java | 111 +-
.../PipeProcessorSubtaskExecutionGuard.java | 126 +
.../processor/PipeProcessorSubtaskWorker.java | 158 +-
.../PipeProcessorSubtaskWorkerManager.java | 15 +-
.../PipeProcessorSubtaskYieldException.java | 53 +
.../sink/PipeRealtimePriorityBlockingQueue.java | 4 +-
.../agent/task/subtask/sink/PipeSinkSubtask.java | 134 +-
.../subtask/sink/PipeSinkSubtaskLifeCycle.java | 10 +
.../task/subtask/sink/PipeSinkSubtaskManager.java | 251 +-
.../deletion/persist/PageCacheDeletionBuffer.java | 89 +-
.../consensus/deletion/recover/DeletionReader.java | 7 +-
.../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 +
.../tsfile/PipeCompactedTsFileInsertionEvent.java | 1 +
.../common/tsfile/PipeTsFileInsertionEvent.java | 871 ++-
.../tsfile/parser/TsFileInsertionEventParser.java | 57 +-
.../TsFileInsertionEventParserMemoryBlock.java} | 29 +-
.../TsFileInsertionEventParserMemoryManager.java | 143 +
.../parser/TsFileInsertionEventParserProvider.java | 62 +
.../query/TsFileInsertionEventQueryParser.java | 75 +-
...ileInsertionEventQueryParserTabletIterator.java | 12 +-
.../parser/scan/SinglePageWholeChunkReader.java | 41 +-
.../scan/TsFileInsertionEventScanParser.java | 442 +-
.../table/TsFileInsertionEventTableParser.java | 113 +-
...ileInsertionEventTableParserTabletIterator.java | 225 +-
.../tsfile/parser/util/ModsOperationUtil.java | 33 +-
.../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 | 85 +-
.../schema/PipeSchemaRegionSourceMetrics.java | 16 +-
.../metric/sink/PipeDataRegionSinkMetrics.java | 290 +-
.../db/pipe/metric/source/PipeAssignerMetrics.java | 13 +-
.../metric/source/PipeDataRegionSourceMetrics.java | 20 +-
.../processor/aggregate/AggregateProcessor.java | 175 +-
.../aggregate/TimeSeriesRuntimeState.java | 23 +
.../CustomizedReadableIntermediateResults.java | 164 +-
.../numeric/AbstractSameTypeNumericOperator.java | 119 +-
.../processor/TumblingWindowingProcessor.java | 31 +-
.../downsampling/DownSamplingProcessor.java | 3 +
.../downsampling/DownSamplingTimeUtils.java} | 39 +-
.../downsampling/PartialPathLastObjectCache.java | 13 +-
.../downsampling/changing/ChangingValueFilter.java | 19 +-
.../sdt/SwingingDoorTrendingFilter.java | 23 +-
.../tumbling/TumblingTimeSamplingProcessor.java | 9 +-
.../payload/FetchCombineResultRequest.java | 2 +-
.../twostage/plugin/TwoStageCountProcessor.java | 29 +-
.../protocol/airgap/IoTDBAirGapReceiver.java | 65 +-
.../iotconsensusv2/IoTConsensusV2Receiver.java | 6 +-
.../protocol/legacy/loader/TsFileLoader.java | 2 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 490 +-
.../transform/converter/ValueConverter.java | 141 +-
.../PipeConvertedInsertTabletStatement.java | 25 +
...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 4 +-
.../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 | 1063 +++-
.../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 | 152 +-
.../resource/tsfile/PipeTsFileResourceManager.java | 125 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 7 +
.../IoTDBDataNodeCacheLeaderClientManager.java | 8 +-
.../batch/PipeSchemaRegionWritePlanEventBatch.java | 9 +-
.../evolvable/batch/PipeTabletEventBatch.java | 107 +-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 139 +-
.../batch/PipeTabletEventTsFileBatch.java | 113 +-
.../batch/PipeTransferBatchReqBuilder.java | 95 +-
.../request/PipeTransferTabletBatchReqV2.java | 42 +-
.../request/PipeTransferTsFileSealWithModReq.java | 263 +-
.../protocol/airgap/IoTDBDataNodeAirGapSink.java | 1 +
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 65 +-
.../airgap/IoTDBSchemaRegionAirGapSink.java | 2 +-
.../iotconsensusv2/IoTConsensusV2AsyncSink.java | 46 +-
.../iotconsensusv2/IoTConsensusV2SyncSink.java | 94 +-
.../IoTConsensusV2TabletBatchEventHandler.java | 8 +
.../IoTConsensusV2TabletInsertionEventHandler.java | 11 +
.../IoTConsensusV2TsFileInsertionEventHandler.java | 24 +-
.../IoTConsensusV2TransferBatchReqBuilder.java | 21 +-
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 7 +-
.../sink/protocol/opcda/OpcDaServerHandle.java | 73 +-
.../db/pipe/sink/protocol/opcda/OpcDaSink.java | 9 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 777 ++-
.../PipeTransferTabletBatchEventHandler.java | 2 +-
.../PipeTransferTabletInsertNodeEventHandler.java | 13 +-
.../PipeTransferTabletInsertionEventHandler.java | 8 +-
.../handler/PipeTransferTrackableHandler.java | 94 +-
.../async/handler/PipeTransferTsFileHandler.java | 312 +-
.../thrift/sync/IoTDBDataRegionSyncSink.java | 68 +-
.../thrift/sync/IoTDBSchemaRegionSink.java | 6 +-
.../sink/protocol/writeback/WriteBackSink.java | 105 +-
.../sink/util/PipeTabletEventTransferUtils.java | 97 +
.../pipe/sink/util/TabletStatementConverter.java | 128 +-
.../util/builder/PipeTableModelTsFileBuilder.java | 50 +-
.../builder/PipeTableModelTsFileBuilderV2.java | 56 +-
.../util/builder/PipeTreeModelTsFileBuilder.java | 37 +-
.../util/builder/PipeTreeModelTsFileBuilderV2.java | 46 +-
.../pipe/sink/util/builder/PipeTsFileBuilder.java | 30 +-
.../db/pipe/sink/util/cacher/LeaderCacheUtils.java | 44 +-
.../sink/util/sorter/PipeInsertEventSorter.java | 106 +-
.../dataregion/DataRegionListeningFilter.java | 18 +-
.../dataregion/DataRegionWatermarkInjector.java | 10 +-
.../source/dataregion/IoTDBDataRegionSource.java | 40 +-
...istoricalDataRegionTsFileAndDeletionSource.java | 68 +-
.../PipeRealtimeDataRegionHybridSource.java | 684 ++-
.../realtime/PipeRealtimeDataRegionLogSource.java | 1 +
.../realtime/PipeRealtimeDataRegionSource.java | 89 +-
.../PipeRealtimeDataRegionTsFileSource.java | 151 +-
.../realtime/assigner/DisruptorQueue.java | 8 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 244 +-
.../listener/PipeInsertionDataNodeListener.java | 77 +-
.../matcher/CachedSchemaPatternMatcher.java | 56 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 297 +-
.../iotdb/db/protocol/client/ConfigNodeInfo.java | 148 +-
.../iotdb/db/protocol/session/ClientSession.java | 23 +
.../iotdb/db/protocol/session/IClientSession.java | 3 +
.../db/protocol/session/InternalClientSession.java | 5 +
.../db/protocol/session/MqttClientSession.java | 5 +
.../db/protocol/session/RestClientSession.java | 11 +-
.../handler/RPCServiceThriftHandlerMetrics.java | 37 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 151 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 288 +-
.../thrift/impl/DataNodeRegionManager.java | 18 +-
.../thrift/impl/PushMultiPipeMetaHelper.java | 36 +-
.../db/queryengine/common/MPPQueryContext.java | 130 +-
.../db/queryengine/common/TimeseriesContext.java | 4 +-
.../common/header/DatasetHeaderFactory.java | 8 +
.../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 +-
.../aggregation/TimeDurationAccumulator.java | 7 +-
.../timerangeiterator/AggrWindowIterator.java | 44 +-
.../timerangeiterator/ITimeRangeIterator.java | 43 +-
.../timerangeiterator/PreAggrWindowIterator.java | 48 +-
.../PreAggrWindowWithNaturalMonthIterator.java | 14 +-
.../TableDateBinTimeRangeIterator.java | 6 +-
.../queryengine/execution/driver/DataDriver.java | 65 +-
.../execution/driver/DataDriverContext.java | 2 +
.../db/queryengine/execution/driver/Driver.java | 6 +
.../execution/exchange/MPPDataExchangeManager.java | 161 +-
.../execution/exchange/MPPDataExchangeService.java | 7 +-
.../execution/exchange/sink/ShuffleSinkHandle.java | 162 +-
.../execution/exchange/sink/SinkChannel.java | 73 +-
.../execution/exchange/source/SourceHandle.java | 260 +-
.../execution/executor/RegionWriteExecutor.java | 36 +-
.../fragment/FakedFragmentInstanceContext.java | 84 +-
.../fragment/FragmentInstanceContext.java | 454 +-
.../fragment/FragmentInstanceExecution.java | 11 +-
.../fragment/FragmentInstanceFailureInfo.java | 4 +-
.../FragmentInstanceFinishedException.java} | 27 +-
.../fragment/FragmentInstanceManager.java | 22 +-
.../execution/fragment/QueryContext.java | 23 +-
.../execution/fragment/QueryDataSourceLease.java | 58 +
.../queryengine/execution/memory/MemoryPool.java | 5 +-
.../execution/operator/AggregationUtil.java | 34 +-
.../process/InsertTabletStatementGenerator.java | 137 +-
.../operator/process/TransformOperator.java | 45 +-
.../operator/process/ai/InferenceOperator.java | 30 +-
.../process/copyto/TableCopyToOperator.java | 29 +-
.../process/copyto/tsfile/CopyToTsFileOptions.java | 13 +-
.../copyto/tsfile/TsFileFormatCopyToWriter.java | 26 +-
.../process/last/LastQueryCollectOperator.java | 12 +-
.../schema/source/DeviceBlackListConstructor.java | 14 +-
.../operator/source/DataSourceOperator.java | 10 +
.../execution/operator/source/FileLoaderUtils.java | 4 +
.../source/PipeReceiverRuntimeSnapshotFilter.java | 63 +
.../execution/operator/source/SeriesScanUtil.java | 530 +-
.../operator/source/ShowReceiversOperator.java | 177 +
.../relational/AbstractAggTableScanOperator.java | 152 +-
.../AbstractDefaultAggTableScanOperator.java | 14 +
.../relational/AbstractTableScanOperator.java | 174 +-
.../relational/DeviceIteratorScanOperator.java | 195 +-
.../InformationSchemaContentSupplierFactory.java | 265 +-
.../relational/LastQueryAggTableScanOperator.java | 28 +-
...onAlignedDeviceViewAggregationScanOperator.java | 102 +-
.../operator/window/WindowManagerFactory.java | 62 +-
.../execution/schedule/DriverScheduler.java | 9 +-
.../execution/schedule/DriverTaskThread.java | 35 +-
.../metric/SeriesScanCostMetricSet.java | 86 +
.../iotdb/db/queryengine/plan/Coordinator.java | 110 +-
.../db/queryengine/plan/analyze/Analysis.java | 2 +
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 14 +
.../queryengine/plan/analyze/AnalyzeVisitor.java | 92 +-
.../plan/analyze/ClusterPartitionFetcher.java | 119 +-
.../plan/analyze/IPartitionFetcher.java | 14 +
.../analyze/cache/partition/PartitionCache.java | 271 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 76 +-
.../analyze/load/LoadTsFileTableSchemaCache.java | 2 +-
.../analyze/load/LoadTsFileTreeSchemaCache.java | 6 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 21 +-
.../plan/analyze/schema/ISchemaFetcher.java | 19 +
.../plan/analyze/schema/SchemaValidator.java | 95 +-
.../queryengine/plan/execution/QueryExecution.java | 17 +
.../execution/config/TableConfigTaskVisitor.java | 153 +-
.../execution/config/TreeConfigTaskVisitor.java | 37 +-
.../config/executor/ClusterConfigTaskExecutor.java | 108 +-
.../config/executor/IConfigTaskExecutor.java | 9 +
.../config/metadata/DatabaseSchemaTask.java | 3 +
.../config/metadata/ShowClusterDetailsTask.java | 63 +-
.../execution/config/metadata/ShowClusterTask.java | 40 +-
.../config/metadata/ShowConfigNodesTask.java | 28 +-
.../config/metadata/ShowDataNodesTask.java | 30 +-
.../metadata/relational/AbstractDatabaseTask.java | 1 +
...java => AlterTableSetColumnPropertiesTask.java} | 39 +-
.../relational/RelationalAuthorizerTask.java | 9 +-
.../metadata/relational/ShowCreatePipeTask.java | 7 +-
.../metadata/relational/ShowCreateTableTask.java | 8 +-
.../config/metadata/relational/ShowDBTask.java | 1 +
.../metadata/relational/ShowTablesDetailsTask.java | 3 +
.../plan/execution/config/sys/AuthorizerTask.java | 11 +-
.../execution/config/sys/pipe/ShowPipeTask.java | 9 +
.../sys/subscription/ShowSubscriptionsTask.java | 50 +
.../plan/expression/ExpressionFactory.java | 19 +-
.../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 +-
.../ConcatDeviceAndBindSchemaForHavingVisitor.java | 14 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 47 +-
.../plan/optimization/LimitOffsetPushDown.java | 103 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 99 +-
.../planner/DataNodeTableOperatorGenerator.java | 403 +-
.../plan/planner/LocalExecutionPlanContext.java | 2 +-
.../plan/planner/LocalExecutionPlanner.java | 17 +-
.../plan/planner/LogicalPlanBuilder.java | 39 +
.../plan/planner/LogicalPlanVisitor.java | 7 +
.../plan/planner/OperatorGeneratorUtil.java | 28 +-
.../plan/planner/OperatorTreeGenerator.java | 79 +-
.../SimpleFragmentParallelPlanner.java | 2 +
.../ConsumeAllChildrenPipelineMemoryEstimator.java | 1 +
...umeChildrenOneByOnePipelineMemoryEstimator.java | 1 +
.../memory/FakedMemoryReservationManager.java | 3 +
.../NotThreadSafeMemoryReservationManager.java | 16 +-
....java => OperatorMemoryNotEnoughException.java} | 29 +-
.../memory/PipelineMemoryEstimatorFactory.java | 1 +
.../memory/ThreadSafeMemoryReservationManager.java | 5 +
.../plan/node/DataNodePlanNodeDeserializer.java | 3 +
.../planner/plan/node/PlanGraphJsonPrinter.java | 2 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 5 +-
.../plan/planner/plan/node/PlanVisitor.java | 5 +
.../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/ShowReceiversNode.java | 115 +
.../plan/node/source/TimeseriesRegionScanNode.java | 10 +-
.../plan/node/write/InsertMultiTabletsNode.java | 5 +-
.../planner/plan/node/write/InsertRowNode.java | 218 +-
.../planner/plan/node/write/InsertRowsNode.java | 5 +-
.../planner/plan/node/write/InsertTabletNode.java | 366 +-
.../plan/node/write/RelationalInsertRowsNode.java | 5 +-
.../node/write/RelationalInsertTabletNode.java | 4 +
.../planner/plan/parameter/SeriesScanOptions.java | 9 +-
.../parameter/model/ModelInferenceDescriptor.java | 4 +-
.../plan/relational/analyzer/Analyzer.java | 2 +-
.../relational/analyzer/StatementAnalyzer.java | 250 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 85 +-
.../read_tsfile/ExternalTsFileQueryResource.java | 7 +-
.../AdditionalInformationSchemaProvider.java | 59 +
...ditionalInformationSchemaProviderRegistry.java} | 29 +-
.../plan/relational/metadata/DeviceEntry.java | 19 +-
.../plan/relational/metadata/Metadata.java | 22 +-
.../relational/metadata/TableMetadataImpl.java | 96 +-
.../metadata/fetcher/DeviceEntryFetchContext.java | 71 +
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 226 +-
.../fetcher/cache/TableDeviceSchemaCache.java | 38 +-
.../cache/TreeDeviceSchemaCacheManager.java | 9 +
.../spill/AbstractDeviceEntryMaterializer.java | 254 +
.../metadata/spill/BatchDeviceEntrySource.java} | 19 +-
.../metadata/spill/DeviceEntryDataSet.java | 55 +
.../metadata/spill/DeviceEntryDataSetHandle.java | 113 +
.../metadata/spill/DeviceEntryDataSetResult.java} | 37 +-
.../metadata/spill/DeviceEntryDiskSpiller.java | 149 +
.../spill/DeviceEntryFileSpillerReader.java | 162 +
.../metadata/spill/DeviceEntryIOContext.java | 60 +
...DeviceEntryMaterializationMemoryController.java | 78 +
.../metadata/spill/DeviceEntryMaterializer.java | 132 +
.../metadata/spill/DeviceEntryReader.java} | 18 +-
.../spill/DeviceEntryRpcSegmentFetcher.java | 126 +
.../metadata/spill/DeviceEntrySegmentFetcher.java} | 12 +-
.../spill/DeviceEntrySortedMaterializer.java | 373 ++
.../metadata/spill/DeviceEntrySpillManager.java | 256 +
.../metadata/spill/InMemoryDeviceEntryDataSet.java | 90 +
.../metadata/spill/InMemoryDeviceEntrySource.java | 35 +-
.../spill/LocalSegmentDeviceEntrySource.java | 92 +
.../spill/RemoteSegmentDeviceEntrySource.java | 65 +
.../metadata/spill/SegmentDeviceEntrySource.java | 88 +
.../metadata/spill/SpilledDeviceEntryDataSet.java | 95 +
.../plan/relational/planner/RelationPlanner.java | 12 +-
.../plan/relational/planner/TableModelPlanner.java | 6 +-
.../distribute/TableDistributedPlanGenerator.java | 1662 +++++-
.../distribute/TableModelQueryFragmentPlanner.java | 18 +-
.../ir/GapFillStartAndEndTimeExtractVisitor.java | 6 +
...ithUncorrelatedScalarSubqueryReconstructor.java | 40 +-
.../iterative/rule/PruneTableScanColumns.java | 14 +-
.../planner/node/AggregationTableScanNode.java | 213 +-
.../node/AggregationTreeDeviceViewScanNode.java | 45 +-
.../AlignedAggregationTreeDeviceViewScanNode.java | 45 +-
.../planner/node/DeviceTableScanNode.java | 94 +-
...onAlignedAggregationTreeDeviceViewScanNode.java | 45 +-
.../node/TreeAlignedDeviceViewScanNode.java | 33 +-
.../planner/node/TreeDeviceViewScanNode.java | 33 +-
.../node/TreeNonAlignedDeviceViewScanNode.java | 33 +-
.../TableDeviceAttributeCommitUpdateNode.java | 4 +-
.../DataNodeLocationSupplierFactory.java | 12 +
.../PushAggregationIntoTableScan.java | 20 +-
.../optimizations/PushPredicateIntoTableScan.java | 171 +-
.../optimizations/QueryCardinalityUtil.java | 4 +-
.../planner/optimizations/SortElimination.java | 67 +-
.../optimizations/TableFunctionOrdering.java | 79 +
.../TransformAggregationToStreamable.java | 5 +-
.../optimizations/TransformSortToStreamSort.java | 45 +-
.../optimizations/UnaliasSymbolReferences.java | 12 +-
.../relational/planner/optimizations/Util.java | 1 +
.../relational/security/AccessControlImpl.java | 22 +-
.../security/TreeAccessCheckVisitor.java | 41 +-
.../relational/sql/ast/AbstractTraverseDevice.java | 5 +-
.../plan/relational/sql/ast/AstVisitor.java | 4 +
.../sql/ast/DefaultTraversalVisitor.java | 9 +
.../plan/relational/sql/ast/LoadTsFile.java | 32 +-
.../relational/sql/ast/SetColumnProperties.java | 140 +
.../plan/relational/sql/ast/ShowSubscriptions.java | 16 +-
.../plan/relational/sql/parser/AstBuilder.java | 92 +-
.../relational/sql/util/DataNodeSqlFormatter.java | 33 +-
.../plan/scheduler/AsyncPlanNodeSender.java | 46 +-
.../plan/scheduler/AsyncSendPlanNodeHandler.java | 53 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 45 +
.../scheduler/load/LoadTsFileDispatcherImpl.java | 174 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 36 +-
.../queryengine/plan/statement/StatementType.java | 2 +
.../plan/statement/StatementVisitor.java | 10 +
.../plan/statement/crud/InsertBaseStatement.java | 46 +
.../plan/statement/crud/InsertRowStatement.java | 29 +-
.../plan/statement/crud/InsertRowsStatement.java | 17 +
.../plan/statement/crud/InsertTabletStatement.java | 72 +-
.../plan/statement/crud/LoadTsFileStatement.java | 95 +-
.../metadata/DatabaseSchemaStatement.java | 15 +
.../statement/metadata/ShowDatabaseStatement.java | 1 +
.../metadata/pipe/ShowPipeMemoryStatement.java | 58 +
.../subscription/ShowSubscriptionsStatement.java | 9 +
.../plan/statement/sys/ShowReceiversStatement.java | 61 +
.../FragmentInstanceStatisticsDrawer.java | 23 +
.../FragmentInstanceStatisticsJsonDrawer.java | 14 +
.../statistics/QueryPlanStatistics.java | 39 +
...ializableRowRecordListBackedMultiColumnRow.java | 2 +-
.../dag/input/ConstantInputReader.java | 63 +-
.../dag/intermediate/MultiInputLayer.java | 9 +-
.../SingleInputMultiReferenceLayer.java | 9 +-
.../SingleInputSingleReferenceLayer.java | 9 +-
.../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 | 65 +-
.../schemaengine/lease/MetadataLeaseManager.java | 4 +-
.../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 | 103 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 59 +-
.../schemaregion/logfile/SchemaLogReader.java | 14 +-
.../schemaregion/logfile/SchemaLogWriter.java | 28 +-
.../visitor/SchemaRegionPlanDeserializer.java | 18 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 29 +-
.../impl/mem/mnode/impl/BasicInternalMNode.java | 60 +-
.../impl/mem/snapshot/MemMTreeSnapshotUtil.java | 2 +
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 12 +-
.../impl/pbtree/flush/PBTreeFlushExecutor.java | 2 +
.../mtree/impl/pbtree/schemafile/SchemaFile.java | 23 +-
.../pbtree/schemafile/log/SchemaFileLogReader.java | 3 +-
.../pbtree/schemafile/pagemgr/PageIOChannel.java | 12 +-
.../schemaregion/mtree/traverser/Traverser.java | 6 +
.../schemaengine/schemaregion/tag/TagManager.java | 59 +-
.../schemaregion/utils/MetaFormatUtils.java | 23 +
.../schemaregion/utils/ResourceByPathUtils.java | 344 +-
.../db/schemaengine/table/DataNodeTableCache.java | 56 +-
.../iotdb/db/schemaengine/table/ITableCache.java | 2 +
.../schemaengine/table/InformationSchemaUtils.java | 4 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 17 +-
.../db/service/DataNodeInternalRPCService.java | 8 +-
.../iotdb/db/service/DataNodeShutdownHook.java | 8 +-
.../iotdb/db/service/ExternalRPCService.java | 14 +-
.../iotdb/db/service/RegionMigrateService.java | 12 +-
.../iotdb/db/service/metrics/CacheMetrics.java | 17 +
.../service/metrics/DataNodeExceptionMetrics.java | 104 +
.../db/service/metrics/DataNodeMetricsHelper.java | 3 +
.../metrics/IoTDBInternalLocalReporter.java | 1 +
.../iotdb/db/service/metrics/WritingMetrics.java | 114 +-
.../db/service/metrics/file/TsFileMetrics.java | 22 +
.../iotdb/db/storageengine/StorageEngine.java | 64 +-
.../db/storageengine/dataregion/DataRegion.java | 235 +-
.../dataregion/DataRegionMetrics.java | 49 +-
.../performer/impl/FastCompactionPerformer.java | 8 +-
.../impl/ReadChunkCompactionPerformer.java | 2 +-
.../impl/ReadPointCompactionPerformer.java | 2 +-
.../execute/task/AbstractCompactionTask.java | 2 +
.../execute/utils/CompactionPathUtils.java | 12 +-
.../compaction/execute/utils/CompactionUtils.java | 15 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 49 +-
.../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 +-
.../compaction/schedule/CompactionScheduler.java | 2 +
.../impl/RewriteCrossSpaceCompactionSelector.java | 3 +-
.../selector/impl/SettleSelectorImpl.java | 12 +-
.../dataregion/flush/CompressionRatio.java | 5 +-
.../dataregion/flush/MemTableFlushTask.java | 25 +-
.../dataregion/memtable/AbstractMemTable.java | 90 +-
.../memtable/AbstractWritableMemChunk.java | 35 +-
.../memtable/AlignedReadOnlyMemChunk.java | 138 +-
.../memtable/AlignedWritableMemChunk.java | 520 +-
.../memtable/AlignedWritableMemChunkGroup.java | 37 +-
.../dataregion/memtable/IMemTable.java | 18 +-
.../dataregion/memtable/IWritableMemChunk.java | 14 +-
.../memtable/IWritableMemChunkGroup.java | 12 +-
.../memtable/MemChunkTimeRangeUtils.java | 56 +
.../dataregion/memtable/ReadOnlyMemChunk.java | 104 +-
.../dataregion/memtable/TsFileProcessor.java | 221 +-
.../memtable/TsFileProcessorInfoMetrics.java | 55 +-
.../dataregion/memtable/WritableMemChunk.java | 153 +-
.../dataregion/memtable/WritableMemChunkGroup.java | 26 +-
.../modification/DropTableModProgress.java | 65 +
.../dataregion/modification/TagPredicate.java | 24 +
.../modification/v1/ModificationFileV1.java | 4 +-
.../v1/io/LocalTextModificationAccessor.java | 37 +-
.../dataregion/read/control/FileReaderManager.java | 698 ++-
.../read/reader/chunk/MemAlignedPageReader.java | 52 +-
.../read/reader/chunk/MemPageReader.java | 84 +-
.../dataregion/snapshot/SnapshotTaker.java | 6 +-
.../dataregion/tsfile/TsFileLock.java | 27 +-
.../dataregion/tsfile/TsFileResource.java | 28 +-
.../tsfile/generator/TsFileNameGenerator.java | 3 +-
.../tsfile/timeindex/ArrayDeviceTimeIndex.java | 8 +-
.../dataregion/tsfile/timeindex/FileTimeIndex.java | 4 +-
.../tsfile/timeindex/PlainDeviceTimeIndex.java | 4 +-
.../dataregion/utils/DiskUsageStatisticUtil.java | 12 +-
.../utils/TableDiskUsageStatisticUtil.java | 2 +
.../utils/TreeDiskUsageStatisticUtil.java | 2 +-
.../dataregion/utils/TsFileResourceUtils.java | 11 +-
.../FileTimeIndexCacheWriter.java | 30 +-
.../tableDiskUsageIndex/TableDiskUsageIndex.java | 2 +
.../tsfile/TsFileTableDiskUsageIndexWriter.java | 4 +
.../tsfile/TsFileTableSizeIndexFileWriter.java | 4 +-
.../tsfile/TsFileTableSizeIndexReader.java | 2 +
.../dataregion/wal/buffer/AbstractWALBuffer.java | 39 +-
.../dataregion/wal/buffer/WALBuffer.java | 156 +-
.../wal/checkpoint/CheckpointManager.java | 10 +-
.../storageengine/dataregion/wal/io/LogWriter.java | 51 +-
.../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 | 22 +-
.../storageengine/dataregion/wal/node/WALNode.java | 136 +-
.../dataregion/wal/recover/WALNodeRecoverTask.java | 56 +-
.../dataregion/wal/recover/WALRepairWriter.java | 125 +-
.../file/AbstractTsFileRecoverPerformer.java | 2 +-
.../recover/file/SealedTsFileRecoverPerformer.java | 2 +
.../wal/recover/file/TsFilePlanRedoer.java | 9 +-
.../file/UnsealedTsFileRecoverPerformer.java | 23 +-
.../db/storageengine/load/LoadTsFileManager.java | 82 +-
.../db/storageengine/load/LoadTsFilePathUtils.java | 47 +
.../load/LoadTsFilePieceNodeAssembler.java | 170 +
.../load/active/ActiveLoadDirScanner.java | 33 +-
.../load/active/ActiveLoadPathHelper.java | 103 +
.../load/active/ActiveLoadPendingQueue.java | 26 +-
.../load/active/ActiveLoadTsFileLoader.java | 86 +-
.../load/config/LoadTsFileConfigurator.java | 23 +
.../LoadConvertedInsertTabletStatement.java | 4 +
...leStatementDataTypeConvertExecutionVisitor.java | 168 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 300 +-
.../converter/LoadTreeTsFileTabletIterator.java | 63 +-
.../converter/LoadTsFileDataTypeConverter.java | 2 +-
.../converter/PipeTsFileConversionTaskManager.java | 543 ++
.../load/memory/LoadTsFileMemoryBlock.java | 20 +-
.../load/memory/LoadTsFileParserMemoryManager.java | 121 +
.../load/metrics/ActiveLoadingFilesMetricsSet.java | 6 +
.../ActiveLoadingFilesNumberMetricsSet.java | 16 +-
.../load/metrics/LoadTsFileMemMetricSet.java | 19 +-
.../load/splitter/AlignedChunkData.java | 110 +-
.../splitter/BatchedAlignedValueChunkData.java | 87 +-
.../load/splitter/NonAlignedChunkData.java | 77 +-
.../load/splitter/TsFileSplitter.java | 27 +-
.../iotdb/db/storageengine/load/util/LoadUtil.java | 169 +-
.../db/storageengine/rescon/disk/TierManager.java | 4 +
.../rescon/memory/PrimitiveArrayManager.java | 89 +-
.../agent/SubscriptionBrokerAgent.java | 125 +-
.../agent/SubscriptionConsumerAgent.java | 211 +-
.../agent/SubscriptionReceiverAgent.java | 339 +-
.../agent/SubscriptionRuntimeAgent.java | 2 +
.../subscription/agent/SubscriptionTopicAgent.java | 240 +-
.../broker/ConsensusSubscriptionBroker.java | 314 +-
.../subscription/broker/ISubscriptionBroker.java | 11 +
.../db/subscription/broker/SubscriptionBroker.java | 49 +-
.../broker/SubscriptionPrefetchingQueue.java | 160 +-
.../broker/SubscriptionPrefetchingQueueStates.java | 28 +-
.../TsFileDeduplicationBlockingPendingQueue.java | 11 +-
.../consensus/ConsensusLogToTabletConverter.java | 100 +-
.../consensus/ConsensusPrefetchingQueue.java | 1815 ++++++-
.../ConsensusSubscriptionCommitManager.java | 190 +-
.../ConsensusSubscriptionSetupHandler.java | 417 +-
.../ConsensusSubscriptionWalRetention.java | 163 +
.../broker/consensus/ProgressWALIterator.java | 640 ++-
.../consensus/SubscriptionQueueTimeTracker.java | 119 +
.../columnfilter/TreeViewTabletProjector.java | 1 -
.../db/subscription/event/SubscriptionEvent.java | 19 +-
.../batch/SubscriptionPipeTabletEventBatch.java | 30 +-
.../batch/SubscriptionPipeTsFileEventBatch.java | 8 +-
.../event/cache/SubscriptionPollResponseCache.java | 32 +-
.../response/SubscriptionEventTabletResponse.java | 13 +-
.../response/SubscriptionEventTsFileResponse.java | 13 +-
...nsensusSubscriptionPrefetchingQueueMetrics.java | 280 +-
.../subscription/metric/SubscriptionMetrics.java | 34 +
.../SubscriptionPrefetchingQueueMetrics.java | 55 +-
.../receiver/SubscriptionReceiver.java | 36 +
.../receiver/SubscriptionReceiverV1.java | 356 +-
.../resource/SubscriptionMemoryManager.java | 368 +-
.../ConsensusSubscriptionPrefetchExecutor.java | 10 +
.../task/stage/SubscriptionTaskSinkStage.java | 10 +
.../task/subtask/ConsensusPrefetchSubtask.java | 12 +
.../task/subtask/SubscriptionSinkSubtask.java | 8 +-
.../subtask/SubscriptionSinkSubtaskLifeCycle.java | 7 +-
.../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 +-
.../TsFileOverlapValidationAndRepairTool.java | 13 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 174 +-
.../iotdb/db/utils/DataNodeDateTimeUtils.java | 158 +-
.../iotdb/db/utils/EncodingInferenceUtils.java | 30 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 15 +-
.../apache/iotdb/db/utils/ModificationUtils.java | 20 +-
.../org/apache/iotdb/db/utils/ObjectWriter.java | 31 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 446 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 166 +-
.../org/apache/iotdb/db/utils/TabletDecoder.java | 80 +-
.../iotdb/db/utils/TimeFilterForDeviceTTL.java | 5 +-
.../apache/iotdb/db/utils/TimeValuePairUtils.java | 67 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 31 +-
.../org/apache/iotdb/db/utils/TypeServices.java | 4457 +++++++++++++++
.../db/utils/datastructure/AlignedTVList.java | 1535 +++---
.../db/utils/datastructure/BackAlignedTVList.java | 7 +-
.../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 +-
.../db/utils/datastructure/QuickAlignedTVList.java | 7 +-
.../iotdb/db/utils/datastructure/TVList.java | 362 +-
.../db/utils/datastructure/TimAlignedTVList.java | 9 +-
.../SlidingTimeWindowEvaluationHandler.java | 22 +-
.../db/utils/windowing/window/WindowImpl.java | 75 +-
.../apache/iotdb/db/utils/writelog/LogWriter.java | 25 +-
.../db/audit/DNAuditLoggerRevokeFailureTest.java | 183 +
.../DNAuditLoggerUserRoleModificationTest.java | 354 ++
.../audit/DataNodeUserDataTransferAuditorTest.java | 136 +
.../db/auth/ClusterAuthorityFetcherLeaseTest.java | 24 +-
.../apache/iotdb/db/auth/LoginLockManagerTest.java | 25 +-
.../org/apache/iotdb/db/auth/entity/RoleTest.java | 84 -
.../org/apache/iotdb/db/auth/entity/UserTest.java | 53 -
.../db/conf/ActiveLoadListeningDirConfigTest.java | 139 +
.../iotdb/db/conf/DataNodeMemoryConfigTest.java | 57 +-
.../IoTDBDescriptorDefaultMemoryConfigTest.java | 52 +
.../conf/IoTDBDescriptorSystemPropertiesTest.java | 65 +
.../org/apache/iotdb/db/conf/PropertiesTest.java | 139 +
.../iotdb/db/conf/QueryThreadPoolConfigTest.java | 110 +
.../dataregion/DataRegionStateMachineTest.java | 53 +-
.../cache/TreeDeviceSchemaCacheManagerTest.java | 29 +
.../schemaRegion/SchemaRegionAliasAndTagTest.java | 62 +
.../schemaRegion/SchemaRegionManagementTest.java | 38 +-
.../SchemaRegionSimpleRecoverTest.java | 76 +
.../SchemaRegionTableDevicePerformanceTest.java | 335 ++
.../agent/plugin/PipeDataNodePluginAgentTest.java | 24 +
.../pipe/agent/runtime/PipeAgentLauncherTest.java | 186 +
.../pipe/agent/task/PipeDataNodeTaskAgentTest.java | 389 ++
.../task/builder/PipeDataNodeTaskBuilderTest.java | 79 +
.../task/connection/PipeEventCollectorTest.java | 4 +-
.../PipeProcessorSubtaskExecutionGuardTest.java | 253 +
.../processor/PipeProcessorSubtaskTest.java | 87 +
.../processor/PipeProcessorSubtaskWorkerTest.java | 305 ++
.../subtask/sink/PipeSinkSubtaskLifeCycleTest.java | 58 +
.../subtask/sink/PipeSinkSubtaskManagerTest.java | 92 +-
.../task/subtask/sink/PipeSinkSubtaskTest.java | 172 +-
.../persist/PageCacheDeletionBufferTest.java | 88 +
.../pipe/event/PipeTabletInsertionEventTest.java | 36 +-
.../pipe/event/TsFileInsertionEventParserTest.java | 283 +-
.../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 +
.../schema/PipeSchemaRegionSinkMetricsTest.java | 77 +
.../metric/sink/PipeDataRegionSinkMetricsTest.java | 98 +
.../pattern/CachedSchemaPatternMatcherTest.java | 84 +
.../aggregate/TimeSeriesRuntimeStateTest.java | 76 +
.../processor/TumblingWindowingProcessorTest.java | 100 +
.../plugin/TwoStageCountProcessorTest.java | 55 +
.../receiver/PipeStatementTsStatusVisitorTest.java | 18 +
.../protocol/airgap/IoTDBAirGapReceiverTest.java | 270 +
.../protocol/thrift/IoTDBDataNodeReceiverTest.java | 319 ++
.../PipeConvertedInsertTabletStatementTest.java | 133 +
.../resource/PipeTsFileResourceManagerTest.java | 87 +
.../memory/PipeMemoryManagerResizeTest.java | 441 +-
.../resource/memory/PipeMemoryManagerTest.java | 30 +
.../pipe/sink/PipeDataNodeThriftRequestTest.java | 208 +-
.../iotdb/db/pipe/sink/PipeReceiverTest.java | 12 +-
.../apache/iotdb/db/pipe/sink/PipeSinkTest.java | 155 +-
.../batch/PipeTabletEventTsFileBatchTest.java | 1 +
.../batch/PipeTransferBatchReqBuilderTest.java | 135 +
.../airgap/IoTDBDataRegionAirGapSinkTest.java | 34 +-
.../thrift/async/IoTDBDataRegionAsyncSinkTest.java | 115 +
...peTransferTabletInsertNodeEventHandlerTest.java | 105 +
.../handler/PipeTransferTrackableHandlerTest.java | 140 +
.../PipeTransferTsFileHandlerCleanupTest.java | 133 +
.../sink/util/cacher/LeaderCacheUtilsTest.java | 151 +
.../db/pipe/source/IoTDBDataRegionSourceTest.java | 31 +
.../db/pipe/source/PipeRealtimeExtractTest.java | 1292 ++++-
.../dataregion/DataRegionListeningFilterTest.java | 65 +
.../DataRegionWatermarkInjectorTest.java} | 28 +-
...ricalDataRegionTsFileAndDeletionSourceTest.java | 62 +
.../realtime/PipeRealtimeDataRegionSourceTest.java | 25 +
.../assigner/PipeDataRegionAssignerTest.java | 88 +
.../PipeInsertionDataNodeListenerTest.java | 66 +
.../db/protocol/client/ConfigNodeInfoTest.java | 75 +
.../db/protocol/session/QueryOwnershipTest.java | 343 ++
.../DataNodeInternalRPCServiceImplDiskTest.java | 139 +
.../DataNodeInternalRPCServiceImplLoadTest.java | 94 +
...nternalRPCServiceImplPushMultiPipeMetaTest.java | 72 +
...eInternalRPCServiceImplSetSystemStatusTest.java | 91 +
...rnalRPCServiceImplSubscriptionDisabledTest.java | 56 +
.../db/queryengine/common/MPPQueryContextTest.java | 58 +
.../queryengine/execution/ConfigExecutionTest.java | 27 +
.../db/queryengine/execution/DataDriverTest.java | 46 +
.../execution/aggregation/AccumulatorTest.java | 19 +
.../aggregation/TimeRangeIteratorTest.java | 127 +
.../exchange/MPPDataExchangeManagerTest.java | 80 +
.../execution/exchange/ShuffleSinkHandleTest.java | 226 +
.../SinkChannelFailurePropagationTest.java | 366 ++
.../execution/exchange/SinkChannelTest.java | 16 +-
.../execution/exchange/SourceHandleTest.java | 335 ++
.../db/queryengine/execution/exchange/Utils.java | 7 +
.../executor/RegionWriteExecutorTest.java | 268 +
.../fragment/FileReaderReferenceLifecycleTest.java | 189 +
.../fragment/FragmentInstanceContextTest.java | 41 +
.../fragment/FragmentInstanceExecutionTest.java | 216 +-
.../fragment/FragmentInstanceManagerTest.java | 131 +
.../fragment/QueryDataSourceLeaseTest.java | 49 +
.../fragment/QueryModificationLoaderTest.java | 5 +
.../RegionQueryInitializationLockTest.java | 280 +
.../fragment/RegionScanTimeSliceTest.java | 96 +
.../execution/memory/MemoryPoolTest.java | 128 +
.../operator/LastQueryCollectOperatorTest.java | 140 +
.../process/TableStreamSortOperatorTest.java | 63 +
.../process/ai/InferenceOperatorTest.java} | 31 +-
.../process/fill/GroupedFillOperatorTest.java | 174 +
.../process/tvf/TableFunctionOperatorTest.java | 331 ++
.../process/window/TopKRankingOperatorTest.java | 75 +-
.../source/DeviceBlackListConstructorTest.java | 120 +
.../source/SeriesScanUtilCancellationTest.java | 557 ++
.../operator/source/ShowReceiversOperatorTest.java | 571 ++
.../relational/DeviceIteratorScanOperatorTest.java | 50 +
...alTsFileTableScanOperatorRuntimeFilterTest.java | 9 +
.../InformationSchemaReceiversSupplierTest.java | 406 ++
.../operator/window/SessionWindowTest.java | 8 +
.../schedule/DefaultDriverSchedulerTest.java | 81 +
.../execution/schedule/DriverTaskThreadTest.java | 120 +
.../ConvertPredicateToTimeFilterTest.java | 5 +
.../db/queryengine/plan/analyze/AnalyzeTest.java | 13 +
.../queryengine/plan/analyze/AnalyzeUtilsTest.java | 63 +-
.../plan/analyze/FakePartitionFetcherImpl.java | 17 +
.../plan/analyze/QueryTimePartitionTest.java | 27 +
.../plan/analyze/cache/PartitionCacheTest.java | 31 +-
.../plan/analyze/load/LoadTsFileAnalyzerTest.java | 85 +-
.../plan/analyze/schema/SchemaValidatorTest.java | 101 +
.../config/metadata/DatabaseSchemaTaskTest.java | 57 +
.../metadata/ShowClusterDetailsTaskTest.java | 172 +
.../config/metadata/ShowClusterTaskTest.java | 168 +
.../config/metadata/ShowConfigNodesTaskTest.java | 121 +
.../config/metadata/ShowDataNodesTaskTest.java | 114 +
.../metadata/relational/ShowCreateTaskTest.java | 46 +-
.../config/sys/pipe/ShowPipeTaskTest.java | 13 +-
.../ShowSubscriptionsTaskTest.java} | 68 +-
.../ConvertPredicateToFilterVisitorTest.java | 104 +
...est.java => RemoveNodeSingleNodeParseTest.java} | 27 +-
.../parser/ShowSubscriptionsStatementTest.java | 48 +
.../plan/parser/StatementGeneratorTest.java | 88 +
.../plan/planner/LastQueryCacheTest.java | 236 +
.../LocalExecutionPlannerOperatorsMemoryTest.java | 46 +
.../plan/planner/PipelineBuilderTest.java | 2 +-
.../distribution/AggregationTableScanTest.java | 36 +
.../plan/planner/distribution/Util.java | 19 +
.../plan/planner/distribution/Util2.java | 19 +
.../planner/node/source/SourceNodeSerdeTest.java | 11 +
.../node/write/InsertTabletNodeSerdeTest.java | 71 +
.../planner/node/write/WritePlanNodeSplitTest.java | 49 +
.../node/write/RelationalDeleteDataNodeTest.java | 22 +
.../plan/relational/analyzer/AnalyzerTest.java | 147 +
.../plan/relational/analyzer/AuthTest.java | 51 +
.../analyzer/EvaluateEmptyIntersectTest.java | 25 +-
.../analyzer/RemoveEmptyExceptBranchesTest.java | 82 +-
.../plan/relational/analyzer/TSBSMetadata.java | 54 +-
.../relational/analyzer/TableFunctionTest.java | 174 +
.../plan/relational/analyzer/TestMetadata.java | 59 +-
.../relational/analyzer/UnionOptimizeTest.java | 28 +-
.../metadata/fetcher/SchemaPredicateUtilTest.java | 125 +
.../fetcher/cache/TableDeviceSchemaCacheTest.java | 184 +-
.../spill/DeviceEntryMaterializerTest.java | 372 ++
.../spill/DeviceEntryRpcSegmentFetcherTest.java | 107 +
.../spill/InMemoryDeviceEntrySourceTest.java} | 33 +-
.../spill/SegmentDeviceEntrySourceTest.java | 347 ++
.../planner/AggregationNodeRateSerdeTest.java | 92 +
.../plan/relational/planner/PlanTester.java | 6 +-
.../relational/planner/TableModelPlannerTest.java | 78 +
.../planner/WindowFunctionOptimizationTest.java | 12 +-
.../TableDistributedPlanGeneratorRateTest.java | 124 +
.../informationschema/ShowReceiversTest.java | 128 +
.../OrderingPropertyPropagationTest.java | 481 ++
.../optimizations/TableFunctionSortTest.java | 263 +
.../relational/security/AccessControlImplTest.java | 119 +
...atementTest.java => ShowSubscriptionsTest.java} | 39 +-
...java => RemoveNodeSingleNodeStatementTest.java} | 25 +-
.../relational/sql/parser/ShowPipeMemoryTest.java | 63 +
.../relational/sql/parser/StreamKeywordTest.java | 127 +
.../plan/scheduler/AsyncPlanNodeSenderTest.java | 81 +
.../load/LoadTsFileDispatcherImplTest.java | 225 +
.../scheduler/load/LoadTsFileSchedulerTest.java | 43 +
.../crud/InsertStatementPartialInsertTest.java | 28 +
.../statement/crud/LoadTsFileStatementTest.java | 72 +
.../FragmentInstanceStatisticsJsonDrawerTest.java | 12 +
.../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 +
.../utils/ResourceByPathUtilsTest.java | 113 +
.../schemaengine/table/DataNodeTableCacheTest.java | 114 +
.../DataNodeInternalRPCServiceImplTest.java | 99 +
.../metrics/DataNodeMetricsRestartTest.java | 290 +
.../db/service/metrics/WritingMetricsTest.java | 87 +
.../db/service/metrics/file/TsFileMetricsTest.java | 148 +
.../buffer/TimeSeriesMetadataCacheTest.java | 4 +-
.../storageengine/dataregion/DataRegionTest.java | 338 +-
.../dataregion/DatabaseMemMetricsTest.java | 144 +
.../TsFileResourceProgressIndexTest.java | 9 +
.../compaction/AbstractCompactionTest.java | 121 +-
.../compaction/CompactionWorkerTest.java | 58 +-
.../CompactionDataTypeAlterTableTest.java | 37 +-
.../cross/CrossSpaceCompactionSelectorTest.java | 33 +-
.../CrossSpaceCompactionWithFastPerformerTest.java | 7 +-
...sSpaceCompactionWithReadPointPerformerTest.java | 7 +-
.../cross/RewriteCompactionFileSelectorTest.java | 3 +-
.../utils/writer/AbstractCompactionWriterTest.java | 125 +-
.../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 | 221 +-
...gnedFlushDuplicateTimeCheckPerformanceTest.java | 238 +
.../memtable/AlignedTVListIteratorTest.java | 86 +
.../memtable/AlignedWritableMemChunkTest.java | 216 +
.../memtable/MemChunkDeserializeTest.java | 12 +-
.../memtable/MemChunkTimeRangeUtilsTest.java | 59 +
.../dataregion/memtable/MemTableFlushTaskTest.java | 417 +-
.../memtable/NonAlignedTVListIteratorTest.java | 72 +
.../dataregion/memtable/PrimitiveMemTableTest.java | 50 +-
.../TabletDeviceRangeReusePerformanceTest.java | 283 +
.../dataregion/memtable/TsFileProcessorTest.java | 240 +-
...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/tsfile/TsFileResourceTest.java | 30 +
.../dataregion/utils/TableDiskUsageTest.java | 8 +
.../dataregion/wal/buffer/WALBufferCommonTest.java | 27 +
.../wal/buffer/WALBufferRollRecoveryTest.java | 300 ++
.../dataregion/wal/io/WALFileTest.java | 289 +-
.../wal/node/ConsensusReqReaderTest.java | 53 +
.../wal/node/WALFileListCachePerformanceTest.java | 338 ++
.../wal/node/WalDeleteOutdatedNewTest.java | 12 +
.../wal/recover/WALRepairWriterTest.java | 140 +-
.../load/LoadTsFilePieceNodeAssemblerTest.java | 215 +
.../db/storageengine/load/TsFileSplitterTest.java | 254 +-
.../load/active/ActiveLoadDirScannerTest.java | 42 +-
.../load/active/ActiveLoadPathHelperTest.java | 60 +-
.../load/active/ActiveLoadTsFileLoaderTest.java | 14 +
...atementDataTypeConvertExecutionVisitorTest.java | 84 +
.../load/converter/LoadTsFileInvalidPathTest.java | 195 +
.../LoadTsFileParserPipeMemoryIsolationTest.java | 66 +
.../PipeTsFileConversionTaskManagerTest.java | 381 ++
.../load/memory/LoadTsFileMemoryManagerTest.java | 20 +
.../db/storageengine/load/util/LoadUtilTest.java | 159 +-
.../rescon/disk/FolderManagerTest.java | 76 +
.../agent/SubscriptionConsumerAgentTest.java | 114 +
.../agent/SubscriptionReceiverAgentTest.java | 729 +++
.../agent/SubscriptionTopicAgentTest.java | 116 +
.../ConsensusSubscriptionBrokerOwnershipTest.java | 192 +
...onsensusSubscriptionBrokerPayloadLimitTest.java | 160 +
.../SubscriptionBrokerAgentPayloadLimitTest.java | 118 +
...riptionPrefetchingQueueRecycleIntervalTest.java | 160 +
...sFileDeduplicationBlockingPendingQueueTest.java | 68 +
.../ConsensusLogToTabletConverterTest.java | 115 +
...onsensusPrefetchingQueueDataNodeMemoryTest.java | 569 +-
...onsensusPrefetchingQueueInitializationTest.java | 254 +
.../ConsensusPrefetchingQueueSeekTest.java | 242 +
.../consensus/ConsensusPrefetchingQueueTest.java | 3068 +++++++++--
...nsensusPrefetchingQueueWalBackpressureTest.java | 468 +-
.../ConsensusSubscriptionCommitStateTest.java | 55 +
.../ConsensusSubscriptionSetupHandlerTest.java | 113 +
.../ConsensusSubscriptionWalRetentionTest.java | 102 +
.../broker/consensus/ProgressWALIteratorTest.java | 862 ++-
.../SubscriptionWalPrefetchPerformanceTest.java | 380 ++
.../SubscriptionPipeTabletEventBatchTest.java | 256 +
.../cache/SubscriptionPollResponseCacheTest.java | 60 +
...susSubscriptionPrefetchingQueueMetricsTest.java | 108 +
.../metric/SubscriptionMetricsRestartTest.java | 275 +
.../receiver/SubscriptionReceiverV1Test.java | 286 +-
.../resource/SubscriptionMemoryManagerTest.java | 122 +
.../org/apache/iotdb/db/tools/ImportWALTest.java | 2115 ++++++++
.../db/tools/TableWALDeleteConverterTest.java | 318 ++
.../apache/iotdb/db/utils/CommonUtilsTest.java} | 25 +-
.../apache/iotdb/db/utils/DateTimeUtilsTest.java | 41 +
.../iotdb/db/utils/QueryDataSetUtilsTest.java | 109 +-
.../apache/iotdb/db/utils/SerializeUtilsTest.java | 132 +-
.../utils/TSDataTypeSwitchArchitectureTest.java} | 27 +-
.../iotdb/db/utils/TSDataTypeSwitchRule.java | 182 +
.../iotdb/db/utils/TSDataTypeSwitchRuleTest.java | 186 +
.../apache/iotdb/db/utils/TypeServicesTest.java | 305 ++
.../AlignedBitmapRangeCheckPerformanceTest.java | 201 +
.../AlignedSparseWritePerformanceTest.java | 314 ++
.../db/utils/datastructure/AlignedTVListTest.java | 498 +-
.../SlidingTimeWindowEvaluationHandlerTest.java | 15 +
.../src/test/resources/iotdb-system.properties | 3 +
iotdb-core/metrics/ReadMe.md | 1 +
iotdb-core/metrics/core/pom.xml | 5 +
.../metrics/core/reporter/IoTDBJmxReporter.java | 115 +-
.../iotdb/metrics/core/type/IoTDBAutoGauge.java | 5 +-
.../core/utils/IoTDBMetricObjNameFactory.java | 38 +-
.../metrics/core/utils/ObjectNameFactory.java | 45 +
.../metrics/core/MetricManagerLifecycleTest.java | 339 ++
.../core/reporter/IoTDBJmxReporterTest.java | 205 +
.../metrics/core/type/IoTDBAutoGaugeTest.java | 68 +
.../core/utils/IoTDBMetricObjNameFactoryTest.java | 123 +
.../apache/iotdb/metrics/i18n/MetricsMessages.java | 1 +
.../apache/iotdb/metrics/i18n/MetricsMessages.java | 1 +
.../iotdb/metrics/AbstractMetricManager.java | 215 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 14 +
.../metrics/config/MetricConfigDescriptor.java | 94 +-
.../iotdb/metrics/metricsets/jvm/JvmGcMetrics.java | 86 +-
.../metrics/metricsets/system/SystemMetrics.java | 13 +-
.../reporter/iotdb/IoTDBSessionReporter.java | 1 +
.../reporter/prometheus/PrometheusReporter.java | 120 +-
.../org/apache/iotdb/metrics/utils/NodeType.java | 3 +-
.../iotdb/metrics/config/MetricConfigTest.java | 16 +
.../prometheus/PrometheusReporterTest.java | 75 +
iotdb-core/node-commons/pom.xml | 8 +
.../resources/conf/edge/iotdb-system.properties | 202 +
.../conf/iotdb-system.properties.template | 240 +-
.../apache/iotdb/commons/i18n/ClientMessages.java | 3 +
.../apache/iotdb/commons/i18n/CommonMessages.java | 292 +-
.../apache/iotdb/commons/i18n/ConfigMessages.java | 39 +
.../apache/iotdb/commons/i18n/LBACMessages.java | 32 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 5 +-
.../apache/iotdb/commons/i18n/QueryMessages.java | 44 +
.../apache/iotdb/commons/i18n/ServiceMessages.java | 6 +
.../apache/iotdb/commons/i18n/StorageMessages.java | 38 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 2 +
.../apache/iotdb/commons/i18n/ClientMessages.java | 3 +
.../apache/iotdb/commons/i18n/CommonMessages.java | 46 +-
.../apache/iotdb/commons/i18n/ConfigMessages.java | 33 +
.../apache/iotdb/commons/i18n/LBACMessages.java | 32 +
.../apache/iotdb/commons/i18n/PipeMessages.java | 5 +-
.../apache/iotdb/commons/i18n/QueryMessages.java | 42 +
.../apache/iotdb/commons/i18n/ServiceMessages.java | 6 +
.../apache/iotdb/commons/i18n/StorageMessages.java | 35 +
.../apache/iotdb/commons/i18n/UtilMessages.java | 2 +
.../iotdb/commons/audit/AbstractAuditLogger.java | 124 +
.../apache/iotdb/commons/audit/AuditEventType.java | 4 +-
.../TrustedChannelFailureHandler.java} | 16 +-
.../commons/audit/UserDataTransferAuditEvent.java | 84 +
...Type.java => UserDataTransferAuditHandler.java} | 54 +-
.../UserDataTransferErrorCode.java} | 17 +-
.../audit/UserDataTransferProtectionMethod.java} | 10 +-
.../org/apache/iotdb/commons/auth/entity/Role.java | 66 +-
.../org/apache/iotdb/commons/auth/entity/User.java | 64 -
.../commons/auth/role/LocalFileRoleAccessor.java | 76 +-
.../commons/auth/user/LocalFileUserAccessor.java | 9 +-
.../commons/binaryallocator/BinaryAllocator.java | 311 --
.../binaryallocator/BinaryAllocatorState.java | 71 -
.../PooledBinaryPhantomReference.java | 42 -
.../iotdb/commons/binaryallocator/arena/Arena.java | 273 -
.../binaryallocator/autoreleaser/Releaser.java | 93 -
.../binaryallocator/config/AllocatorConfig.java | 53 -
.../ema/AdaptiveWeightedAverage.java | 100 -
.../commons/binaryallocator/evictor/Evictor.java | 102 -
.../metric/BinaryAllocatorMetrics.java | 138 -
.../commons/binaryallocator/utils/SizeClasses.java | 146 -
.../commons/client/AbstractConfigNodeClient.java} | 980 ++--
.../commons/client/AbstractConfigNodeInfo.java} | 59 +-
.../apache/iotdb/commons/client/ClientManager.java | 19 +-
.../iotdb/commons/client/ClientManagerMetrics.java | 200 +-
.../client/property/ClientPoolProperty.java | 5 +-
.../apache/iotdb/commons/cluster/NodeStatus.java | 102 +-
.../apache/iotdb/commons/cluster/RegionStatus.java | 5 +
.../iotdb/commons/concurrent/ThreadName.java | 4 +-
.../commons/concurrent/ThreadPoolMetrics.java | 74 +-
.../WrappedScheduledExecutorService.java | 4 +-
.../WrappedSingleThreadExecutorService.java | 4 +-
.../WrappedSingleThreadScheduledExecutor.java | 4 +-
.../threadpool/WrappedThreadPoolExecutor.java | 4 +-
.../commons/conf/AbstractIoTDBStartCheck.java | 195 +
.../apache/iotdb/commons/conf/CommonConfig.java | 127 +-
.../iotdb/commons/conf/CommonDescriptor.java | 45 +-
.../commons/consensus/index/ProgressIndex.java | 10 +
.../consensus/index/impl/HybridProgressIndex.java | 25 +
.../consensus/index/impl/IoTProgressIndex.java | 9 +
.../consensus/index/impl/MetaProgressIndex.java | 9 +
.../consensus/index/impl/MinimumProgressIndex.java | 9 +
.../consensus/index/impl/RecoverProgressIndex.java | 9 +
.../consensus/index/impl/SimpleProgressIndex.java | 9 +
.../consensus/index/impl/StateProgressIndex.java | 14 +-
.../index/impl/TimePartitionProgressIndex.java | 9 +
.../index/impl/TimeWindowStateProgressIndex.java | 11 +-
.../apache/iotdb/commons/disk/FolderManager.java | 28 +-
.../commons/disk/strategy/DirectoryStrategy.java | 20 +-
.../strategy/RandomOnDiskUsableSpaceStrategy.java | 2 +-
.../commons/disk/utils}/DirectoryChecker.java | 48 +-
.../commons/enums/HandleSystemErrorStrategy.java | 6 +-
.../pipe/PipeRuntimeSinkResourceException.java | 51 +
...RuntimeSinkRetryTimesConfigurableException.java | 6 +
.../exception/table/TableInDeletionException.java} | 26 +-
.../commons/executable/ExecutableManager.java | 14 +-
.../commons/file/SystemPropertiesHandler.java | 8 +-
.../commons/lbac/LBACAccessDeniedException.java | 56 +
.../iotdb/commons/lbac/LBACRuntimeException.java} | 20 +-
.../apache/iotdb/commons/lbac/RequiredLabels.java | 79 +
.../commons/lbac/operation/LabelAccessType.java} | 8 +-
.../iotdb/commons/model/ModelHyperparameter.java | 2 +-
.../commons/partition/SeriesPartitionTable.java | 25 +-
.../org/apache/iotdb/commons/path/AlignedPath.java | 4 +-
.../iotdb/commons/path/ExtendedPartialPath.java | 34 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 2 +-
.../apache/iotdb/commons/path/PathPatternNode.java | 35 +-
.../apache/iotdb/commons/path/PathPatternUtil.java | 6 +-
.../apache/iotdb/commons/path/fa/IPatternFA.java | 8 +
.../iotdb/commons/path/fa/nfa/SimpleNFA.java | 102 +-
.../agent/plugin/builtin/BuiltinPipePlugin.java | 82 +-
.../agent/plugin/builtin/sink/opcua/OpcUaSink.java | 34 -
.../pipe/agent/plugin/meta/PipePluginMeta.java | 13 +-
.../plugin/service/PipePluginClassLoader.java | 8 +-
.../service/PipePluginExecutableManager.java | 60 +-
.../iotdb/commons/pipe/agent/task/PipeTask.java | 8 +
.../commons/pipe/agent/task/PipeTaskAgent.java | 280 +-
.../pipe/agent/task/meta/PipeRuntimeMeta.java | 4 +-
.../pipe/agent/task/meta/PipeStaticMeta.java | 33 +
.../commons/pipe/agent/task/meta/PipeTaskMeta.java | 21 +-
.../agent/task/meta/PipeTemporaryMetaInAgent.java | 19 +-
.../task/meta/PipeTemporaryMetaInCoordinator.java | 99 +-
.../task/progress/PipeEventCommitManager.java | 15 +
.../pipe/agent/task/stage/PipeTaskStage.java | 8 +
.../task/subtask/PipeAbstractSinkSubtask.java | 22 +-
.../pipe/agent/task/subtask/PipeSubtask.java | 15 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 1 +
.../pipe/config/constant/PipeSinkConstant.java | 14 +-
.../pipe/config/constant/PipeSourceConstant.java | 10 +
.../pipe/config/constant/SystemConstant.java | 3 +
.../options/PipeInclusionOptions.java | 15 +
.../queue/serializer/PlainQueueSerializer.java | 32 +-
.../iotdb/commons/pipe/event/EnrichedEvent.java | 14 +
.../commons/pipe/event/ProgressReportEvent.java | 5 +
.../pipe/metric/PipeEventCommitMetrics.java | 20 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 118 +-
.../pipe/receiver/PipeReceiverStatusHandler.java | 258 +-
.../runtime/PipeReceiverRuntimeRegistry.java | 355 ++
.../runtime/PipeReceiverRuntimeSnapshot.java | 115 +
.../pipe/resource/PipeRecentFailureCounter.java | 93 +
.../pipe/resource/PipeResourceFailureType.java | 27 +-
.../commons/pipe/resource/PipeStopStrategy.java | 76 +
.../pipe/sink/client/IoTDBClientManager.java | 25 +
.../pipe/sink/client/IoTDBSyncClientManager.java | 110 +-
.../IoTConsensusV2TransferFileSealWithModReq.java | 10 +-
.../common/PipeTransferHandshakeConstant.java | 2 +
.../payload/thrift/request/PipeRequestType.java | 3 +
.../thrift/request/PipeTransferFileSealReqV2.java | 8 +-
.../thrift/request/PipeTransferHandshakeV1Req.java | 3 +-
.../thrift/request/PipeTransferHandshakeV2Req.java | 12 +-
...eTransferPipeReceiverRuntimeInfoCleanupReq.java | 103 +
.../commons/pipe/sink/protocol/IoTDBSink.java | 58 +
.../pipe/sink/protocol/IoTDBSslSyncSink.java | 22 +
.../pipe/source/IoTDBNonDataRegionSource.java | 45 +-
.../execution/MemoryEstimationHelper.java | 13 +
.../plan/planner/plan/node/PlanNodeType.java | 1 +
.../function/TableBuiltinTableFunction.java | 52 +-
.../function/tvf/ForecastTableFunction.java | 18 +-
.../plan/relational/metadata/ColumnSchema.java | 13 +-
.../relational/planner/node/AggregationNode.java | 33 +-
.../planner/rowpattern/LogicalIndexPointer.java | 4 +-
.../plan/relational/sql/ast/InListExpression.java | 2 +-
.../plan/relational/type/InternalTypeManager.java | 67 +-
.../queryengine/plan/udf/ForecastTimeUtils.java | 78 +
.../commons/queryengine/plan/udf/UDTFForecast.java | 15 +-
.../schema/column/ColumnHeaderConstant.java | 117 +-
.../schema/filter/impl/DeviceFilterUtil.java | 261 +-
.../multichildren/AbstractMultiChildrenFilter.java | 2 +-
.../schema/filter/impl/values/InFilter.java | 4 +-
.../table/AlterOrDropTableOperationType.java | 5 +-
.../apache/iotdb/commons/schema/table/Audit.java | 13 +
.../commons/schema/table/InformationSchema.java | 149 +
.../iotdb/commons/schema/table/TreeViewSchema.java | 2 +
.../apache/iotdb/commons/schema/table/TsTable.java | 28 +-
.../commons/schema/tree/AbstractTreeVisitor.java | 81 +-
.../multi/FunctionViewExpression.java | 4 +-
.../TrustedChannelAuditServerEventHandler.java | 152 +
.../service/metric/JvmGcMonitorMetrics.java | 42 +-
.../commons/service/metric/MetricService.java | 28 +-
.../commons/service/metric}/ProcessMetrics.java | 8 +-
.../iotdb/commons/service/metric/enums/Metric.java | 45 +-
.../iotdb/commons/service/metric/enums/Tag.java | 2 +
.../snapshot/ReusableBufferedOutputStream.java | 134 +
.../commons/snapshot/SnapshotStreamFactory.java | 130 +
.../meta/consumer/CommitProgressKeeper.java | 15 +
.../meta/consumer/ConsumerGroupMeta.java | 45 +-
.../meta/consumer/ConsumerGroupMetaKeeper.java | 20 +
.../subscription/meta/consumer/ConsumerMeta.java | 4 +
.../consumer/SubscriptionProgressSnapshot.java | 278 +
.../subscription/meta/topic/TopicMetaKeeper.java | 42 +-
.../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 | 168 +-
.../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 +-
.../commons/udf/builtin/UDTFTimeDifference.java | 4 +-
.../apache/iotdb/commons/udf/builtin/UDTFTopK.java | 65 +-
.../commons/udf/builtin/UDTFValueDifference.java | 12 +
.../iotdb/commons/udf/builtin/UDTFValueTrend.java | 42 +-
.../TableBuiltinAggregationFunction.java | 11 +-
.../relational/tvf/CapacityTableFunction.java | 30 +-
.../relational/tvf/CumulateTableFunction.java | 19 +-
.../builtin/relational/tvf/FFTTableFunction.java | 804 +++
.../tvf/FilterTransferTableFunction.java | 315 ++
.../builtin/relational/tvf/HOPTableFunction.java | 41 +-
.../relational/tvf/HighPassTableFunction.java | 81 +
.../relational/tvf/LowPassTableFunction.java | 77 +
.../builtin/relational/tvf/M4TableFunction.java | 87 +-
.../relational/tvf/SessionTableFunction.java | 6 +-
.../relational/tvf/TumbleTableFunction.java | 6 +-
.../udf/builtin/relational/tvf/WindowTVFUtils.java | 216 +
.../builtin/relational/tvf/XCorrTableFunction.java | 249 +
.../builtin/relational/tvf/fft/DoubleFFT_1D.java | 191 +
.../builtin/relational/tvf/fft/FloatFFT_1D.java | 160 +
.../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 +-
.../iotdb/commons/utils/CommonDateTimeUtils.java | 20 +
.../org/apache/iotdb/commons/utils/FileUtils.java | 60 +-
.../org/apache/iotdb/commons/utils/IOUtils.java | 2 +-
.../apache/iotdb/commons/utils/SerializeUtils.java | 371 +-
.../apache/iotdb/commons/utils/StatusUtils.java | 3 +
.../iotdb/commons/utils/TimePartitionUtils.java | 208 +-
.../commons/audit/AbstractAuditLoggerTest.java | 171 +
.../audit/UserDataTransferAuditEventTest.java | 57 +
.../binaryallocator/BinaryAllocatorTest.java | 171 -
.../commons/client/ClientManagerMetricsTest.java | 580 ++
.../iotdb/commons/cluster/NodeStatusTest.java | 91 +
.../commons/concurrent/ThreadPoolMetricsTest.java | 157 +
.../iotdb/commons/conf/CommonConfigTest.java | 282 +
...ubscriptionCacheMemoryUsagePercentageTest.java} | 30 +-
.../commons/consensus/index/ProgressIndexTest.java | 82 +
.../partition/SeriesPartitionTableTest.java | 43 +
.../iotdb/commons/path/PathPatternNodeTest.java | 71 +
.../plugin/service/PipePluginClassLoaderTest.java | 35 +
.../service/PipePluginExecutableManagerTest.java | 111 +
.../agent/task/meta/PipeTemporaryMetaTest.java | 32 +
.../PipeReceiverStatusHandlerTest.java | 226 +
.../pipe/metric/PipeEventCommitMetricsTest.java | 99 +
.../pipe/plugin/meta/PipePluginMetaTest.java | 17 +
.../runtime/PipeReceiverRuntimeRegistryTest.java | 947 ++++
.../resource/PipeRecentFailureCounterTest.java | 48 +
.../pipe/resource/PipeStopStrategyTest.java | 84 +
.../thrift/request/PipeRequestTypeTest.java | 25 +
.../pipe/source/IoTDBNonDataRegionSourceTest.java | 172 +
.../iotdb/commons/pipe/task/PipeMetaDeSerTest.java | 74 +
.../commons/pipe/task/PipeSleepIntervalTest.java | 17 +
.../relational/type/InternalTypeManagerTest.java | 61 +
.../schema/filter/impl/DeviceFilterUtilTest.java | 400 ++
.../iotdb/commons/schema/table/AuditTest.java} | 26 +-
.../TrustedChannelAuditServerEventHandlerTest.java | 220 +
.../service/metric/JvmGcMonitorMetricsTest.java | 72 +
.../service/metric/MetricReporterSwitchTest.java | 166 +
.../service/metric/MetricServiceRestartTest.java | 218 +
.../snapshot/SnapshotStreamFactoryTest.java | 307 ++
.../consumer/ConsumerGroupDeSerTest.java | 51 +
.../meta/consumer/CommitProgressKeeperTest.java | 19 +
.../consumer/SubscriptionProgressSnapshotTest.java | 78 +
.../subscription/topic/TopicMetaKeeperTest.java | 120 +
.../relational/tvf/CapacityTableFunctionTest.java | 58 +-
.../relational/tvf/FFTTableFunctionTest.java | 518 ++
.../relational/tvf/ForecastTimeUtilsTest.java | 70 +
.../tvf/TimeWindowTableFunctionBoundaryTest.java | 186 +
.../udf/builtin/relational/tvf/fft/FFT1DTest.java | 148 +
.../commons/udf/utils/MasterRepairUtilTest.java | 94 +
.../udf/utils/UDFDataTypeTransformerTest.java | 71 +
.../commons/utils/CommonDateTimeUtilsTest.java | 33 +
.../apache/iotdb/commons/utils/FileUtilsTest.java | 22 +
.../commons/utils/TimePartitionUtilsTest.java | 160 +
.../iotdb/rpc/ClientPoolIdleEvictionTest.java | 326 ++
.../db/relational/grammar/sql/RelationalSql.g4 | 24 +-
.../thrift-commons/src/main/thrift/common.thrift | 14 +-
.../src/main/thrift/confignode.thrift | 66 +-
.../src/main/thrift/datanode.thrift | 50 +
.../opc-ua-sink-example}/pom.xml | 25 +-
.../java/org/apache/iotdb/opcua/ClientExample.java | 4 +-
.../apache/iotdb/opcua/ClientExampleRunner.java | 41 +-
.../java/org/apache/iotdb/opcua/ClientTest.java | 54 +-
.../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 | 260 +-
.../plugin/sink}/opcua/client/ClientRunner.java | 48 +-
.../opcua/client/IoTDBKeyStoreLoaderClient.java | 2 +-
.../sink}/opcua/client/IoTDBOpcUaClient.java | 307 +-
.../sink}/opcua/server/OpcUaKeyStoreLoader.java | 2 +-
.../plugin/sink}/opcua/server/OpcUaNameSpace.java | 210 +-
.../sink}/opcua/server/OpcUaServerBuilder.java | 248 +-
.../sink/opcua/server/OpcUaTypeServices.java | 145 +
.../pipe/plugin/sink/opcua/OpcUaSinkTest.java | 242 +
.../sink/opcua/OpcUaSinkTsFileMetadataTest.java | 167 +
.../sink/opcua/OpcUaSinkTsFilePerformanceTest.java | 415 ++
.../sink}/opcua/client/ClientRunnerTest.java | 4 +-
.../sink/opcua/client/IoTDBOpcUaClientTest.java | 310 ++
.../opcua/server/OpcUaNameSpaceMetadataTest.java | 168 +
.../sink}/opcua/server/OpcUaServerBuilderTest.java | 106 +-
.../server/OpcUaTcpNoneCompatibilityTest.java | 132 +
.../sink/opcua/server/OpcUaTypeServicesTest.java | 44 +-
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 | 153 +-
scripts/conf/edge-env.sh | 69 +
scripts/conf/windows/edge-env.bat | 48 +
scripts/sbin/start-edge.sh | 96 +
scripts/sbin/stop-edge.sh | 114 +
scripts/sbin/windows/check-edge.ps1 | 66 +
scripts/sbin/windows/start-cli.bat | 1 +
scripts/sbin/windows/start-confignode.bat | 4 +-
scripts/sbin/windows/start-datanode.bat | 4 +-
scripts/sbin/windows/start-edge.bat | 109 +
scripts/sbin/windows/start-standalone.bat | 7 +-
scripts/sbin/windows/stop-datanode.bat | 5 +-
scripts/sbin/windows/stop-edge.bat | 29 +
scripts/tools/README.md | 156 +
.../utils/BitMap.py => scripts/tools/import-wal.sh | 47 +-
scripts/tools/ops/daemon-edge.sh | 114 +
scripts/tools/ops/destroy-edge.sh | 161 +
scripts/tools/windows/import-wal.bat | 43 +
scripts/tools/windows/ops/destroy-edge.bat | 96 +
.../main/forbidden-apis/secure-erase | 24 +-
2049 files changed, 164213 insertions(+), 41159 deletions(-)
create mode 100644 .github/scripts/test-edge-ops.py
create mode 100644 .github/scripts/test-edge-windows.ps1
create mode 100644 .github/workflows/edge-it.yml
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/ainode-common-files.xml
delete mode 100644 distribution/src/assembly/cli.xml
delete mode 100644 distribution/src/assembly/confignode.xml
delete mode 100644 distribution/src/assembly/datanode.xml
copy distribution/src/assembly/{all.xml => edge.xml} (62%)
create mode 100644 distribution/src/assembly/library-pipe.xml
create mode 100644 distribution/src/assembly/resources/conf-edge/logback-edge.xml
create mode 100644 external-service-impl/rest/src/main/java/org/apache/iotdb/rest/TrustedChannelAuditHandshakeListener.java
create mode 100644 external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/utils/TypeServices.java
create mode 100644 external-service-impl/rest/src/test/java/org/apache/iotdb/rest/TrustedChannelAuditHandshakeListenerTest.java
copy iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/CapacityTableFunction.java => integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/LargeResultTableFunction.java (51%)
copy iotdb-client/jdbc/src/main/resources/services/META-INF/java.sql.Driver => integration-test/src/main/java/org/apache/iotdb/itbase/category/EdgeIT.java (92%)
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/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/IoTDBShowQueriesIT.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/edge/it/IoTDBEdgeBasicIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeRelationalSecurityIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBShowReceiversLifecycleIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/pipe/it/single/IoTDBPipeOperationDiagnosticsIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/pipe/it/single/IoTDBShowReceiversIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/pipe/it/triple/IoTDBShowReceiversTripleIT.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/IoTDBFFTTableFunctionIT.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/query/recent/AbstractIoTDBMPPDataExchangeLargeTsBlockIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBDeviceEntrySpillIT.java
copy integration-test/src/test/java/org/apache/iotdb/{subscription/it/local/AbstractSubscriptionLocalIT.java => relational/it/query/recent/IoTDBMPPDataExchangeLargeTsBlock128KIT.java} (56%)
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/relational/it/schema/IoTDBTableAuthHAIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/tablemodel/IoTDBConsensusSubscriptionConsumerDisconnectTableIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/tablemodel/IoTDBConsensusSubscriptionUnsubscribeTableIT.java
copy iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/PipeTask.java => iotdb-client/client-cpp/src/include/SslConfig.h (74%)
copy iotdb-client/{service-rpc/src/main/java/org/apache/iotdb/rpc/NonOpenTransport.java => client-cpp/src/rpc/RpcSslUtils.cpp} (59%)
copy iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/PipeTask.java => iotdb-client/client-cpp/src/rpc/RpcSslUtils.h (69%)
copy iotdb-client/{service-rpc/src/main/java/org/apache/iotdb/rpc/NonOpenTransport.java => client-cpp/src/session/SslConfig.cpp} (65%)
create mode 100644 iotdb-client/client-cpp/test/cpp/RpcSslIotdbE2eTest.cpp
create mode 100644 iotdb-client/client-cpp/test/cpp/sessionUtilsTest.cpp
create mode 100644 iotdb-client/client-cpp/test/fixtures/tls/ca.crt
create mode 100644 iotdb-client/client-cpp/test/fixtures/tls/client.crt
create mode 100644 iotdb-client/client-cpp/test/fixtures/tls/client.key
create mode 100644 iotdb-client/client-cpp/test/fixtures/tls/tls-server.p12
copy iotdb-client/{jdbc/src/main/resources/services/META-INF/java.sql.Driver => client-cpp/test/main_rpc_ssl.cpp} (94%)
rename iotdb-client/{jdbc/src/main/resources/services/META-INF/java.sql.Driver => client-cpp/test/main_utils.cpp} (87%)
create mode 100644 iotdb-client/client-cpp/test/scripts/configure_iotdb_ssl_it.py
create mode 100644 iotdb-client/client-cpp/test/scripts/run_cpp_it_phases.py
create mode 100644 iotdb-client/client-py/iotdb/utils/SessionUtils.py
create mode 100644 iotdb-client/client-py/tests/unit/test_session_query_ids.py
create mode 100644 iotdb-client/client-py/tests/unit/test_session_utils.py
create mode 100644 iotdb-client/isession/src/main/java/org/apache/iotdb/isession/TypeServices.java
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
copy iotdb-core/ainode/iotdb/ainode/core/model/chronos2/__init__.py => iotdb-client/jdbc/src/main/resources/META-INF/services/java.sql.Driver (95%)
copy iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/ClusterSchemaManagerTest.java => iotdb-client/jdbc/src/test/java/org/apache/iotdb/jdbc/DriverServiceRegistrationTest.java (52%)
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/DeepCopyRpcTransportFactoryTest.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/exception/SubscriptionConsumerFencedException.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/SubscriptionSessionConnectionTimeoutTest.java
create mode 100644 iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/base/SubscriptionConsumerConnectionFailureTest.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/SubscriptionConsumerMultiProviderPollTest.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/consumer/base/SubscriptionProviderStatusTest.java
create mode 100644 iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/payload/TypeServicesTest.java
create mode 100644 iotdb-core/ainode/src/assembly/resources/NOTICE-binary
create mode 100644 iotdb-core/ainode/src/assembly/resources/licenses/LICENSE-GLIDE
create mode 100644 iotdb-core/ainode/src/assembly/resources/licenses/LICENSE-MOMENT
create mode 100644 iotdb-core/ainode/tests/test_sundial_flow_loss.py
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/AbstractGroupedDeltaAccumulator.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/AbstractGroupedIncreaseAccumulator.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/AbstractGroupedIrateAccumulator.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/AbstractGroupedRateAccumulator.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedNaiveDeltaAccumulator.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedNaiveIncreaseAccumulator.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedNaiveIrateAccumulator.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedNaiveRateAccumulator.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedOrderedDeltaAccumulator.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedOrderedIncreaseAccumulator.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedOrderedIrateAccumulator.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/GroupedOrderedRateAccumulator.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/rate/TimeValueBufferBigArray.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/AbstractDeltaTableAccumulator.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/AbstractIncreaseTableAccumulator.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/AbstractIrateTableAccumulator.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/AbstractRateTableAccumulator.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/ExtrapolationUtil.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/NaiveDeltaAccumulator.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/NaiveIncreaseAccumulator.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/NaiveIrateAccumulator.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/NaiveRateAccumulator.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/OrderedDeltaAccumulator.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/OrderedIncreaseAccumulator.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/OrderedIrateAccumulator.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/OrderedRateAccumulator.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/RateFunctionIntermediateStateCodec.java
copy iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/task/PipeConfigNodeTask.java => calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/RateFunctionType.java} (54%)
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/RateFunctionValidation.java
create mode 100644 iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/TimeValueBuffer.java
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine => calc-commons/src/main/java/org/apache/iotdb/calc}/plan/planner/memory/PipelineMemoryEstimator.java (95%)
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/grouped/rate/GroupedRateAccumulatorMemoryTest.java
create mode 100644 iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/ExtrapolationUtilTest.java
create mode 100644 iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/RateAccumulatorFactoryTest.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/execution/operator/source/relational/aggregation/rate/RateFunctionIntermediateStateCodecTest.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
delete mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/RemoveRegionGroupProcedure.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/main/java/org/apache/iotdb/edge/EdgeNode.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
copy iotdb-core/{datanode/src/test/java/org/apache/iotdb/db/pipe/processor/twostage/plugin/TwoStageCountProcessorTest.java => confignode/src/test/java/org/apache/iotdb/confignode/conf/ConfigNodeConfigTest.java} (50%)
create mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/conf/LoadStatisticsPublisherConfigTest.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
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/partition/PartitionManagerRegionMaintainTest.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/SubscriptionCoordinatorTest.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
delete mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/region/RemoveRegionGroupProcedureTest.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/config/UserDataTransferAuditClassifier.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
delete mode 100644 iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RateLimitedGrpcFactory.java
delete mode 100644 iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RateLimitedGrpcLogAppender.java
create mode 100644 iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/client/DispatchLogHandlerTest.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/iot/subscription/SubscriptionQueueRegistryTest.java
create mode 100644 iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/subscription/SubscriptionWalRetentionCalculatorTest.java
create mode 100644 iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/pipe/metric/IoTConsensusV2ServerMetricsTest.java
delete mode 100644 iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/ratis/RateLimitedGrpcLogAppenderTest.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/audit/DataNodeUserDataTransferAuditor.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/audit/UserRoleModificationAuditContext.java
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{pipe/resource/memory/PipeTsFileMemoryBlock.java => exception/load/LoadAnalyzeInvalidPathException.java} (74%)
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/query/{QueryTimeoutRuntimeException.java => DeviceEntrySpillNotFoundException.java} (60%)
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/agent/task/subtask/processor/PipeProcessorSubtaskExecutionGuard.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/subtask/processor/PipeProcessorSubtaskYieldException.java
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{utils/datastructure/QuickAlignedTVList.java => pipe/event/common/tsfile/parser/TsFileInsertionEventParserMemoryBlock.java} (62%)
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/TsFileInsertionEventParserMemoryManager.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/{utils/datastructure/TimAlignedTVList.java => pipe/processor/downsampling/DownSamplingTimeUtils.java} (54%)
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/binaryallocator/arena/ArenaStrategy.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/execution/fragment/QueryDataSourceLease.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/PipeReceiverRuntimeSnapshotFilter.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/ShowReceiversOperator.java
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/{RelationalAuthorizerTask.java => AlterTableSetColumnPropertiesTask.java} (54%)
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/memory/{ConsumeAllChildrenPipelineMemoryEstimator.java => OperatorMemoryNotEnoughException.java} (55%)
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/ShowReceiversNode.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/metadata/fetcher/DeviceEntryFetchContext.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/AbstractDeviceEntryMaterializer.java
copy iotdb-core/{metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/NodeType.java => datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/BatchDeviceEntrySource.java} (68%)
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntryDataSet.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntryDataSetHandle.java
copy iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/task/PipeConfigNodeTask.java => datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntryDataSetResult.java} (54%)
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntryDiskSpiller.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntryFileSpillerReader.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntryIOContext.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntryMaterializationMemoryController.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntryMaterializer.java
copy iotdb-core/{metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/NodeType.java => datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntryReader.java} (69%)
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntryRpcSegmentFetcher.java
copy iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/PipeTask.java => datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntrySegmentFetcher.java} (74%)
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntrySortedMaterializer.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntrySpillManager.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/InMemoryDeviceEntryDataSet.java
copy integration-test/src/main/java/org/apache/iotdb/it/env/remote/config/RemoteConfigNodeConfig.java => iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/InMemoryDeviceEntrySource.java (56%)
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/LocalSegmentDeviceEntrySource.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/RemoteSegmentDeviceEntrySource.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/SegmentDeviceEntrySource.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/SpilledDeviceEntryDataSet.java
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/statement/metadata/pipe/ShowPipeMemoryStatement.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/ShowReceiversStatement.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/metrics/DataNodeExceptionMetrics.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/MemChunkTimeRangeUtils.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/LoadTsFilePathUtils.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTsFilePieceNodeAssembler.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/converter/PipeTsFileConversionTaskManager.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/LoadTsFileParserMemoryManager.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/test/java/org/apache/iotdb/db/audit/DNAuditLoggerRevokeFailureTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/audit/DNAuditLoggerUserRoleModificationTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/audit/DataNodeUserDataTransferAuditorTest.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/ActiveLoadListeningDirConfigTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/conf/IoTDBDescriptorDefaultMemoryConfigTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/conf/IoTDBDescriptorSystemPropertiesTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/conf/QueryThreadPoolConfigTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/SchemaRegionTableDevicePerformanceTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/runtime/PipeAgentLauncherTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/subtask/processor/PipeProcessorSubtaskExecutionGuardTest.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/agent/task/subtask/processor/PipeProcessorSubtaskWorkerTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/task/subtask/sink/PipeSinkSubtaskLifeCycleTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/consensus/deletion/persist/PageCacheDeletionBufferTest.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/processor/aggregate/window/processor/TumblingWindowingProcessorTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/receiver/transform/statement/PipeConvertedInsertTabletStatementTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/payload/evolvable/batch/PipeTransferBatchReqBuilderTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/async/IoTDBDataRegionAsyncSinkTest.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/sink/util/cacher/LeaderCacheUtilsTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/DataRegionListeningFilterTest.java
copy iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/{processor/twostage/plugin/TwoStageCountProcessorTest.java => source/dataregion/DataRegionWatermarkInjectorTest.java} (55%)
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/client/ConfigNodeInfoTest.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/DataNodeInternalRPCServiceImplDiskTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/thrift/impl/DataNodeInternalRPCServiceImplLoadTest.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/protocol/thrift/impl/DataNodeInternalRPCServiceImplSubscriptionDisabledTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/exchange/SinkChannelFailurePropagationTest.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/FragmentInstanceManagerTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/fragment/QueryDataSourceLeaseTest.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
copy iotdb-core/datanode/src/test/java/org/apache/iotdb/db/{pipe/processor/twostage/plugin/TwoStageCountProcessorTest.java => queryengine/execution/operator/process/ai/InferenceOperatorTest.java} (52%)
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/execution/operator/source/SeriesScanUtilCancellationTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/source/ShowReceiversOperatorTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/DeviceIteratorScanOperatorTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/InformationSchemaReceiversSupplierTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/schedule/DriverTaskThreadTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/analyze/schema/SchemaValidatorTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/DatabaseSchemaTaskTest.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
copy iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/{pipe/ShowPipeTaskTest.java => subscription/ShowSubscriptionsTaskTest.java} (52%)
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/predicate/ConvertPredicateToFilterVisitorTest.java
rename iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/parser/{RemoveDataNodeMultiNodeParseTest.java => RemoveNodeSingleNodeParseTest.java} (66%)
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/parser/ShowSubscriptionsStatementTest.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/relational/metadata/fetcher/SchemaPredicateUtilTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntryMaterializerTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/DeviceEntryRpcSegmentFetcherTest.java
copy iotdb-core/datanode/src/test/java/org/apache/iotdb/db/{pipe/processor/twostage/plugin/TwoStageCountProcessorTest.java => queryengine/plan/relational/metadata/spill/InMemoryDeviceEntrySourceTest.java} (51%)
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/spill/SegmentDeviceEntrySourceTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/AggregationNodeRateSerdeTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/TableModelPlannerTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/distribute/TableDistributedPlanGeneratorRateTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/informationschema/ShowReceiversTest.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/security/AccessControlImplTest.java
copy iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{parser/RemoveDataNodeMultiNodeStatementTest.java => ShowSubscriptionsTest.java} (57%)
rename iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/sql/parser/{RemoveDataNodeMultiNodeStatementTest.java => RemoveNodeSingleNodeStatementTest.java} (70%)
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/relational/sql/parser/StreamKeywordTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/scheduler/AsyncPlanNodeSenderTest.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/schemaengine/schemaregion/utils/ResourceByPathUtilsTest.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/WritingMetricsTest.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/MemChunkTimeRangeUtilsTest.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/dataregion/wal/buffer/WALBufferRollRecoveryTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/wal/node/WALFileListCachePerformanceTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFilePieceNodeAssemblerTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/converter/LoadTsFileInvalidPathTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/converter/LoadTsFileParserPipeMemoryIsolationTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/converter/PipeTsFileConversionTaskManagerTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/agent/SubscriptionReceiverAgentTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/ConsensusSubscriptionBrokerOwnershipTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/ConsensusSubscriptionBrokerPayloadLimitTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/subscription/broker/SubscriptionBrokerAgentPayloadLimitTest.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/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/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
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/CommonUtilsTest.java} (57%)
copy iotdb-core/{confignode/src/test/java/org/apache/iotdb/confignode/manager/ClusterSchemaManagerTest.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/datanode/src/test/java/org/apache/iotdb/db/utils/datastructure/AlignedBitmapRangeCheckPerformanceTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/datastructure/AlignedSparseWritePerformanceTest.java
create mode 100644 iotdb-core/metrics/core/src/test/java/org/apache/iotdb/metrics/core/MetricManagerLifecycleTest.java
create mode 100644 iotdb-core/metrics/core/src/test/java/org/apache/iotdb/metrics/core/reporter/IoTDBJmxReporterTest.java
create mode 100644 iotdb-core/metrics/core/src/test/java/org/apache/iotdb/metrics/core/type/IoTDBAutoGaugeTest.java
create mode 100644 iotdb-core/metrics/core/src/test/java/org/apache/iotdb/metrics/core/utils/IoTDBMetricObjNameFactoryTest.java
create mode 100644 iotdb-core/metrics/interface/src/test/java/org/apache/iotdb/metrics/reporter/prometheus/PrometheusReporterTest.java
create mode 100644 iotdb-core/node-commons/src/assembly/resources/conf/edge/iotdb-system.properties
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/en/org/apache/iotdb/commons/i18n/StorageMessages.java
create mode 100644 iotdb-core/node-commons/src/main/i18n/zh/org/apache/iotdb/commons/i18n/LBACMessages.java
create mode 100644 iotdb-core/node-commons/src/main/i18n/zh/org/apache/iotdb/commons/i18n/StorageMessages.java
copy iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{pipe/agent/task/PipeTask.java => audit/TrustedChannelFailureHandler.java} (70%)
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/audit/UserDataTransferAuditEvent.java
copy iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/audit/{AuditEventType.java => UserDataTransferAuditHandler.java} (54%)
copy iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{pipe/agent/task/PipeTask.java => audit/UserDataTransferErrorCode.java} (81%)
copy iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/resource/memory/PipeTsFileMemoryBlock.java => node-commons/src/main/java/org/apache/iotdb/commons/audit/UserDataTransferProtectionMethod.java} (78%)
delete mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/binaryallocator/BinaryAllocator.java
delete mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/binaryallocator/BinaryAllocatorState.java
delete mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/binaryallocator/PooledBinaryPhantomReference.java
delete mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/binaryallocator/arena/Arena.java
delete mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/binaryallocator/autoreleaser/Releaser.java
delete mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/binaryallocator/config/AllocatorConfig.java
delete mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/binaryallocator/ema/AdaptiveWeightedAverage.java
delete mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/binaryallocator/evictor/Evictor.java
delete mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/binaryallocator/metric/BinaryAllocatorMetrics.java
delete mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/binaryallocator/utils/SizeClasses.java
copy iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/protocol/client/ConfigNodeClient.java => node-commons/src/main/java/org/apache/iotdb/commons/client/AbstractConfigNodeClient.java} (53%)
copy iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/protocol/client/ConfigNodeInfo.java => node-commons/src/main/java/org/apache/iotdb/commons/client/AbstractConfigNodeInfo.java} (74%)
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/AbstractIoTDBStartCheck.java
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon/disk => node-commons/src/main/java/org/apache/iotdb/commons/disk/utils}/DirectoryChecker.java (77%)
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/pipe/PipeRuntimeSinkResourceException.java
copy iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/exception/query/QueryTimeoutRuntimeException.java => node-commons/src/main/java/org/apache/iotdb/commons/exception/table/TableInDeletionException.java} (52%)
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/lbac/LBACAccessDeniedException.java
rename iotdb-core/{consensus/src/main/java/org/apache/iotdb/consensus/ratis/RateLimitedGrpcRpcType.java => 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-core/{confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/RemoveRegionGroupState.java => node-commons/src/main/java/org/apache/iotdb/commons/lbac/operation/LabelAccessType.java} (87%)
delete mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/sink/opcua/OpcUaSink.java
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/runtime/PipeReceiverRuntimeRegistry.java
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/runtime/PipeReceiverRuntimeSnapshot.java
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/resource/PipeRecentFailureCounter.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/pipe/resource/PipeResourceFailureType.java (67%)
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/resource/PipeStopStrategy.java
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/payload/thrift/request/PipeTransferPipeReceiverRuntimeInfoCleanupReq.java
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/queryengine/plan/udf/ForecastTimeUtils.java
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/service/TrustedChannelAuditServerEventHandler.java
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/service/metrics => node-commons/src/main/java/org/apache/iotdb/commons/service/metric}/ProcessMetrics.java (97%)
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/snapshot/ReusableBufferedOutputStream.java
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/snapshot/SnapshotStreamFactory.java
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/subscription/meta/consumer/SubscriptionProgressSnapshot.java
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/main/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/FFTTableFunction.java
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/FilterTransferTableFunction.java
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/HighPassTableFunction.java
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/LowPassTableFunction.java
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/XCorrTableFunction.java
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/fft/DoubleFFT_1D.java
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/fft/FloatFFT_1D.java
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/audit/AbstractAuditLoggerTest.java
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/audit/UserDataTransferAuditEventTest.java
delete mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/binaryallocator/BinaryAllocatorTest.java
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/client/ClientManagerMetricsTest.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
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/conf/CommonConfigTest.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/consensus/index/ProgressIndexTest.java
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/agent/plugin/service/PipePluginExecutableManagerTest.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/pipe/receiver/runtime/PipeReceiverRuntimeRegistryTest.java
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/resource/PipeRecentFailureCounterTest.java
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/resource/PipeStopStrategyTest.java
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/source/IoTDBNonDataRegionSourceTest.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/schema/filter/impl/DeviceFilterUtilTest.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/schema/table/AuditTest.java} (55%)
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/service/TrustedChannelAuditServerEventHandlerTest.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/MetricReporterSwitchTest.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/snapshot/SnapshotStreamFactoryTest.java
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/subscription/meta/consumer/SubscriptionProgressSnapshotTest.java
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/subscription/topic/TopicMetaKeeperTest.java
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/FFTTableFunctionTest.java
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/ForecastTimeUtilsTest.java
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/TimeWindowTableFunctionBoundaryTest.java
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/fft/FFT1DTest.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 (79%)
rename {example/pipe-opc-ua-sink => library-pipe/opc-ua-sink-example}/src/main/java/org/apache/iotdb/opcua/ClientExample.java (92%)
rename {example/pipe-opc-ua-sink => library-pipe/opc-ua-sink-example}/src/main/java/org/apache/iotdb/opcua/ClientExampleRunner.java (79%)
rename {example/pipe-opc-ua-sink => library-pipe/opc-ua-sink-example}/src/main/java/org/apache/iotdb/opcua/ClientTest.java (66%)
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 (77%)
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 (86%)
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 (52%)
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 (83%)
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 (68%)
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
create mode 100644 library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink/opcua/OpcUaSinkTsFileMetadataTest.java
create mode 100644 library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink/opcua/OpcUaSinkTsFilePerformanceTest.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/client/ClientRunnerTest.java (97%)
create mode 100644 library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink/opcua/client/IoTDBOpcUaClientTest.java
create mode 100644 library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink/opcua/server/OpcUaNameSpaceMetadataTest.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/server/OpcUaServerBuilderTest.java (58%)
create mode 100644 library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink/opcua/server/OpcUaTcpNoneCompatibilityTest.java
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/TimAlignedTVList.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/conf/edge-env.sh
create mode 100644 scripts/conf/windows/edge-env.bat
create mode 100644 scripts/sbin/start-edge.sh
create mode 100644 scripts/sbin/stop-edge.sh
create mode 100644 scripts/sbin/windows/check-edge.ps1
create mode 100644 scripts/sbin/windows/start-edge.bat
create mode 100644 scripts/sbin/windows/stop-edge.bat
create mode 100644 scripts/tools/README.md
copy iotdb-client/client-py/iotdb/utils/BitMap.py => scripts/tools/import-wal.sh (51%)
create mode 100644 scripts/tools/ops/daemon-edge.sh
create mode 100644 scripts/tools/ops/destroy-edge.sh
create mode 100644 scripts/tools/windows/import-wal.bat
create mode 100644 scripts/tools/windows/ops/destroy-edge.bat
rename iotdb-client/jdbc/osgi.bnd => src/main/forbidden-apis/secure-erase (67%)