You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2023/11/20 01:33:08 UTC
(iotdb) branch native_raft updated (7c867432cc1 -> eecbc7c8bdd)
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch native_raft
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 7c867432cc1 fix configuration
add 3073fe63bc3 [IOTDB-6029] flink-sql-iotdb-connector (#10958)
add daebc419e0e Pipe: Increase the injection frequency of HeartBeatEvent to reduce the delay in log transferring (#10970)
add 8424f821475 Accelerate the deletion execution (#10967)
add f1a4012424f Pipe: drop HeartbeatEvent when pipe is stopped to avoid OOM (#10977)
add f80c2894f42 Fix point priority reader array index out of bound exception (#10919)
add c307a455819 Reimplement compaction memory estimator (#10951)
add 7a005340bb1 add lazy page reader for aligned page reader to avoid huge memory cost when reading rows of aligned timeseries (#10966)
add 7356c8a435c upgrade ratis snapshot version to 2.5.2-8efe8a1-SNAPSHOT (#10971)
add 9669a68b185 Feature add insertRecords method to rest service (#10832)
add d11974558d1 [IOTDB-6082] Improve disk space metrics (#10983)
add 1357cede80d Pipe: fix some minor concurrent issues & collect pipe's logs into a separate file (#10990)
add f869a95cfef [IOTDB-6119] Add ConfigNode leader service check (#10985)
add 39819a2bd1d [IOTDB-6061] Fix the instability failure caused by initServer in IoTConsensus UT not binding to the corresponding port (#10991)
add 656c462af56 [IOTDB-6129] ConfigNode restarts without relying on Seed-ConfigNode (#10988)
add 35736cc6782 Pipe: Fix start-time and end-time parameters not working when extracting history data (#11001)
add 155c181ad6e fix (#10993)
add b1ac40b42b9 fix wal npe when memTable has flushed. (#10899)
add d5450a1e564 [IOTDB-6134] Fill statement content in show queries for inner schema fetch
add d1c0cf9050c Optimize python client package and release process (#11007)
add ed87567e56b Fix possible NPE while executing show cluster or show cluster details
add cd57fefbf13 Pipe: Add IT for pipe lifecycle, pipe syntax, pipe extractor parameters (#11019)
add 35ffb5128db [IOTDB-6135] Pipe: Fix a bug which keeps generating PipeHeartbeatEvent unnecessarily (#11008)
add 00cb64c2718 Move Jenkins notification to notifications list (#11029)
add eb43b4909a7 Pipe: Report queue size in PipeHeartbeatEvent (#10997)
add eee581e1c1f Perfect plan graph for last query scan node
add 7d9ac670327 [IOTDB-6130] Delete data by specific pattern didn't work
add 1a3568ff2a0 Pipe: Improve performance for 10000+ pipes (#11021)
add 43aa7db32f3 Added file overlap analysis tool (#11030)
add 815c21b3fb8 Fixed wal triggering disk threshold loop too many times (#11017)
add 4be0aaaafdd [RatisConsensus] use warn_and_return to enable cluster restart when log corruption can be ignored (#11036)
add eb500c9db70 Fix mods file contains writable view
add b9ed1ed9ce5 [RatisConsensus] retry cache expiration time should be longer than retriable-client wait duration (#11045)
add 66206461638 Fix/grafana plugin error (#11043)
add 2f7e99b14ae [IOTDB-6139] Refine Ratis Properties (#11047)
add c9315c755cb [IOTDB-6138] Fix the support of negative timestamp (#11033)
add d2da03655ec Change display nums of client to fixed 1000
add d33b16b1ffd [IoTDB ML] Basic model training and inference features available
add 975ff0199d7 Fix negative requested permit of CompactionWriteRateLimiter (#11066)
add f39b994873c Fix incorrect package path for modelInferenceException (#11072)
add e991dc09991 fix readonly because of disk full (#11059)
add ac0dd9d3111 Pipe: Fix ConcurrentModificationException caused by concurrently iterating through CachedSchemaPatternMatcher.extractors when an PipeHeartbeatEvent is being assigned (#11074)
add 54e11400bb0 [IOTDB-6142] Pipe: Implemented IoTDBOpcUaConnector to enable transfer using Opc Ua protocol (#10976)
add ba46d351ed5 Pipe: include creation time in PipeProcessorSubtask#taskID to avoid task scheduling issues after 1000+ pipes' creating and dropping (#11078)
add 6cc9b6a903a Fix compaction speed calculation (#11055)
add 5223b60b427 [IOTDB-6128] Pipe: supporting multiples device operation in flink-sql-iotdb-connector (#11010)
add c4ff2b13449 Pipe: Clear reference count of on-the-fly EnrichedEvent in queues when pipe is dropped (#11077)
add 71a98702a63 Use codecov to show code coverage (#11079)
add f910c66bee3 Fix/release findings (#11088)
add e71d22c52b6 Update badge in README.md (#11093)
add 1ec1264e2d5 Remove some copyright info (#11095)
add 624895955d3 Tsfile resource validation and repair tool (#10984)
add 420af60cd8d Fix seq space file num and size statistics (#10982)
add f6fed7c6706 [IOTDB-6144] Adjust the default thrift timeout parameter to 60s (#11091)
add 4f1fe0638cd [IOTDB-6137] Improved error messages for expressions as constants in GROUP BY
add 27b8e5bebae [RatisConsensus] Bump ratis snapshot version to 2.5.2-284ecbb-SNAPSHOT (#11089)
add 5ea3166aa23 Permission mode refine final pr
add 97d9cea38ed Correct the license info of hbase (#11115)
add 7c760f29d00 fix count_time bug
add a5e315d7a99 fox code smell
add 7309e3282f5 Change default encoder of INT32 and INT64 from RLE to TS_2DIFF (#11114)
add f0259706b17 Auth online upgrade
add 3c24fa31750 [IOTDB-6147] Alter view does not check the source path
add 1f7d56f6f4e [IOTDB-6148] Pipe: Fixed the bug that some uncommited progresses may be reported (#11125)
add b49d0fb96f2 Pipe: fix NPE when HybridProgressIndex.updateToMinimumIsAfterProgressIndex after system reboot (DR: SimpleConsensus) (#11126)
add 82188e378a7 [IOTDB-6149] Fix incorrect output of UDF with multiple inputs
add c23013463d2 Pipe: use PipeTaskCoordinatorLock instead of ReentrantLock for multi thread sync (#11129)
add 0abbee3afbf fix session sessionDataSet unclose when use export tsfile tool (#11131)
add ce932ba81e7 Pipe: push down the construction of history events to save memory when large amount of pipes are running (#11067)
add d095eae36c1 Fix/addressed issues with rat not being able to process the source bundle (#11098)
add 7c333ac53b4 Remove cancelled/done MemoryReservationFuture from the queue when freeing memory
add 77a7dcf6ad0 [IOTDB-6152] Add IoTConsensus Sync Log Timer (#11134)
add 9ebb70cd70c [IOTDB-6155] Fix some minor bugs of flink-sql-iotdb-connector (#11143)
add 7e878aa7bf7 Add replication factor metrics and add database tag in throughput metrics and schema metrics (#11113)
add 5c719ecec4d [IOTDB-6151] Move datanode system.properties (#11153)
add 5f5a1d4fb7d Enhance last query, support non single base series (#11120)
add ca7b9d0ff02 [To rel/1.2][IOTDB-6156] Fixed TConfiguration invalidly in Thrift AsyncServer For IoTConsensus
add 0b3db97b9da Remove the useless code and fix smell in last query (#11156)
add bdb6bd6da90 Pipe: fix pipe procedure stuck because of data node async request forever waiting for response (#11157)
add d06746a045e [IOTDB-6158] add examples and ITs for flink-sql-connector (#11152)
add 94caed8d802 Fix storage group to database (#11160)
add ccb88e3a4e2 Delete unused compaction recover code (#11147)
add 42df87d1cb0 Fix the warn log in IT (#11164)
add 3313d742104 [IOTDB-6159] Pipe: Supported E-language payload in air gap connector/receiver (#11136)
add 1aa098cda93 [IOTDB-6157] Check timestamp precision when insert (#11151)
add c813d2e71ad [IOTDB-6163] fix bug of option sql parsing error in flink-sql-connector (#11174)
add d0cf8d6dbe2 Pipe: fix pipe coordinator deadlock causing CN election timeout (#11176) (#11177)
add e488a7c1bc2 [IOTDB-6164] Fix create illegal path through rest api bug (#11178)
add 4d7aaeb8c9c [IOTDB-6143] Pipe: Support PipeConnector subtasks with the same parameters concurrently scheduling (#11083)
add 6f1a5454eb8 [IOTDB-6162] Enhanced accuracy in deleting data
add d7396bfc349 Fix datanode stuck when meets disk error (#11172)
add d654e03c869 Fix NPE issue when setting system to readonly manually (#11166)
add 90823c819e7 Fix auth check of CreateAlignedTimeSeries
add 66ebb0b57d8 [IOTDB-6167] DataNode can't register to cluster when fetch system configuration throws NPE(#11187)
add 9c751ad657a Fix metric of auth
add f48bc2c6d79 Optimize python client insert records values serialization (#11193)
add 6cbe5f0d577 [IOTDB-6165] Pipe: cache device metadata in TsFile reader to avoid redundant IO (#11186)
add a9093c29250 [ISSUE-11199] Pipe: fix NPE when casting from null values in InsertRowNode deserialization (#11200)
add 10a0614dcf3 Pipe: fix NPE in PipeEnrichedInsertBaseStatement#isQuery when analyzing statement in metadata mismatch scenarios (#11203)
add 8a845dd05b4 Sl fix auth bugs
add 3250550f9a6 [IOTDB-6154] Pipe: better algorithm for hybrid mode to switch log/tsfile extraction in iotdb-extractor (#11142)
add 3f8c344b3a8 Pipe: fix file handle leak when processing with extractor.pattern (#11209)
add b4c2caeaf2f Manipulate series of Audit and IoTDB reporter as super user
add 5c7718ea8fa Pipe: Add IT for different cluster config and consensus protocols (#11097)
add 8980844590a Add UT for session module (#11158)
add 53a2bee7b20 Fix the dead lock bug when the generated distributed query plan contains cycle
add 0cb79e5f07e [IoTDB-6172] Finish canAddTsBlock of SharedTsBlockQueue to ensure that blocked Driver could be correctly finished
add 9a7e114a5b6 Ensure concurrency safety when updating last cache
add 2fd218422b6 Optimize the python client performance for Python 3.10 or later (#11198)
add 1c3a59e4b9b Pipe: Added tablet event count and tsfile event count to PipeHeartbeatEvent reports (#11225)
add 6e7088ae6ae [IOTDB-6170] Pipe: Removed unnecessary parse when tsFile resources' time ranges are covered by startTime-endTime (#11211)
add a4eeeba9759 SchemaCache supports precise eviction
add ae8f284d429 Fix the data scan ordering when executing last query
add ed62ba67cd4 [IOTDB-6168] ConfigNode register retry logic does not worked (#11188)
add 9ab3c422cdb Auth online upgrade
add fde69bc82c2 Fix auth check when alter and create view
add 0f2cf0a3b48 Optimize merge selection process and increase disk space availability logic (#11197)
add 1c3ab3900c7 Pipe: fix drop pipe stuck (make connector subtask close faster by early returning) (#11222)
add 62a956d3ed5 [auth].fix internal error when check sysPri grant option
add 4d3a16fb61b Bump org.apache.avro:avro in /iotdb-connector/hive-connector (#11236)
add 7af3d774343 Bump org.apache.tomcat.embed:tomcat-embed-core from 10.1.0-M1 to 10.0.27 in /iotdb-core/datanode (#11235)
add 4d38980c075 Bump postcss from 8.4.21 to 8.4.31 in /iotdb-connector/grafana-plugin (#11238)
add 24dd2b7f2c9 [IOTDB-6160] Correct the target paths verify logic in Select Into
add 68b394a470e Pipe: instantiate iotdb-thrift-connector from sync to async (#11248)
add e929ceed0c0 Allow `\``*`\`` in DevicePath (#10901)
add e3c8643fae2 chore: Enable ge.apache.org
add fefb873a8bf Pipe: add status message for procedure execution timed out (#11257)
add 18a4d91b94f [IOTDB-6177] Pipe: Removed the exception time judgement when reporting exceptions to avoid losing failure message (#11249)
add 7c976f13c55 [IOTDB-6176] Pipe: record SimpleProgressIndex for insertion when using SimpleConsensus to avoid wrong advance progress report (#11255)
add 6f83353c2f3 [IOTDB-6179] Load: remove uncessary create schema logic when loading tsfiles (which allows users without create schema permission to execute load) (#11256)
add 9ffca1c7997 Load: skipping instead of throwing exceptions when loading empty tsfiles (#11261)
add ff7fdb795ab [IOTDB-6183] Optimize the timeout retry logic of IoTConsensus sending RPCS (#11266)
add c0260ea7b5c Fix NPE when partially inserting tablet span multiple data partitions
add f36af625129 Add database and region tag into tsfile metrics (#11228)
add f22baa079c0 [IOTDB-6185] Fix show cluster null status bug (#11273)
add 6a3b3e33650 Fixed failed to compile Grafana plugin using the latest version of SDK (#11271)
add 59e97fd405a [IOTDB-6184] MergeSort should break when one tsBlock is run out in one iteration. (#11270)
add 1be2eebac36 Fixed ping command for rest service (#11247)
add 8951eb8ce04 Pipe: running count of the connector does not return to zero after exceptions occur (resulting in the failure of the automatic restart mechanism) (#11279)
add 9111d69d217 Refactor the CompactionWorker part of Compaction framework (#11242)
add f3619920e29 Bump golang.org/x/net in /iotdb-connector/grafana-plugin (#11288)
add 5bbe062515c Pipe: fix recovering huge entry from wal with wrong position bug & fix multi pipes sharing the same ByteBuffer (#11285)
add 2ee7675ce10 Pipe: make hybrid extractor aware of event collector's queue size & block processor subtask's execution when events buffered in EventCollector (#11283)
add 4cee8227e75 [IOTDB-6182] Add fsync in ConfigNode persistence modules (#11264)
add 52ce8855836 Add stopwatch for AbstractConsumeAllOperator
add 32a1e10b2e4 Fix SYS_DISK_FREE_SPACE metric and add SYS_AVAILABLE_SPACE metric (#11289)
add af56f90e26a Added fsync operation when persisting files (#11275)
add 1d1b52cccb8 Optimize result set iteration in Python Client (#11231)
add 848af7209ec upgrade compression ratio file name format and solve the problem of high compression ratio caused by repeated data writing (#11220)
add b61f634b57e Fix the problem of inaccurate GC monitor detection at the beginning and adjusting the alert threshold. (#11297)
add 8c384da094c [IOTDB-6188] Load: Optimize the return of error codes related to user privileges (#11299)
add 17ba8eb944f add disk free ration check before compaction task start (#11292)
add 5f7a0bff761 Fix potential loss of metrics when restart confignode (#11287)
add 0b57fd39e1d [auth].fix error when check role. (#11293)
add c66f53faf97 fix(csv):Fixed the prompt after CSV file import (#10835)
add cfca49e0e0f Pipe: fix tsfile and wal forever pinned when enabling log batch mode in iotdb-async-thrift-connector & fine tune hybrid extractor mode (#11305)
add ae77b4f360e [IOTDB-6190] Increase the threshold for Ratis to shut itself down if it detects that a process is stuck
add ba77da8a75a [IOTDB-6178] Add fsync for schemaregion, CQInfo, ModelInfo
add 46fd4520026 Fix bad tsfile being recoverd from wal (#11276)
add e1a0830ff27 ci(grafana): only build on iotdb-connector/grafana-plugin/** changed (#11311)
add 16f287f2cab Fixed an issue where searchIndex was not restored properly after IoT protocol restart (#11306)
add 24f24eaee51 Set ShowQuries related DriverTasks to the highest priority
add 676a21bacbd fix(cli-windows): Ensure that any user defined CLASSPATH variables are not used on startup (#11316)
add e93d0fcaaa6 Set default compaction validation level to RESOURCE_ONLY (#11278)
add 15824d9a292 Pipe: fix missing `pipeReceiverFileDir` update after updating `systemDir` during conf initialization (#11318)
add 37a5212f23a [IOTDB-6175] Add TopKNode for `order by time|expression limit N align by device` query and push down LIMIT value.
add 87a15d2860a [IOTDB-6189] Fix bugs for csv-tools (The output is incorrect when the import fails. The csv file with bom header can not be imported. The last line can not be imported) (#11308)
add fd1b9823d8e Refactor/managing dependencies (#11150)
add b029ffffa42 Bump org.xerial.snappy:snappy-java from 1.1.8.4 to 1.1.10.4 (#11216)
add 2eec1fb633e Bump go.opentelemetry.io/contrib/instrumentation/net/http/httptrace/otelhttptrace (#11321)
add 3727570a7c6 fixed grafana-plugin compilation failure (#11322)
add 7aaeb22b62c Bump @babel/traverse in /iotdb-connector/grafana-plugin (#11325)
add 9a25e6c4ba4 Bump org.eclipse.jetty:jetty-http (#11326)
add 6771d33da31 [IOTDB-6192] Remove redundant mergeSortOperator in 'ORDER BY TIME ALIGN BY DEVICE' (#11320)
add 879d7020ff3 [IOTDB-6141] Optimize the large time range raw query performance
add 76a5f5d848c Pipe: decouple pipe receiver directory from the system directory and add support for multiple folders (#11333)
add aa091b0882b [IOTDB-6193] Reject Node startup when loading configuration file failed (#11331)
add 01275e6cb27 [IOTDB-6191] Fix group by year
add 89f37300927 Pipe: fix all tablets become non-aligned when using batch mode (#11343)
add 5da895ab08e Pipe: fix potential NPE risk when reflecting `pipeReceiverFileDirs` (#11346)
add fd1ba791919 Make show version can be used by anyone
add 82303b66e11 Add batch operators loading in the next method of TopKOperator
add af2c5ee51ff [IOTDB-6171] Implement getRegionReplicaSet method of QueryExecutor
add e28a27c1eda [IOTDB-6195] Fix bug in group by month while using left open and right close syntax
add 2a30dcd2c45 Fix tag value in file metrics (#11344)
add e2bfd156bea add path check example (#11336)
add 6700c84cd0d fix(start-cli):add add-opens script (#11353)
add 5eff10ec013 Pipe: integrate pipe with metrics framework & add assigner / extractor / processor / connector / heartbeat metrics (#11302)
add df374105ba9 [IOTDB-6169] Pipe: Allocate a PipeInsertNodeCache to each leader data region (#11201)
add eb22612eef9 [IOTDB-6200] Change schema template to device template
add 960952e0a7d [IOTDB-6201] Fix possible query timeout error in TimeJoinNode and possible query cycle in last query.
add 212a72d0a01 Refactor Compaction recover and exception handle logic (#11349)
add a45e4414dd1 Use bash instead of sh in integration test
add 6f6f6425c7f [IOTDB-6197] Improvements on periodic snapshot guardian (#11342)
add ce4fc833223 [IOTDB-6194] Remove _list from parameter target_config_node_list (#11335)
add 0118acaa963 Fix partition interval may be not set correctly
add 7759b8747a7 Add SLEEP_BOUND for the DriverTaskTimeoutSentinelThread
add 3602124f76b Fix auth upgrade 1.2 (#11355)
add ca7fbfe0192 Add Interface to extend TsFileResource (#11362)
add e1ba3ac52a2 fix(cli-it): add IOTDB_HOME into environment (#11363)
add abb688bd323 Pipe: introduce wal entry write cache for realtime log mode (#11366)
add 6a2a4b468d1 auth.add entry for pre version plan
add 224da329db8 Fix the scope of metric module in pom.xml (#11368)
add 64449a45c81 fix(config):remove accidental space (#11371)
add 044a00b83b9 Remove UDTFJexl from built-in function (#11365)
add 273ade23501 Fix aligned timeseries may loss point after flush
add 5debd8a757a [IOTDB-6202] Pipe: listen to tsfile load when realtime mode = forced-log (#11369)
add 161e3a7b175 Pipe: add fsync ops for PipePluginInfo, PipeTaskInfo, IoTDBThriftReceiverV1, IoTDBThriftReceiverV1 and ExecutableManager (#11351)
add 34de5255f31 [IOTDB-6203] Remove rpc_thrift_compression_enable hard code (#11370)
add cebd62b6c36 [IOTDB-6205] Pipe: Fixed null pointer exception (NPE) when getting historical pending queue size in metrics (#11374)
add 4757f4d2960 [IOTDB-6198] Pipe: Memory Management Framework (#11350)
add e8e2353f5ee [IOTDB-6204] Pipe: Changed the default settings and add manual configuration logic for opc-ua-connector key directory (#11373)
add 1c2c42845e7 rest service adjustment permission authentication (#11312)
add 06a44df157e Pipe: fine tune hybrid mode by removing tooManyWALPinned judgement and increasing pipeMaxAllowedPendingTsFileEpochPerDataRegion to 2 (#11382)
add 617bfcea3d3 Pipe: assign progress index for sealed tsfile recovery (#11384)
add 1448699284e Pipe: support parameter extractor.history.sloppy-time-range to improve historical data processing efficiency (#11387)
add 5e392a232b4 docs: update build cli documentation in README (#11385)
add e434a120246 feat(env):add MEMORY_SIZE parameters into env.sh/env.bat (#11380)
add ea575bab472 Skip loading Chunk without matched ChunkMetadata (#11376)
add dc049d4e81b check startTime and endTime in isSatisfied of TsFileResource
add 96f2164fe03 Revert "Remove UDTFJexl from built-in function (#11365)"
add e973e6725f8 Pipe: improve db-level pipe performance by removing useless pattern check (#11386)
add ffa327154f0 [IOTDB-6187] IoTConsense WAL Interval Reading Strategy Optimization (#11291)
add 7b4fbb1c699 Avoid modification causing OOM while there is much deletion entry in mods file
add 2d8090da0a0 Improve the high availability of IoTDB
add 655ed78c9b0 Add fsync for AuthorInfo, ClusterSchemaInfo, TriggerInfo and UDFInfo
add ee459bdc81c Pipe: add memory / cache hit rate / resource reference count / tsfile epoch metrics (#11388)
add e3e5f688cf5 Add missing UDF registration commands in scripts. (#11391)
add e0271e50cb9 [IOTDB-6211] Restore cluste registered ConfigNodes from system.properties file when restart DataNode (#11402)
add 9c1eb55dc51 [IOTDB-6208] Node error detection through broken thrift pipe (#11397)
add 64f0e3ce14d auth. some improvement.
add e45c251ecb9 Fix TsFileResource endTime error when insert empty tablet and flush (#11404)
add 00fc9b5708b Pipe: rename extractor -> source, connector -> sink, sloppy-time-range -> loose-range (#11406)
add 5732861f698 fixed rest start fail (#11398)
add b13edf3d099 [IOTDB-6207] Load: Add Write Point Rate Metric (#11379)
add 811f019a6e4 PBTree mode support logical view (#11401)
add 7b55646f51d Add fsync for QuotaInfo
add 41a516618fd [IOTDB-6219] Fix the display problem of explain that the print result is not aligned
add bd9c3fa7e37 fix datanode can't stop because wal thread. (#11314)
add e3d2a2ae613 [IOTDB-6151] Move datanode system.properties safer (#11415)
add 7c5feb13613 datanode's dn_rpc_port supports ssl (#11218)
add f3e0f35a09d Fixed Ratis server RPC timeout parameter setting invalidation bug (#11418)
add 5fac123f292 [IOTDB-6190] Increase the threshold for Ratis to shut itself down if it detects that a process is stuck
add 100c7b9afc2 Remove IoTDB-ML Module
add 374b851389d degrade log level of pbtree memory status monitor (#11419)
add 538fd5c43c8 Fix empty tsfile resource didn't remove (#11413)
add 3e01d33e517 Add java doc for SessionDataSet.next() method to let users prefer to use SessionDataSet.DataIterator
add 32e3d066813 Pipe: rename PipeExtractor -> PipeSource, PipeConnector -> PipeSink in pipe-api, antlr (#11427)
add 3adb2e079cc Pipe: Disable batch mode for retry connector in case some events are never retried & Pipe won't collect TsFile without tail magic & Make async connector stop properly when retry count exceeds limit (#11425)
add 4040bfccce4 [IOTDB-6218] Rename storage_query_schema_consensus_free_memory_proportion to datanode_memory_proportion (#11408)
add 1dd5a200281 Speed up recover stage when DataNode restarting (#11421)
add ce82c2b76a6 [IOTDB-6206] Metric: merge metric algorithm library and optimize some core components (#11410)
add 457848c39fb [IOTDB-6220] Pipe: Added connector endpoint check logic to avoid self-transmission (#11417)
add f47675302df Fix PBTree view device isAligned should be null
add c2c70755e54 Extend expected test time of SharedTsBlockQueueTest
add 91310539d9a Add PrivilegeType USE_MODEL
add 6b513b5e933 [IOTDB-6225] Support batch processing in UDF interface
add a4879954d5c Add InsertionCrossSpaceCompaction to move non overlapped unsequence file to sequence space directly (#11414)
add ea3537bf7ed [IOTDB-6223] Pipe: Pipe Memory Management integrates into the Pipe Module (#11424)
add 726403f11ab fix compile error caused by concurrent PR merge in github (#11438)
add ad980dbf973 Fix Compaction Schedule didn't start (#11439)
add f94565d1919 Pipe: rename plugins *-extractor -> *-source, *-connector -> *-sink (#11440)
add 2feb202ca9d add tsfile correctness validation for write compaction and load (#11392)
add 9c05a54f238 feat(env): set MAX_CACHED_BUFFER_SIZE equals OFF_HEAP_MEMORY / IO_THREADS_NUMBER
add a457e8f71fc fixed the issue of missing enableQueryRedirection parameter in SSL (#11436)
add e614c5e8f6c Pipe: remove unnecessary waiting operation for memory alloc calculation (#11445)
add e7592c09d91 fix the issue that compaction scheduler is not started when DataRegion created (#11446)
add 3d9cd3c3052 Refactor Series/Device Quota Limitation (#11422)
add 7915e0a19c4 [IOTDB-6227] Remove unused retry policy in IStateMachine (#11451)
add 2c64ea41227 Fix concurrent read lock bug in StampedWriterPreferredLock (#11453)
add 54b7e6d4cd9 [IOTDB-6220] Pipe: Changed the sink loopback detection logic to support hostName and IPv6 specification. (#11455)
add 13f6e7e61d3 [IOTDB-6234] Pipe: Added client example for opc-ua-connector (#11460)
add a7b745842d4 Pipe: add stream & batch options for source.realtime.mode & remove some pipe plugins from show pipe plugins' dataset & make pipe-api compatible with the v1.2.x releases (#11461)
add c712ce8980e Bump master branch version from 1.3.0-SNAPSHOT to 1.3.1-SNAPSHOT (#11450)
add bce85d58c1f Fix opc-ua-sink version error
add 3b179eeb3ab To adapt activation (#11463)
add da8b9c0bf59 Disable spotless for JDK 21 (#11469)
add ff19689fa6a [IOTDB-6224] Fix group by month in non-ms precision and mixed unit
add ac7629e78f4 [IOTDB-6236] Pipe: CountPointProcessor example (#11470)
add d8580c95122 Implement iterative volatile node process during pbtree flush (#11432)
add 83447eb30b1 [IOTDB-6235] Pipe: Implement write-back-sink to transfer data back to the sender (#11466)
add 1f34ad7c9f8 Fix the path of TsFileResource in unit test
add 93de59e4db0 Pipe: add connector's pending tsfile event count to help isTsFileEventCountInQueueExceededLimit judgement when hybrid mode is enabled (#11476)
add 1df8ec25eea Make all built-in scalar UDF into batch processing
add aa99a220bc3 Pipe: preliminary SSL support for pipe connector (sink) sync client (#11465)
add 3244255e940 fix empty resource recovered from wal (#11452)
add 4e686b9a824 Pipe: Enable github machines instead of self-hosted machines to run pipe IT (#11435)
add 256194a9e28 [IOTDB-6240] Pipe: Fix bug with PipeMemoryManager allocating memory for the DisruptorQueue (#11485)
add cc5ed977507 Pipe: refined key set of tags for pipe metrics & fixed hit rate in PipeWALInsertNodeCacheMetrics always `1.0`(#11484)
add fd3911f4ca6 Pipe: convert the value of source, processor, sink key to lowercase & convert `SHOW_PIPE_PLUGINS_BLACKLIST` keys to uppercase (#11487)
add 0f328ce5eb9 Fix empty tsfile genarated when all datatypes in one insert mismatching (#11456)
add f7b26846a0a Add Metric Prometheus Reporter IT (#11443)
add 0b8faac5f75 PBTree: Logging Disabled with Ratis and Pre-Allocation Disabled for devices using template (#11467)
add f594958f0da Feat/configurable home directory (#11492)
add ed3817eaac3 fix: Increase the timeout even more to finally make the build succeed.
add 9077f03e1a4 Fix NPE in SchemaStatisticsTest (#11490)
add 4b0fc1d7ec6 [IOTDB-6239] Show regions display error create time (#11481)
add b478d96ad21 Fix datanode stuck when meets disk error (#11486)
add 16eee23443b Simplify library-udf packaging result
add 058c5f6eab6 [IOTDB-6241] Load: Check System READ_ONLY mode in Analysis, Dispatch and Writing Stage (#11488)
add 3e1feac4d9e [IOTDB-1476]IoTDB support IPv6 (#11457)
add 8f3729fb825 Update ReadMe in IT module (#11499)
add 31d0c5bc1e8 Pipe: Added check in PipeSubtask submit logic to ensure one PipeConnectorSubtask instance is running in only one thread (#11474)
add a4510266fdb [IOTDB-6206] Metric Core: Shrink ringBuffer length to optimize histogram and timer's record performance (#11500)
add 1f518743f9f Fix aggregation error when inserting negative timestamp
add 05a608f8ea1 Pipe: Make each connector subtask inject cron event at fix rate to avoid random time of batch transmission (#11501)
add 1ea88fa2030 [IOTDB-6238] Fix delete timeSeries / deactivate template procedure rollback logic (#11479)
add 45c2fdf5535 Pipe: introduce pipe_max_allowed_pinned_memtable_count param for realtime hybrid mode (#11505)
add e094b3649f5 add time cost for datanode start (#11498)
add 33a3d73ed34 Pipe IT: adjust -DintegrationTest.forkCount & -DDataNodeMaxHeapSize in pipe-it-2cluster.yml to provide more stable env (#11504)
add bbc57ec98ff Check empty target file after sequence InnerSpaceCompactionTask (#11454)
add bb79cf16592 Add compaction logs and metrics (#11448)
add 98c4aa324ec Pipe: skip pipe CN heartbeat and sync when `PipeTaskCoordinatorLock` is held by another thread (#11509)
add d3548ed2acd [IOTDB-6209] Pipe: Solving the topological order of the progress index in the historical data collection phase (#11478)
add 8901076ec17 [IOTDB-6227] Add retry for RatisConsensus read (#11458)
add 58d3a129113 Fix exception add database name message (#11507)
add 47bc342f407 [IOTDB-6245] Load: Adjust forceCloseWriterManager execution delay in LoadTsFileManager to 15mins to avoid OOM & clear all data structures after use to help GC (#11506)
add 4eb2015166b [IOTDB-6186] Grafana does not support group by time and level (#11338)
add 872482ce8b9 fix(conf): add e.g. for ssl (#11512)
add 93295a1cf8e Check and update searchIndex when restarting dataNode if necessary (#11510)
add 369041f3672 Optimize batch fetch schema for data insertion
add aa9f7f1f424 Pipe: collect total memory size with pipe module instead of memory usage (#11513)
add c86cb0e76c6 [IOTDB-6246] Pipe: Validator validates the range of values for optional parameters improperly (#11520)
add 27d219d07b4 remove duplicate description of metric (#11519)
add bbc053fbc4b Pipe: Added concurrency check to avoid WALEntryHandler#getInsertNode returning null to fix potential NPE (#11523)
add acbf2057ad8 Add logs in compaction recovery (#11433)
add 918ee105303 [IOTDB-6247] Remove redundant error log when restarting simple consensus ConfigNode (#11529)
add 726c4733910 [IOTDB-6239] Revert updation of CreateRegionGroupsPlan (#11528)
add 3a4c085afee Add OFF level (#11530)
add f7b899b1e05 fix insertion compaction replace keyword bug (#11514)
add ebca20e5d83 Validate flushed tsfile without holding closeQueryLock (#11508)
add 29c9186525d Pipe: Enable dynamic adjusting of allocated pipe memory (#11518)
add 070a514f141 Pipe IT: Enable Pipe IT to tolerate failures caused by resource shortage (#11527)
add 3eb76822ca0 Support high available while meeting timeout exception
add 6bb3d93be13 Pipe IT: Fix WALFlushListener.testConcurrentGetValue() & Fix smells reported by sonar (#11525)
add 723b5718f3b Bump go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc (#11517)
add 180e5f1fe73 Implement more fine-grained time slice control for the AggregationScanOperator (#11521)
add 31ad3ffc825 Pipe IT: Enable IoTDBPipeExtractorIT & IoTDBPipeSwitchStatusIT to tolerate failures caused by resource shortage (#11539)
add 0d88353b824 fix compaction logs and metrics (#11533)
add f11c252809e DataNode & ConfigNode exit directly while meeting OutOfMemoryError
add 71043c1fed6 add nonnull to ProgressIndex's topological sort (#11542)
add f1fc5b1de10 return WRITE_PROCESS_ERROR when catching BatchProcessException in writing process (#11543)
add 6730cb106d9 add file validate when rename file, avoid rename error because file is not exist (#11536)
add 2bfffe6f73a Fix insertRecordsOfOneDevice causes data out of order (#11535)
add 36bb554e756 Pipe: Make the pipe to detect illegal parameters when there is no data (#11541)
add de96005b9bd Fix aligned series modification not matched in MultiTsFileDeviceIterator (#11544)
add fbbb0200d2b Increase retry timeout for ratis retry mechanism (#11548)
add 93cc6aa56ec Refactor CachedMTreeStore.updateMNode interface usage and implementation in PBTree (#11546)
add b4a1d020ca5 Fix update and recovery of LastFlushTimeMap (#11538)
add f3b3d3979c6 use fast constructor of PartialPath in Compaction (#11547)
add 5c438ac89f9 Skip null value row when counting time (#11459)
add b7a414adcc8 Pipe: ignore the IoTDBPipeClusterIT.testNewDataNodeFailureAfterTransferringData to avoid inevitable IT failure (#11552)
add c8f8086b000 [IOTDB-6243] Support time duration threshold in fill(PREVIOUS) clause (#11550)
add 1dd2f1a3104 [IOTDB-6237] Improve query back-end execution process
add d8b57579a02 ISchemaTree supports template interface (#11545)
add 5daba02e8b1 Bump io.projectreactor.netty:reactor-netty-http from 1.1.11 to 1.1.13 (#11549)
add a2d10d3a9b6 ISchemaTree add interface getDeviceUsingTemplate (#11558)
add 1c8cb48a5ff Fix aligned device modification not matched in MultiTsFileDeviceIterator (#11555)
add 6ae6ed844a4 Extend time slice for DriverTasks in higher level queue and double default EXECUTION_TIME_SLICE
add 013a29a32e3 Change the package name back in common-api
add 117b35cebd6 Complete the log information for Some Procedure (#11554)
add b0c421983a5 Enhance IoTConsensus retry judgement to all writenodes in a batch (#11564)
add 8548f4c3edb Fix UT testLargeFileInLowerLevel timeout (#11568)
add 39548ab550b Pipe: Fixed event forever pinned and retry never invoked when TException encountered in IoTDBThriftAsyncConnector (#11560)
add 5ad07424552 Optimize fetch template schema (#11566)
add 27637120a72 Pipe: skip pipe CN meta sync after successful synchronization when having no pipe (#11532)
add eecbc7c8bdd Merge branch 'master' into native_raft
No new revisions were added by this update.
Summary of changes:
.github/workflows/client-go.yml | 1 +
.github/workflows/client-python.yml | 4 +
.github/workflows/cluster-it-1c1d.yml | 1 +
.github/workflows/cluster-it-1c3d.yml | 1 +
.github/workflows/grafana-plugin.yml | 15 +-
.github/workflows/iotdb-ml.yml | 60 -
.github/workflows/pipe-it-2cluster.yml | 10 +-
.github/workflows/sonar-codecov.yml | 83 +
.github/workflows/sonar-coveralls.yml | 85 -
.github/workflows/unit-test.yml | 1 +
.gitignore | 13 +-
.mvn/extensions.xml | 33 +
.mvn/gradle-enterprise.xml | 48 +
Jenkinsfile | 8 +-
LICENSE | 21 +-
NOTICE | 2 +-
NOTICE-binary | 2 +-
README.md | 6 +-
README_ZH.md | 2 +-
checkstyle.xml | 4 +-
code-coverage/pom.xml | 76 +-
codecov.yml | 6 +-
distribution/pom.xml | 170 +-
distribution/src/assembly/flink-sql-connector.xml | 41 +
distribution/src/assembly/library-udf.xml | 23 +-
.../DockerCompose/docker-compose-cluster-1c2d.yml | 6 +-
.../DockerCompose/docker-compose-host-3c3d.yml | 4 +-
.../DockerCompose/docker-compose-standalone.yml | 4 +-
docker/src/main/Dockerfile-1c1d | 4 +-
example/client-cpp-example/pom.xml | 31 +-
example/flink-sql/pom.xml | 99 +
.../org/apache/iotdb/example/BatchSinkExample.java | 74 +
.../apache/iotdb/example/BoundedScanExample.java | 52 +
.../java/org/apache/iotdb/example/CDCExample.java | 54 +
.../org/apache/iotdb/example/LookupExample.java | 77 +
.../apache/iotdb/example/StreamingSinkExample.java | 68 +
example/flink/pom.xml | 24 +-
example/hadoop/pom.xml | 4 +-
example/jdbc/pom.xml | 6 +-
example/kafka/pom.xml | 2 +-
example/mqtt-customize/pom.xml | 2 +-
....apache.iotdb.db.protocol.mqtt.PayloadFormatter | 19 +
example/mqtt/pom.xml | 2 +-
example/pipe-count-point-processor/pom.xml | 66 +
.../java/org/apache/iotdb/CountPointProcessor.java | 82 +
example/pipe-opc-ua-sink/pom.xml | 42 +
.../java/org/apache/iotdb/opcua/ClientExample.java | 50 +
.../apache/iotdb/opcua/ClientExampleRunner.java | 144 ++
.../java/org/apache/iotdb/opcua/ClientTest.java | 129 +
.../iotdb/opcua/IoTDBKeyStoreLoaderClient.java | 128 +
example/pom.xml | 67 +-
example/pulsar/pom.xml | 4 +-
example/rabbitmq/pom.xml | 2 +-
example/rest-java-example/pom.xml | 13 +-
example/rocketmq/pom.xml | 4 +-
example/schema/pom.xml | 44 +
.../org/apache/iotdb/schema/PathCheckExample.java | 138 ++
example/session/pom.xml | 10 +-
.../main/java/org/apache/iotdb/SessionExample.java | 3 +-
.../main/java/org/apache/iotdb/TabletExample.java | 4 +-
example/trigger/pom.xml | 14 +-
example/tsfile/pom.xml | 2 +-
.../iotdb/tsfile/TsFileWriteAlignedWithTablet.java | 3 +-
.../apache/iotdb/tsfile/TsFileWriteWithTablet.java | 3 +-
example/udf/pom.xml | 8 +-
integration-test/README.md | 24 +-
integration-test/checkstyle.xml | 4 +-
integration-test/import-control.xml | 194 +-
integration-test/pom.xml | 465 ++--
.../apache/iotdb/db/query/udf/example/TwoSum.java | 64 +
.../iotdb/db/query/udf/example/TwoSumBlock.java | 107 +
.../iotdb/it/env/cluster/ClusterConstant.java | 2 +
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 5 +-
.../it/env/cluster/config/MppCommonConfig.java | 53 +-
.../it/env/cluster/config/MppConfigNodeConfig.java | 7 +
.../it/env/cluster/config/MppDataNodeConfig.java | 7 +
.../env/cluster/config/MppSharedCommonConfig.java | 58 +-
.../iotdb/it/env/cluster/env/AbstractEnv.java | 147 +-
.../iotdb/it/env/cluster/env/Cluster1Env.java | 6 +
.../iotdb/it/env/cluster/env/MultiClusterEnv.java | 6 +
.../apache/iotdb/it/env/cluster/env/SimpleEnv.java | 6 +
.../it/env/cluster/node/AbstractNodeWrapper.java | 25 +-
.../it/env/cluster/node/ConfigNodeWrapper.java | 16 +-
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 18 +-
.../it/env/remote/config/RemoteCommonConfig.java | 34 +-
.../env/remote/config/RemoteConfigNodeConfig.java | 9 +-
.../it/env/remote/config/RemoteDataNodeConfig.java | 9 +-
.../iotdb/it/env/remote/env/RemoteServerEnv.java | 37 +-
.../iotdb/it/framework/IoTDBTestConstants.java | 27 +
.../iotdb/it/framework/IoTDBTestListener.java | 66 -
.../iotdb/it/framework/IoTDBTestReporter.java | 4 +-
.../apache/iotdb/it/framework/IoTDBTestStat.java | 4 +-
.../org/apache/iotdb/it/utils/TsFileGenerator.java | 4 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 51 +
.../apache/iotdb/itbase/env/BaseNodeWrapper.java | 2 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 16 +-
.../apache/iotdb/itbase/env/ConfigNodeConfig.java | 6 +-
.../apache/iotdb/itbase/env/DataNodeConfig.java | 6 +-
.../apache/iotdb/cli/it/StartClientScriptIT.java | 43 +-
.../confignode/it/IoTDBClusterAuthorityIT.java | 496 ----
.../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 27 -
.../it/cluster/IoTDBClusterRestartIT.java | 35 +-
.../it/database/IoTDBDatabaseSetAndDeleteIT.java | 23 +-
.../it/partition/IoTDBPartitionGetterIT.java | 8 +-
.../confignode/it/utils/ConfigNodeTestUtils.java | 7 -
.../org/apache/iotdb/db/it/IOTDBLoadTsFileIT.java | 110 +-
.../java/org/apache/iotdb/db/it/IoTDBAuthIT.java | 835 -------
.../apache/iotdb/db/it/IoTDBDatetimeFormatIT.java | 1 +
.../apache/iotdb/db/it/IoTDBInsertMultiRowIT.java | 32 +
.../apache/iotdb/db/it/IoTDBInsertWithQueryIT.java | 46 +-
.../iotdb/db/it/IoTDBPartialInsertionIT.java | 71 +
.../db/it/IoTDBSyntaxConventionIdentifierIT.java | 14 +-
.../aggregation/IoTDBCountTimeAlignedDeviceIT.java | 58 +
.../IoTDBOrderByLimitOffsetAlignByDeviceIT.java | 102 +
.../IoTDBOrderByWithAlignByDeviceIT.java | 290 ++-
.../db/it/aligned/IoTDBAlignedSeriesQuery5IT.java | 56 +
.../db/it/aligned/IoTDBGroupByLevelQueryIT.java | 12 +-
.../db/it/aligned/IoTDBInsertAlignedValues2IT.java | 42 +
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 1118 +++++++++
.../iotdb/db/it/auth/IoTDBClusterAuthorityIT.java | 538 ++++
.../iotdb/db/it/auth/IoTDBSeriesPermissionIT.java | 305 +++
.../iotdb/db/it/auth/IoTDBSystemPermissionIT.java | 332 +++
.../db/it/auth/IoTDBTemplatePermissionIT.java | 161 ++
.../java/org/apache/iotdb/db/it/cq/IoTDBCQIT.java | 88 -
.../db/it/fill/IoTDBFillWithThresholdInMSIT.java | 276 +++
.../db/it/fill/IoTDBFillWithThresholdInNSIT.java | 242 ++
.../db/it/fill/IoTDBFillWithThresholdInUSIT.java | 242 ++
.../db/it/groupby/IoTDBGroupByNaturalMonthIT.java | 208 +-
.../IoTDBGroupByNaturalMonthNsPrecisionIT.java | 107 +
.../IoTDBGroupByNaturalMonthUsPrecisionIT.java | 92 +
.../apache/iotdb/db/it/metric/IoTDBMetricIT.java | 68 +
.../db/it/schema/IoTDBClusterDeviceQuotaIT.java | 44 -
.../it/schema/IoTDBClusterMeasurementQuotaIT.java | 126 -
.../db/it/schema/IoTDBDeactivateTemplateIT.java | 56 +-
.../db/it/schema/IoTDBDeleteTimeSeriesIT.java | 4 +-
.../iotdb/db/it/schema/IoTDBExtendTemplateIT.java | 26 +-
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 8 +-
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 263 +-
.../it/schema/quota/IoTDBClusterDeviceQuotaIT.java | 43 +
.../db/it/schema/quota/IoTDBClusterMixQuotaIT.java | 109 +
.../db/it/schema/quota/IoTDBClusterQuotaIT.java | 111 +
.../quota/IoTDBClusterTimeSeriesQuotaIT.java | 44 +
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 19 +-
.../db/it/strangepath/IoTDBStrangePathIT.java | 78 +
.../db/it/trigger/IoTDBTriggerManagementIT.java | 117 +-
.../iotdb/db/it/udf/IoTDBUDFBlockQueryIT.java | 155 ++
.../iotdb/db/it/udf/IoTDBUDFWindowQueryIT.java | 17 +-
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 159 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 303 ++-
.../db/it/withoutNull/IoTDBWithoutAllNullIT.java | 4 +-
.../org/apache/iotdb/flink/it/AbstractTest.java | 46 +
.../java/org/apache/iotdb/flink/it/SinkTest.java | 163 ++
.../java/org/apache/iotdb/flink/it/SourceTest.java | 192 ++
.../test/java/org/apache/iotdb/flink/it/Utils.java | 93 +
.../iotdb/it/framework/IoTDBTestListener.java | 65 +
.../apache/iotdb/it/framework/IoTDBTestRunner.java | 0
.../framework/IoTDBTestRunnerWithParameters.java | 0
.../IoTDBTestRunnerWithParametersFactory.java | 0
.../apache/iotdb/libudf/it/anomaly/AnomalyIT.java | 121 +-
.../iotdb/libudf/it/dprofile/DProfileIT.java | 12 +-
.../iotdb/libudf/it/dquality/DQualityIT.java | 2 +
.../apache/iotdb/libudf/it/drepair/DRepairIT.java | 2 +
.../iotdb/libudf/it/frequency/FrequencyIT.java | 2 +
.../apache/iotdb/pipe/it/IoTDBPipeClusterIT.java | 822 +++++++
.../pipe/it/IoTDBPipeConnectorParallelIT.java | 149 ++
.../apache/iotdb/pipe/it/IoTDBPipeDataSyncIT.java | 76 +-
.../apache/iotdb/pipe/it/IoTDBPipeLifeCycleIT.java | 713 ++++++
.../apache/iotdb/pipe/it/IoTDBPipeProtocolIT.java | 431 ++++
.../iotdb/pipe/it/IoTDBPipeSwitchStatusIT.java | 332 +++
.../apache/iotdb/pipe/it/IoTDBPipeSyntaxIT.java | 658 +++++
.../pipe/it/extractor/IoTDBPipeExtractorIT.java | 700 ++++++
.../iotdb/session/it/IoTDBSessionComplexIT.java | 163 ++
.../it/IoTDBSessionDisableMemControlIT.java | 5 +-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 106 +-
.../session/it/IoTDBSessionSyntaxConventionIT.java | 3 +-
.../org/apache/iotdb/session/it/SessionIT.java | 3 +-
.../org/apache/iotdb/tools/ExportCsvTestIT.java | 4 +-
.../org/apache/iotdb/tools/ExportTsFileTestIT.java | 4 +-
.../org/apache/iotdb/util/AbstractSchemaIT.java | 4 +-
.../iotdb/zeppelin/it/IoTDBInterpreterIT.java | 5 +-
iotdb-api/common-api/pom.xml | 66 +
.../write/UnSupportedDataTypeException.java | 31 +
.../tsfile/file/metadata/enums/TSDataType.java | 193 ++
.../read/common/block/TsBlockBuilderStatus.java | 70 +
.../tsfile/read/common/block/column/Column.java | 0
.../read/common/block/column/ColumnBuilder.java | 0
.../common/block/column/ColumnBuilderStatus.java | 0
.../read/common/block/column/ColumnEncoding.java | 0
.../java/org/apache/iotdb/tsfile/utils/Binary.java | 122 +
.../apache/iotdb/tsfile/utils/TsPrimitiveType.java | 0
iotdb-api/external-api/pom.xml | 12 +-
iotdb-api/pipe-api/pom.xml | 12 +-
.../org/apache/iotdb/pipe/api/PipeConnector.java | 13 +-
.../org/apache/iotdb/pipe/api/PipeExtractor.java | 3 +-
.../org/apache/iotdb/pipe/api/PipeProcessor.java | 10 +-
.../java/org/apache/iotdb/pipe/api/PipeSink.java | 146 ++
.../java/org/apache/iotdb/pipe/api/PipeSource.java | 99 +
.../PipeSinkRuntimeConfiguration.java | 22 +
.../PipeSourceRuntimeConfiguration.java | 22 +
.../parameter/PipeParameterValidator.java | 6 +-
.../api/customizer/parameter/PipeParameters.java | 130 +
.../event/dml/insertion/TsFileInsertionEvent.java | 2 +-
.../pipe/api/exception/PipeSinkException.java | 31 +
iotdb-api/pom.xml | 3 +-
iotdb-api/trigger-api/pom.xml | 18 +-
iotdb-api/udf-api/pom.xml | 17 +-
.../main/java/org/apache/iotdb/udf/api/UDTF.java | 46 +
.../org/apache/iotdb/udf/api/utils/RowImpl.java | 124 +
iotdb-client/cli/pom.xml | 187 +-
.../cli/src/assembly/resources/sbin/start-cli.bat | 40 +-
.../cli/src/assembly/resources/sbin/start-cli.sh | 24 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 98 +-
.../src/main/java/org/apache/iotdb/cli/Cli.java | 27 +-
.../java/org/apache/iotdb/tool/ExportTsFile.java | 14 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 86 +-
.../java/org/apache/iotdb/cli/AbstractCliIT.java | 39 -
.../iotdb/tool/integration/ExportCsvTestIT.java | 2 +-
.../iotdb/tool/integration/ImportCsvTestIT.java | 2 +-
iotdb-client/client-cpp/pom.xml | 70 +-
iotdb-client/client-cpp/src/main/Session.cpp | 2 +-
iotdb-client/client-py/.gitignore | 2 +
iotdb-client/client-py/README.md | 24 +-
iotdb-client/client-py/SessionPoolExample.py | 21 +-
iotdb-client/client-py/iotdb/IoTDBContainer.py | 9 +-
iotdb-client/client-py/iotdb/Session.py | 127 +-
iotdb-client/client-py/iotdb/SessionPool.py | 60 +-
.../client-py/iotdb/template/TemplateNode.py | 2 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.py | 12 +-
iotdb-client/client-py/iotdb/utils/Field.py | 148 +-
.../client-py/iotdb/utils/IoTDBConstants.py | 33 +-
.../client-py/iotdb/utils/IoTDBRpcDataSet.py | 299 ++-
iotdb-client/client-py/iotdb/utils/NumpyTablet.py | 8 +-
.../client-py/iotdb/utils/SessionDataSet.py | 90 +-
iotdb-client/client-py/iotdb/utils/Tablet.py | 14 +-
iotdb-client/client-py/pom.xml | 103 +-
iotdb-client/client-py/release.sh | 19 +-
iotdb-client/client-py/requirements_dev.txt | 2 +-
iotdb-client/client-py/resources/setup.py | 65 +
iotdb-client/client-py/setup.py | 65 -
iotdb-client/client-py/tests/test_session.py | 60 +-
iotdb-client/client-py/tests/test_session_pool.py | 33 +-
iotdb-client/client-py/tests/test_tablet.py | 18 +-
iotdb-client/client-py/tests/test_template.py | 4 +-
iotdb-client/isession/pom.xml | 28 +-
.../org/apache/iotdb/isession/SessionDataSet.java | 9 +
iotdb-client/jdbc/pom.xml | 139 +-
.../main/java/org/apache/iotdb/jdbc/Config.java | 8 +
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 17 +-
.../apache/iotdb/jdbc/IoTDBConnectionParams.java | 28 +
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 4 +-
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 3 +-
.../src/main/java/org/apache/iotdb/jdbc/Utils.java | 42 +-
.../test/java/org/apache/iotdb/jdbc/BatchTest.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 2 +-
.../iotdb/jdbc/IoTDBDatabaseMetadataTest.java | 2 +-
.../apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java | 2 +-
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBStatementTest.java | 2 +-
.../test/java/org/apache/iotdb/jdbc/UtilsTest.java | 25 +
iotdb-client/pom.xml | 2 +-
iotdb-client/service-rpc/pom.xml | 113 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 6 +-
.../org/apache/iotdb/rpc/RpcTransportFactory.java | 36 +
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 29 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 19 +-
.../main/java/org/apache/iotdb/rpc/UrlUtils.java | 52 +
.../java/org/apache/iotdb/rpc/RpcUtilsTest.java | 67 +
.../java/org/apache/iotdb/rpc/UrlUtilsTest.java | 61 +
iotdb-client/session/pom.xml | 114 +-
.../java/org/apache/iotdb/session/Session.java | 77 +-
.../apache/iotdb/session/SessionConnection.java | 27 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 138 +-
.../apache/iotdb/session/util/SessionUtils.java | 3 +-
.../iotdb/session/SessionConnectionTest.java | 388 +++
.../java/org/apache/iotdb/session/SessionTest.java | 1183 +++++++++
.../session/pool/SessionPoolExceptionTest.java | 266 ++
.../apache/iotdb/session/pool/SessionPoolTest.java | 1264 +++++++++-
.../iotdb/session/util/SessionUtilsTest.java | 176 ++
iotdb-connector/flink-iotdb-connector/pom.xml | 42 +-
.../iotdb/flink/IoTDBSinkBatchInsertTest.java | 2 +-
.../iotdb/flink/IoTDBSinkBatchTimerTest.java | 2 +-
.../apache/iotdb/flink/IoTDBSinkInsertTest.java | 2 +-
iotdb-connector/flink-sql-iotdb-connector/pom.xml | 124 +
.../flink/sql/client/IoTDBWebSocketClient.java | 75 +
.../org/apache/iotdb/flink/sql/common/Options.java | 57 +
.../org/apache/iotdb/flink/sql/common/Utils.java | 177 ++
.../sql/exception/IllegalIoTDBPathException.java | 25 +
.../sql/exception/IllegalOptionException.java | 25 +
.../sql/exception/IllegalSchemaException.java | 25 +
.../sql/exception/IllegalUrlPathException.java | 25 +
.../exception/UnsupportedDataTypeException.java | 25 +
.../sql/factory/IoTDBDynamicTableFactory.java | 221 ++
.../sql/function/IoTDBBoundedScanFunction.java | 167 ++
.../flink/sql/function/IoTDBCDCSourceFunction.java | 281 +++
.../flink/sql/function/IoTDBLookupFunction.java | 149 ++
.../flink/sql/function/IoTDBSinkFunction.java | 143 ++
.../flink/sql/provider/IoTDBDynamicTableSink.java | 64 +
.../sql/provider/IoTDBDynamicTableSource.java | 76 +
.../iotdb/flink/sql/wrapper/SchemaWrapper.java | 46 +
.../iotdb/flink/sql/wrapper/TabletWrapper.java | 46 +
.../org.apache.flink.table.factories.Factory | 20 +
iotdb-connector/flink-tsfile-connector/pom.xml | 119 +-
.../iotdb/flink/tsfile/RowTSRecordConverter.java | 6 +-
.../src/test/resources/log4j.properties | 28 +
iotdb-connector/grafana-connector/pom.xml | 160 +-
.../iotdb/web/grafana/conf/MyConfiguration.java | 15 +-
.../web/grafana/interceptor/LoginInterceptor.java | 14 +-
iotdb-connector/grafana-plugin/backend-compile.sh | 4 +-
iotdb-connector/grafana-plugin/go.mod | 85 +-
.../grafana-plugin/pkg/plugin/plugin.go | 6 +-
iotdb-connector/grafana-plugin/pom.xml | 15 +-
iotdb-connector/grafana-plugin/yarn.lock | 149 +-
iotdb-connector/hadoop/pom.xml | 116 +-
.../apache/iotdb/hadoop/fileSystem/HDFSOutput.java | 5 +
.../iotdb/hadoop/tsfile/TSFRecordReader.java | 4 +-
iotdb-connector/hive-connector/pom.xml | 188 +-
iotdb-connector/pom.xml | 18 +-
iotdb-connector/spark-iotdb-connector/pom.xml | 106 +-
.../spark-iotdb-connector/scala_2.11/pom.xml | 7 +-
.../spark-iotdb-connector/scala_2.12/pom.xml | 9 +-
.../org/apache/iotdb/spark/db/DataFrameTools.scala | 2 +-
iotdb-connector/spark-tsfile/pom.xml | 95 +-
.../org/apache/iotdb/spark/tsfile/Converter.scala | 3 +-
.../apache/iotdb/spark/tsfile/WideConverter.scala | 3 +-
.../apache/iotdb/spark/tsfile/ConverterTest.scala | 5 +-
iotdb-connector/zeppelin-interpreter/pom.xml | 54 +-
iotdb-core/antlr/pom.xml | 24 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 12 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 106 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 61 +-
iotdb-core/confignode/pom.xml | 179 +-
.../src/assembly/resources/conf/confignode-env.bat | 105 +-
.../src/assembly/resources/conf/confignode-env.sh | 126 +-
.../resources/conf/iotdb-confignode.properties | 18 +-
.../confignode/client/DataNodeRequestType.java | 3 -
.../async/AsyncConfigNodeHeartbeatClientPool.java | 7 +-
.../client/async/AsyncDataNodeClientPool.java | 45 +-
.../heartbeat/ConfigNodeHeartbeatHandler.java | 27 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 39 +-
.../client/sync/SyncConfigNodeClientPool.java | 3 -
.../client/sync/SyncDataNodeClientPool.java | 3 -
.../iotdb/confignode/conf/ConfigNodeConfig.java | 85 +-
.../confignode/conf/ConfigNodeDescriptor.java | 118 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 10 +-
.../confignode/conf/SystemPropertiesUtils.java | 19 +-
.../consensus/request/ConfigPhysicalPlan.java | 41 +-
.../consensus/request/ConfigPhysicalPlanType.java | 65 +-
.../consensus/request/auth/AuthorPlan.java | 19 +
.../request/read/database/CountDatabasePlan.java | 15 +-
.../request/read/database/GetDatabasePlan.java | 5 +-
.../request/read/model/ShowModelPlan.java | 89 -
.../request/read/model/ShowTrailPlan.java | 97 -
.../read/partition/GetNodePathsPartitionPlan.java | 12 +
.../read/template/GetPathsSetTemplatePlan.java | 11 +-
.../request/write/model/CreateModelPlan.java | 78 -
.../request/write/model/DropModelPlan.java | 81 -
.../request/write/model/UpdateModelInfoPlan.java | 98 -
.../request/write/model/UpdateModelStatePlan.java | 105 -
.../write/region/CreateRegionGroupsPlan.java | 35 +-
.../consensus/response/ModelTableResp.java | 55 -
.../consensus/response/TrailTableResp.java | 55 -
.../response/auth/PermissionInfoResp.java | 40 +-
.../statemachine/ConfigRegionStateMachine.java | 68 +-
.../iotdb/confignode/manager/ConfigManager.java | 217 +-
.../apache/iotdb/confignode/manager/IManager.java | 53 +-
.../iotdb/confignode/manager/ModelManager.java | 149 --
.../confignode/manager/PermissionManager.java | 56 +-
.../iotdb/confignode/manager/ProcedureManager.java | 75 +-
.../manager/consensus/ConsensusManager.java | 50 +-
.../iotdb/confignode/manager/cq/CQManager.java | 9 -
.../manager/load/balancer/RegionBalancer.java | 2 +-
.../manager/load/balancer/RouteBalancer.java | 2 +-
.../confignode/manager/load/cache/LoadCache.java | 8 +-
.../load/cache/node/NodeHeartbeatSample.java | 8 +
.../manager/load/service/HeartbeatService.java | 33 +-
.../manager/node/ClusterNodeStartUtils.java | 4 +-
.../iotdb/confignode/manager/node/NodeManager.java | 26 +-
.../manager/partition/PartitionManager.java | 5 +-
.../manager/partition/PartitionMetrics.java | 250 +-
.../manager/pipe/runtime/PipeHeartbeatParser.java | 27 +-
.../pipe/runtime/PipeHeartbeatScheduler.java | 14 +-
.../manager/pipe/runtime/PipeMetaSyncer.java | 70 +-
.../manager/pipe/task/PipeTaskCoordinator.java | 51 +-
.../manager/pipe/task/PipeTaskCoordinatorLock.java | 107 +
.../manager/schema/ClusterSchemaManager.java | 63 +-
.../schema/ClusterSchemaQuotaStatistics.java | 73 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 419 +++-
.../iotdb/confignode/persistence/ModelInfo.java | 224 --
.../iotdb/confignode/persistence/TriggerInfo.java | 2 +
.../iotdb/confignode/persistence/UDFInfo.java | 3 +
.../iotdb/confignode/persistence/cq/CQInfo.java | 1 +
.../persistence/executor/ConfigPlanExecutor.java | 44 +-
.../confignode/persistence/node/NodeInfo.java | 7 +-
.../partition/DatabasePartitionTable.java | 4 +-
.../persistence/partition/PartitionInfo.java | 33 +-
.../persistence/pipe/PipePluginInfo.java | 10 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 50 +-
.../confignode/persistence/quota/QuotaInfo.java | 1 +
.../persistence/schema/ClusterSchemaInfo.java | 36 +-
.../confignode/persistence/schema/ConfigMTree.java | 41 +-
.../persistence/schema/ConfigMTreeStore.java | 3 +-
.../persistence/schema/TemplatePreSetTable.java | 18 +-
.../persistence/schema/TemplateTable.java | 19 +-
.../schema/mnode/factory/ConfigMNodeFactory.java | 3 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 23 +-
.../procedure/env/DataNodeRemoveHandler.java | 2 +-
.../procedure/impl/model/CreateModelProcedure.java | 228 --
.../procedure/impl/model/DropModelProcedure.java | 220 --
.../impl/node/AddConfigNodeProcedure.java | 9 +
.../impl/node/RemoveConfigNodeProcedure.java | 3 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 174 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 2 +-
.../impl/schema/AlterLogicalViewProcedure.java | 6 +-
.../impl/schema/DeactivateTemplateProcedure.java | 42 +-
.../impl/schema/DeleteDatabaseProcedure.java | 8 +-
.../impl/schema/DeleteLogicalViewProcedure.java | 6 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 44 +-
.../impl/schema/SetTemplateProcedure.java | 6 +-
.../impl/schema/UnsetTemplateProcedure.java | 9 +-
.../statemachine/CreateRegionGroupsProcedure.java | 10 +-
.../impl/sync/AuthOperationProcedure.java | 235 ++
.../impl/trigger/CreateTriggerProcedure.java | 4 +-
.../impl/trigger/DropTriggerProcedure.java | 2 +-
.../state/auth/AuthOperationProcedureState.java | 25 +
.../procedure/state/model/CreateModelState.java | 27 -
.../procedure/state/model/DropModelState.java | 28 -
.../procedure/store/ProcedureFactory.java | 16 +-
.../confignode/procedure/store/ProcedureType.java | 9 +-
.../confignode/procedure/store/ProcedureWAL.java | 3 +
.../iotdb/confignode/service/ConfigNode.java | 87 +-
.../confignode/service/ConfigNodeCommandLine.java | 8 +-
.../confignode/service/ConfigNodeShutdownHook.java | 12 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 120 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 79 +-
.../consensus/response/pipe/PipeTableRespTest.java | 6 +-
.../confignode/persistence/AuthorInfoTest.java | 745 ++++--
.../iotdb/confignode/persistence/NodeInfoTest.java | 2 +-
.../confignode/persistence/PartitionInfoTest.java | 2 +-
.../iotdb/confignode/persistence/PipeInfoTest.java | 9 +-
.../persistence/schema/ClusterSchemaInfoTest.java | 6 +-
.../persistence/schema/ConfigMTreeTest.java | 44 +-
.../impl/CreateRegionGroupsProcedureTest.java | 1 +
.../impl/sync/AuthOperationProcedureTest.java | 98 +
.../confignode1conf/iotdb-confignode.properties | 3 +-
.../confignode2conf/iotdb-confignode.properties | 3 +-
.../confignode3conf/iotdb-confignode.properties | 3 +-
iotdb-core/consensus/pom.xml | 152 +-
.../org/apache/iotdb/consensus/IStateMachine.java | 37 +-
.../apache/iotdb/consensus/config/RatisConfig.java | 109 +-
.../consensus/iot/IoTConsensusServerImpl.java | 85 +-
.../consensus/iot/IoTConsensusServerMetrics.java | 154 +-
.../iot/client/AsyncIoTConsensusServiceClient.java | 6 +-
.../consensus/iot/client/DispatchLogHandler.java | 23 +-
.../iot/client/IoTConsensusClientPool.java | 11 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 3 +-
.../logdispatcher/LogDispatcherThreadMetrics.java | 50 +-
.../service/IoTConsensusRPCServiceProcessor.java | 3 +
.../ratis/ApplicationStateMachineProxy.java | 65 +-
.../apache/iotdb/consensus/ratis/DiskGuardian.java | 252 ++
.../iotdb/consensus/ratis/RatisConsensus.java | 162 +-
.../consensus/ratis/metrics/CounterProxy.java | 2 +-
.../ratis/metrics/IoTDBMetricRegistry.java | 2 +-
.../consensus/ratis/utils/RatisLogMonitor.java | 88 -
.../iotdb/consensus/ratis/utils/Retriable.java | 107 +
.../iotdb/consensus/ratis/utils/RetryPolicy.java | 79 +
.../apache/iotdb/consensus/ratis/utils/Utils.java | 39 +
.../simple/SimpleConsensusServerImpl.java | 1 +
.../apache/iotdb/consensus/iot/ReplicateTest.java | 129 +-
.../iotdb/consensus/ratis/DiskGuardianTest.java | 120 +
.../iotdb/consensus/ratis/RatisConsensusTest.java | 4 +-
.../iotdb/consensus/ratis/RecoverReadTest.java | 3 +-
.../apache/iotdb/consensus/ratis/TestUtils.java | 7 +-
.../apache/iotdb/consensus/ratis/UtilsTest.java | 39 -
.../iotdb/consensus/ratis/utils/UtilsTest.java | 67 +
iotdb-core/datanode/pom.xml | 581 +++--
.../src/assembly/resources/conf/datanode-env.bat | 102 +-
.../src/assembly/resources/conf/datanode-env.sh | 118 +-
.../resources/conf/iotdb-datanode.properties | 86 +-
.../assembly/resources/conf/logback-datanode.xml | 40 +-
.../check-overlap-sequence-files-and-repair.bat | 62 +
.../check-overlap-sequence-files-and-repair.sh | 51 +
.../tools/tsfile/overlap-statistic-tool.bat | 62 +
.../tools/tsfile/overlap-statistic-tool.sh | 51 +
.../src/main/codegen/templates/constantFill.ftl | 3 +-
.../src/main/codegen/templates/previousFill.ftl | 56 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 18 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 394 +--
.../apache/iotdb/db/auth/AuthorizerManager.java | 432 ----
.../apache/iotdb/db/auth/BasicAuthorityCache.java | 12 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 445 +++-
.../org/apache/iotdb/db/auth/IAuthorCache.java | 2 +
.../apache/iotdb/db/auth/IAuthorityFetcher.java | 14 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 194 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 226 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 37 +-
.../iotdb/db/conf/rest/IoTDBRestServiceConfig.java | 2 +-
.../db/consensus/DataRegionConsensusImpl.java | 6 +-
.../db/consensus/SchemaRegionConsensusImpl.java | 10 +-
.../consensus/statemachine/BaseStateMachine.java | 3 +-
.../dataregion/DataExecutionVisitor.java | 6 +-
.../dataregion/DataRegionStateMachine.java | 18 -
.../schemaregion/SchemaExecutionVisitor.java | 2 +-
.../schemaregion/SchemaRegionStateMachine.java | 18 -
.../iotdb/db/exception/IntoProcessException.java | 27 -
.../iotdb/db/exception/LoadReadOnlyException.java | 33 +
.../db/exception/WriteLockFailedException.java | 27 -
.../exception/metadata/PathNotExistException.java | 4 +-
.../metadata/SchemaQuotaExceededException.java | 8 +-
.../metadata/SeriesOverflowException.java | 5 +-
.../template/TemplateIncompatibleException.java | 4 +-
.../db/exception/runtime/IntoProcessException.java | 27 +
.../runtime/WriteLockFailedException.java | 27 +
.../agent/plugin/PipeConnectorConstructor.java | 112 +
.../agent/plugin/PipeExtractorConstructor.java | 58 +
.../db/pipe/agent/plugin/PipePluginAgent.java | 106 +-
.../pipe/agent/plugin/PipePluginConstructor.java | 85 +
.../agent/plugin/PipeProcessorConstructor.java | 52 +
.../db/pipe/agent/receiver/PipeReceiverAgent.java | 14 +-
.../agent/runtime/PipePeriodicalJobExecutor.java | 100 +
.../db/pipe/agent/runtime/PipeRuntimeAgent.java | 21 +-
.../SimpleConsensusProgressIndexAssigner.java | 12 +-
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 91 +-
.../config/constant/PipeConnectorConstant.java | 56 +-
.../config/constant/PipeExtractorConstant.java | 33 +-
.../payload/airgap/AirGapELanguageConstant.java | 34 +
.../payload/airgap/AirGapOneByteResponse.java | 4 +
...oTDBThriftAsyncPipeTransferBatchReqBuilder.java | 9 +-
...IoTDBThriftSyncPipeTransferBatchReqBuilder.java | 5 +-
.../builder/PipeTransferBatchReqBuilder.java | 55 +-
.../request/PipeTransferTabletInsertNodeReq.java | 14 +-
.../request/PipeTransferTabletRawReq.java | 12 +
.../db/pipe/connector/protocol/IoTDBConnector.java | 68 +-
.../protocol/airgap/IoTDBAirGapConnector.java | 90 +-
.../protocol/legacy/IoTDBLegacyPipeConnector.java | 130 +-
.../connector/protocol/opcua/OpcUaConnector.java | 308 +++
.../protocol/opcua/OpcUaKeyStoreLoader.java | 120 +
.../protocol/opcua/OpcUaServerBuilder.java | 293 +++
.../thrift/async/IoTDBThriftAsyncConnector.java | 175 +-
.../PipeTransferTabletBatchEventHandler.java | 2 +-
.../PipeTransferTabletInsertionEventHandler.java | 2 +-
.../PipeTransferTsFileInsertionEventHandler.java | 5 +-
.../thrift/sync/IoTDBThriftSyncConnector.java | 86 +-
.../sync/IoTDBThriftSyncConnectorClient.java | 29 +-
.../protocol/websocket/WebSocketConnector.java | 194 ++
.../websocket/WebSocketConnectorServer.java | 218 ++
.../protocol/writeback/WriteBackConnector.java | 176 ++
.../apache/iotdb/db/pipe/event/EnrichedEvent.java | 63 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 181 +-
.../event/common/row/PipeDataTypeTransformer.java | 5 +-
.../iotdb/db/pipe/event/common/row/PipeRow.java | 3 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 3 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 10 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 59 +-
.../tsfile/TsFileInsertionDataContainer.java | 15 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 23 +-
.../event/realtime/PipeRealtimeEventFactory.java | 10 +-
.../pipe/extractor/IoTDBDataRegionExtractor.java | 154 +-
.../PipeHistoricalDataRegionExtractor.java | 2 +
.../PipeHistoricalDataRegionTsFileExtractor.java | 226 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 121 +-
.../PipeRealtimeDataRegionFakeExtractor.java | 2 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 236 +-
.../PipeRealtimeDataRegionLogExtractor.java | 88 +-
.../PipeRealtimeDataRegionTsFileExtractor.java | 41 +-
.../realtime/assigner/DisruptorQueue.java | 48 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 26 +-
.../pipe/extractor/realtime/epoch/TsFileEpoch.java | 25 +-
.../realtime/epoch/TsFileEpochManager.java | 14 +-
.../listener/PipeInsertionDataNodeListener.java | 15 +-
.../matcher/CachedSchemaPatternMatcher.java | 6 +-
.../iotdb/db/pipe/metric/PipeAssignerMetrics.java | 165 ++
.../iotdb/db/pipe/metric/PipeConnectorMetrics.java | 309 +++
.../iotdb/db/pipe/metric/PipeEventCounter.java | 79 +
.../iotdb/db/pipe/metric/PipeExtractorMetrics.java | 376 +++
.../db/pipe/metric/PipeHeartbeatEventMetrics.java | 125 +
.../apache/iotdb/db/pipe/metric/PipeMetrics.java | 69 +
.../iotdb/db/pipe/metric/PipeProcessorMetrics.java | 309 +++
.../iotdb/db/pipe/metric/PipeResourceMetrics.java | 101 +
.../pipe/metric/PipeWALInsertNodeCacheMetrics.java | 137 ++
.../pipe/receiver/airgap/IoTDBAirGapReceiver.java | 58 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 1 +
.../receiver/thrift/IoTDBThriftReceiverV1.java | 46 +-
.../db/pipe/resource/PipeResourceManager.java | 7 +
.../db/pipe/resource/memory/PipeMemoryBlock.java | 179 ++
.../db/pipe/resource/memory/PipeMemoryManager.java | 291 +++
.../resource/tsfile/PipeTsFileResourceManager.java | 28 +-
.../db/pipe/resource/wal/PipeWALResource.java | 2 +-
.../pipe/resource/wal/PipeWALResourceManager.java | 11 +
.../apache/iotdb/db/pipe/task/PipeTaskManager.java | 30 +-
.../pipe/task/connection/BlockingPendingQueue.java | 46 +-
.../db/pipe/task/connection/EnrichedDeque.java | 87 +
.../pipe/task/connection/PipeEventCollector.java | 58 +-
.../connection/UnboundedBlockingPendingQueue.java | 12 +-
.../db/pipe/task/stage/PipeTaskExtractorStage.java | 12 +-
.../db/pipe/task/stage/PipeTaskProcessorStage.java | 23 +-
.../iotdb/db/pipe/task/subtask/PipeSubtask.java | 68 +-
.../subtask/connector/PipeConnectorSubtask.java | 174 +-
.../connector/PipeConnectorSubtaskManager.java | 126 +-
.../subtask/processor/PipeProcessorSubtask.java | 114 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 96 +-
.../iotdb/db/protocol/client/ConfigNodeInfo.java | 16 +-
.../db/protocol/client/DataNodeInternalClient.java | 2 +-
.../iotdb/db/protocol/client/MLNodeClient.java | 140 --
.../db/protocol/mqtt/BrokerAuthenticator.java | 14 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 7 +
.../protocol/rest/filter/AuthorizationFilter.java | 47 +-
.../rest/handler/AuthorizationHandler.java | 19 +-
.../db/protocol/rest/impl/PingApiServiceImpl.java | 51 +
.../db/protocol/rest/utils/InsertRowDataUtils.java | 105 +
.../rest/v1/handler/QueryDataSetHandler.java | 5 +-
.../rest/v1/handler/RequestValidationHandler.java | 12 +
.../v1/handler/StatementConstructionHandler.java | 75 +-
.../rest/v1/impl/GrafanaApiServiceImpl.java | 9 +-
.../protocol/rest/v1/impl/RestApiServiceImpl.java | 54 +-
.../rest/v2/handler/QueryDataSetHandler.java | 5 +-
.../rest/v2/handler/RequestValidationHandler.java | 12 +
.../v2/handler/StatementConstructionHandler.java | 77 +-
.../rest/v2/impl/GrafanaApiServiceImpl.java | 9 +-
.../protocol/rest/v2/impl/RestApiServiceImpl.java | 53 +-
.../db/protocol/session/RestClientSession.java | 79 +
.../iotdb/db/protocol/session/SessionManager.java | 4 +-
.../handler/MLNodeRPCServiceThriftHandler.java | 60 -
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 34 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 92 +-
.../thrift/impl/IMLNodeRPCServiceWithHandler.java | 26 -
.../protocol/thrift/impl/MLNodeRPCServiceImpl.java | 209 --
.../db/queryengine/common/MPPQueryContext.java | 13 +
.../common/header/ColumnHeaderConstant.java | 31 +-
.../common/header/DatasetHeaderFactory.java | 8 -
.../common/schematree/ClusterSchemaTree.java | 176 +-
.../common/schematree/DeviceSchemaInfo.java | 36 +-
.../common/schematree/IMeasurementSchemaInfo.java | 4 +
.../queryengine/common/schematree/ISchemaTree.java | 25 +-
.../common/schematree/MeasurementSchemaInfo.java | 12 +-
.../common/schematree/node/SchemaEntityNode.java | 18 +-
.../schematree/node/SchemaMeasurementNode.java | 1 +
.../SchemaTreeDeviceUsingTemplateVisitor.java | 54 +
.../visitor/SchemaTreeDeviceVisitor.java | 17 +-
.../schematree/visitor/SchemaTreeVisitor.java | 65 +-
.../visitor/SchemaTreeVisitorFactory.java | 16 +-
.../SchemaTreeVisitorWithLimitOffsetWrapper.java | 6 +
.../timerangeiterator/AggrWindowIterator.java | 91 +-
.../PreAggrWindowWithNaturalMonthIterator.java | 17 +-
.../SingleTimeWindowIterator.java | 3 +-
.../TimeRangeIteratorFactory.java | 41 +-
.../db/queryengine/execution/driver/Driver.java | 12 +
.../db/queryengine/execution/driver/IDriver.java | 4 +
.../execution/exchange/MPPDataExchangeService.java | 3 +-
.../execution/exchange/SharedTsBlockQueue.java | 9 +
.../execution/exchange/sink/SinkChannel.java | 5 +-
.../execution/executor/RegionWriteExecutor.java | 10 +-
.../fragment/FragmentInstanceManager.java | 5 +
.../execution/fragment/QueryContext.java | 57 +-
.../execution/load/AlignedChunkData.java | 4 +-
.../execution/load/LoadTsFileManager.java | 30 +-
.../execution/load/NonAlignedChunkData.java | 4 +-
.../queryengine/execution/load/TsFileSplitter.java | 32 +-
.../queryengine/execution/memory/MemoryPool.java | 1 +
.../execution/operator/AbstractOperator.java | 3 +
.../execution/operator/AggregationUtil.java | 9 +-
.../process/AbstractConsumeAllOperator.java | 101 +-
.../operator/process/AbstractIntoOperator.java | 7 +-
.../operator/process/DeviceViewIntoOperator.java | 9 +-
.../operator/process/DeviceViewOperator.java | 3 +-
.../execution/operator/process/FillOperator.java | 2 +-
.../execution/operator/process/IntoOperator.java | 7 +-
.../operator/process/MergeSortOperator.java | 61 +-
.../operator/process/SingleDeviceViewOperator.java | 5 +-
.../execution/operator/process/SortOperator.java | 7 +-
.../operator/process/TagAggregationOperator.java | 5 +-
.../execution/operator/process/TopKOperator.java | 364 +++
.../execution/operator/process/fill/IFill.java | 3 +-
.../operator/process/fill/IFillFilter.java | 33 +
.../filter/AbstractMonthIntervalFillFilter.java | 46 +
.../fill/filter/FixedIntervalFillFilter.java | 39 +
.../fill/filter/MonthIntervalMSFillFilter.java | 43 +
.../fill/filter/MonthIntervalNSFillFilter.java | 45 +
.../fill/filter/MonthIntervalUSFillFilter.java | 50 +
.../process/fill/identity/IdentityFill.java | 3 +-
.../process/join/RowBasedTimeJoinOperator.java | 57 +-
.../last/AlignedUpdateLastCacheOperator.java | 6 +-
.../operator/process/last/LastQueryOperator.java | 10 +-
.../process/last/LastQuerySortOperator.java | 8 +-
.../process/last/LastQueryTransformOperator.java | 120 +
.../operator/process/last/LastQueryUtil.java | 11 +-
.../schema/CountGroupByLevelMergeOperator.java | 8 +-
.../schema/CountGroupByLevelScanOperator.java | 10 +-
.../schema/NodeManageMemoryMergeOperator.java | 14 +-
.../operator/schema/NodePathsConvertOperator.java | 5 +-
.../operator/schema/NodePathsCountOperator.java | 5 +-
.../operator/schema/SchemaFetchScanOperator.java | 15 +-
.../schema/SchemaQueryOrderByHeatOperator.java | 5 +-
.../operator/schema/SchemaQueryScanOperator.java | 5 +-
.../operator/schema/SchemaTsBlockUtil.java | 7 +-
.../operator/schema/source/DeviceSchemaSource.java | 28 +-
.../schema/source/LogicalViewSchemaSource.java | 17 +-
.../operator/schema/source/NodeSchemaSource.java | 21 +-
.../schema/source/PathsUsingTemplateSource.java | 13 +-
.../schema/source/SchemaSourceFactory.java | 42 +-
.../schema/source/TimeSeriesSchemaSource.java | 14 +-
.../AbstractSeriesAggregationScanOperator.java | 142 +-
.../operator/source/AlignedSeriesScanOperator.java | 12 +-
.../operator/source/ExchangeOperator.java | 6 +-
.../operator/source/ShowQueriesOperator.java | 12 +-
.../execution/schedule/DriverScheduler.java | 12 +-
.../execution/schedule/DriverTaskThread.java | 35 +-
.../schedule/DriverTaskTimeoutSentinelThread.java | 18 +-
.../execution/schedule/ITaskScheduler.java | 8 +
.../multilevelqueue/MultilevelPriorityQueue.java | 115 +-
.../execution/schedule/task/DriverTask.java | 22 +-
.../timer/RuleBasedTimeSliceAllocator.java | 7 +-
.../db/queryengine/plan/analyze/Analysis.java | 41 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 238 +-
.../db/queryengine/plan/analyze/Analyzer.java | 13 +-
.../plan/analyze/ClusterPartitionFetcher.java | 39 +-
.../plan/analyze/ConcatPathRewriter.java | 11 +-
.../plan/analyze/ExpressionAnalyzer.java | 5 +
.../plan/analyze/IPartitionFetcher.java | 12 +-
.../plan/analyze/LoadTsfileAnalyzer.java | 176 +-
.../queryengine/plan/analyze/SelectIntoUtils.java | 10 +-
.../analyze/cache/partition/PartitionCache.java | 54 +-
.../analyze/cache/schema/DataNodeSchemaCache.java | 122 +-
.../schema/DeviceUsingTemplateSchemaCache.java | 62 +-
.../analyze/cache/schema/SchemaCacheEntry.java | 17 +-
.../cache/schema/TimeSeriesSchemaCache.java | 71 +-
.../cache/schema/dualkeycache/IDualKeyCache.java | 22 +
.../dualkeycache/impl/CacheEntryGroupImpl.java | 6 +
.../schema/dualkeycache/impl/DualKeyCacheImpl.java | 159 +-
.../dualkeycache/impl/FIFOCacheEntryManager.java | 60 +-
.../schema/dualkeycache/impl/ICacheEntry.java | 2 +
.../schema/dualkeycache/impl/ICacheEntryGroup.java | 4 +
.../dualkeycache/impl/ICacheEntryManager.java | 2 +
.../dualkeycache/impl/LRUCacheEntryManager.java | 86 +-
.../schema/lastcache/DataNodeLastCacheManager.java | 6 +-
.../schema/lastcache/ILastCacheContainer.java | 2 +-
.../analyze/schema/AutoCreateSchemaExecutor.java | 72 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 14 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 10 +-
.../queryengine/plan/execution/QueryExecution.java | 8 +
.../plan/execution/config/ConfigExecution.java | 10 +-
.../plan/execution/config/ConfigTaskVisitor.java | 219 +-
.../config/executor/ClusterConfigTaskExecutor.java | 206 +-
.../config/executor/IConfigTaskExecutor.java | 16 +-
.../config/metadata/CreateContinuousQueryTask.java | 13 +-
.../config/metadata/CreatePipePluginTask.java | 2 +-
.../config/metadata/DropPipePluginTask.java | 2 +-
.../config/metadata/GetTimeSlotListTask.java | 6 +-
.../config/metadata/ShowClusterDetailsTask.java | 109 +-
.../execution/config/metadata/ShowClusterTask.java | 36 +-
.../config/metadata/ShowConfigNodesTask.java | 8 +-
.../config/metadata/ShowContinuousQueriesTask.java | 8 +-
.../config/metadata/ShowDataNodesTask.java | 7 +-
.../config/metadata/ShowFunctionsTask.java | 19 +-
.../config/metadata/ShowPipePluginsTask.java | 19 +-
.../execution/config/metadata/ShowRegionTask.java | 19 +-
.../execution/config/metadata/ShowTTLTask.java | 5 +-
.../config/metadata/ShowTriggersTask.java | 18 +-
.../config/metadata/ShowVariablesTask.java | 88 +-
.../config/metadata/model/CreateModelTask.java | 42 -
.../config/metadata/model/DropModelTask.java | 41 -
.../config/metadata/model/ShowModelsTask.java | 98 -
.../config/metadata/model/ShowTrailsTask.java | 90 -
.../template/ShowNodesInSchemaTemplateTask.java | 16 +-
.../metadata/template/ShowPathSetTemplateTask.java | 5 +-
.../metadata/template/ShowSchemaTemplateTask.java | 5 +-
.../config/metadata/view/AlterLogicalViewTask.java | 10 +-
.../plan/execution/config/sys/AuthorizerTask.java | 7 +-
.../execution/config/sys/pipe/ShowPipeTask.java | 29 +-
.../config/sys/quota/ShowSpaceQuotaTask.java | 30 +-
.../config/sys/quota/ShowThrottleQuotaTask.java | 34 +-
.../memory/StatementMemorySourceVisitor.java | 23 +-
.../plan/expression/ExpressionFactory.java | 9 +
.../visitor/ColumnTransformerVisitor.java | 4 -
.../visitor/RemoveRootPrefixVisitor.java | 45 +
.../plan/optimization/LimitOffsetPushDown.java | 15 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 272 +-
.../plan/parser/StatementGenerator.java | 123 +-
.../plan/planner/LocalExecutionPlanContext.java | 4 +-
.../plan/planner/LocalExecutionPlanner.java | 4 +-
.../plan/planner/LogicalPlanBuilder.java | 409 ++-
.../plan/planner/LogicalPlanVisitor.java | 78 +-
.../plan/planner/OperatorTreeGenerator.java | 172 +-
.../plan/planner/SubPlanTypeExtractor.java | 15 +
.../distribution/DistributionPlanContext.java | 9 +-
.../planner/distribution/DistributionPlanner.java | 26 +-
.../planner/distribution/ExchangeNodeAdder.java | 193 +-
.../planner/distribution/NodeGroupContext.java | 26 +-
.../SimpleFragmentParallelPlanner.java | 5 +-
.../plan/planner/distribution/SourceRewriter.java | 175 +-
.../plan/planner/plan/FragmentInstance.java | 21 +
.../db/queryengine/plan/planner/plan/SubPlan.java | 5 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 111 +-
.../plan/planner/plan/node/PlanNodeType.java | 12 +-
.../plan/planner/plan/node/PlanVisitor.java | 10 +
.../plan/node/load/LoadSingleTsFileNode.java | 27 +-
.../planner/plan/node/load/LoadTsFileNode.java | 10 +-
.../plan/node/metedata/read/DevicesCountNode.java | 13 +-
.../node/metedata/read/DevicesSchemaScanNode.java | 13 +-
.../metedata/read/LevelTimeSeriesCountNode.java | 13 +-
.../metedata/read/LogicalViewSchemaScanNode.java | 17 +-
.../metedata/read/NodePathsSchemaScanNode.java | 12 +-
.../metedata/read/PathsUsingTemplateScanNode.java | 11 +-
.../node/metedata/read/SchemaQueryScanNode.java | 43 +-
.../node/metedata/read/TimeSeriesCountNode.java | 15 +-
.../metedata/read/TimeSeriesSchemaScanNode.java | 29 +-
.../plan/planner/plan/node/process/TopKNode.java | 166 ++
.../node/process/last/LastQueryCollectNode.java | 17 +-
.../plan/node/process/last/LastQueryMergeNode.java | 24 +-
.../plan/node/process/last/LastQueryNode.java | 27 +-
.../node/process/last/LastQueryTransformNode.java | 129 +
.../planner/plan/node/sink/IdentitySinkNode.java | 5 +
.../planner/plan/node/sink/ShuffleSinkNode.java | 12 +-
.../plan/node/source/AlignedLastQueryScanNode.java | 20 +-
.../plan/node/source/AlignedSeriesScanNode.java | 4 +-
.../plan/node/source/LastQueryScanNode.java | 20 +-
.../planner/plan/node/write/DeleteDataNode.java | 36 +-
.../plan/planner/plan/node/write/InsertNode.java | 12 +
.../planner/plan/node/write/InsertRowNode.java | 8 +-
.../planner/plan/node/write/InsertRowsNode.java | 4 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 48 +-
.../planner/plan/node/write/InsertTabletNode.java | 78 +-
.../plan/node/write/PipeEnrichedInsertNode.java | 1 +
.../planner/plan/parameter/FillDescriptor.java | 36 +-
.../plan/parameter/GroupByTimeParameter.java | 85 +-
.../planner/plan/parameter/SeriesScanOptions.java | 7 +-
.../plan/scheduler/AsyncPlanNodeSender.java | 83 +-
.../plan/scheduler/AsyncSendPlanNodeHandler.java | 28 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 32 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 59 +-
.../statement/AuthorityInformationStatement.java | 48 +
.../db/queryengine/plan/statement/Statement.java | 13 +-
.../queryengine/plan/statement/StatementType.java | 1 +
.../plan/statement/StatementVisitor.java | 27 +-
.../plan/statement/component/FillComponent.java | 14 +
.../statement/component/GroupByTimeComponent.java | 52 +-
.../plan/statement/component/IntoComponent.java | 2 +
.../plan/statement/component/ResultColumn.java | 2 +-
.../plan/statement/component/SelectComponent.java | 2 +-
.../plan/statement/crud/DeleteDataStatement.java | 17 +
.../plan/statement/crud/InsertBaseStatement.java | 17 +
.../plan/statement/crud/InsertRowStatement.java | 4 +-
.../crud/InsertRowsOfOneDeviceStatement.java | 5 +-
.../plan/statement/crud/InsertStatement.java | 17 +
.../plan/statement/crud/InsertTabletStatement.java | 17 +-
.../plan/statement/crud/LoadTsFileStatement.java | 19 +
.../crud/PipeEnrichedInsertBaseStatement.java | 8 +-
.../crud/PipeEnrichedLoadTsFileStatement.java | 15 +-
.../plan/statement/crud/QueryStatement.java | 50 +-
.../InternalCreateMultiTimeSeriesStatement.java | 25 +-
.../InternalCreateTimeSeriesStatement.java | 17 +
.../plan/statement/literal/BooleanLiteral.java | 3 +-
.../plan/statement/literal/DoubleLiteral.java | 3 +-
.../plan/statement/literal/LongLiteral.java | 3 +-
.../plan/statement/literal/NullLiteral.java | 3 +-
.../plan/statement/literal/StringLiteral.java | 3 +-
.../metadata/AlterTimeSeriesStatement.java | 15 +
.../metadata/CreateAlignedTimeSeriesStatement.java | 17 +
.../metadata/CreateContinuousQueryStatement.java | 14 +
.../metadata/CreateFunctionStatement.java | 14 +
.../metadata/CreateMultiTimeSeriesStatement.java | 17 +
.../metadata/CreatePipePluginStatement.java | 72 -
.../metadata/CreateTimeSeriesStatement.java | 15 +
.../statement/metadata/CreateTriggerStatement.java | 14 +
.../metadata/DatabaseSchemaStatement.java | 14 +
.../metadata/DeleteDatabaseStatement.java | 14 +
.../metadata/DeleteTimeSeriesStatement.java | 17 +
.../metadata/DropContinuousQueryStatement.java | 14 +
.../statement/metadata/DropFunctionStatement.java | 14 +
.../metadata/DropPipePluginStatement.java | 60 -
.../statement/metadata/DropTriggerStatement.java | 32 +-
.../plan/statement/metadata/SetTTLStatement.java | 21 +-
.../statement/metadata/ShowClusterStatement.java | 14 +
.../metadata/ShowConfigNodesStatement.java | 9 +
.../metadata/ShowContinuousQueriesStatement.java | 14 +
.../statement/metadata/ShowDataNodesStatement.java | 9 +
.../statement/metadata/ShowDatabaseStatement.java | 5 +-
.../statement/metadata/ShowFunctionsStatement.java | 14 +
.../metadata/ShowPipePluginsStatement.java | 52 -
.../statement/metadata/ShowRegionStatement.java | 9 +
.../plan/statement/metadata/ShowStatement.java | 4 +-
.../statement/metadata/ShowTriggersStatement.java | 14 +
.../statement/metadata/ShowVariablesStatement.java | 14 +
.../metadata/model/CreateModelStatement.java | 109 -
.../metadata/model/DropModelStatement.java | 57 -
.../metadata/model/ShowModelsStatement.java | 51 -
.../metadata/model/ShowTrailsStatement.java | 57 -
.../metadata/pipe/CreatePipePluginStatement.java | 86 +
.../metadata/pipe/CreatePipeStatement.java | 14 +
.../metadata/pipe/DropPipePluginStatement.java | 74 +
.../statement/metadata/pipe/DropPipeStatement.java | 14 +
.../metadata/pipe/ShowPipePluginsStatement.java | 67 +
.../metadata/pipe/ShowPipesStatement.java | 14 +
.../metadata/pipe/StartPipeStatement.java | 14 +
.../statement/metadata/pipe/StopPipeStatement.java | 14 +
.../template/ActivateTemplateStatement.java | 30 +-
.../template/BatchActivateTemplateStatement.java | 36 +-
.../template/DeactivateTemplateStatement.java | 39 +-
.../ShowNodesInSchemaTemplateStatement.java | 9 +
.../template/ShowPathSetTemplateStatement.java | 9 +
.../template/ShowSchemaTemplateStatement.java | 9 +
.../metadata/view/AlterLogicalViewStatement.java | 45 +
.../metadata/view/CreateLogicalViewStatement.java | 39 +
.../metadata/view/DeleteLogicalViewStatement.java | 17 +
.../metadata/view/RenameLogicalViewStatement.java | 19 +
.../plan/statement/sys/AuthorStatement.java | 136 +-
.../plan/statement/sys/KillQueryStatement.java | 14 +
.../plan/statement/sys/ShowQueriesStatement.java | 17 +-
.../plan/statement/sys/ShowVersionStatement.java | 8 +
...ializableRowRecordListBackedMultiColumnRow.java | 4 +-
.../LayerPointReaderBackedSingleColumnRow.java | 3 +-
.../binary/CompareBinaryColumnTransformer.java | 11 +-
.../column/multi/MappableUDFColumnTransformer.java | 44 +-
.../column/ternary/BetweenColumnTransformer.java | 9 +-
.../dag/column/unary/InColumnTransformer.java | 4 +-
.../dag/column/unary/RegularColumnTransformer.java | 7 +-
.../scalar/CastFunctionColumnTransformer.java | 14 +-
.../scalar/ReplaceFunctionColumnTransformer.java | 7 +-
.../scalar/SubStringFunctionColumnTransformer.java | 7 +-
.../MultiInputColumnIntermediateLayer.java | 10 +-
.../binary/CompareEqualToTransformer.java | 5 +-
.../binary/CompareGreaterEqualTransformer.java | 5 +-
.../binary/CompareGreaterThanTransformer.java | 5 +-
.../binary/CompareLessEqualTransformer.java | 5 +-
.../binary/CompareLessThanTransformer.java | 5 +-
.../binary/CompareNonEqualTransformer.java | 5 +-
.../transformer/ternary/BetweenTransformer.java | 17 +-
.../dag/transformer/unary/InTransformer.java | 3 +-
.../dag/transformer/unary/RegularTransformer.java | 3 +-
.../unary/scalar/CastFunctionTransformer.java | 16 +-
.../unary/scalar/ReplaceFunctionTransformer.java | 9 +-
.../unary/scalar/SubStringFunctionTransformer.java | 8 +-
.../transformation/dag/udf/UDTFExecutor.java | 10 +
.../tv/ElasticSerializableBinaryTVList.java | 6 +-
.../tv/ElasticSerializableTVList.java | 8 +-
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 68 +-
.../schemaengine/metric/SchemaEngineMemMetric.java | 24 -
.../schemaengine/metric/SchemaMetricManager.java | 3 +-
.../metric/SchemaRegionCachedMetric.java | 4 +-
.../schemaengine/metric/SchemaRegionMemMetric.java | 36 +-
.../rescon/CachedSchemaEngineStatistics.java | 4 +
.../rescon/DataNodeSchemaQuotaManager.java | 85 +-
.../rescon/ISchemaEngineStatistics.java | 2 +
.../rescon/MemSchemaEngineStatistics.java | 39 +-
.../schemaengine/schemaregion/ISchemaRegion.java | 9 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 38 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 142 +-
.../schemaregion/mtree/IMTreeStore.java | 9 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 121 +-
.../schemaregion/mtree/impl/mem/MemMTreeStore.java | 2 +-
.../impl/mem/mnode/factory/MemMNodeFactory.java | 3 +-
.../mnode/iterator/AbstractTraverserIterator.java | 11 +-
.../impl/mem/mnode/iterator/MNodeIterator.java | 5 +
.../impl/mem/snapshot/MemMTreeSnapshotUtil.java | 12 +-
.../mtree/impl/pbtree/CachedMTreeStore.java | 119 +-
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 348 ++-
.../pbtree/ReentrantReadOnlyCachedMTreeStore.java | 5 +-
.../impl/pbtree/StampedWriterPreferredLock.java | 10 +-
.../mtree/impl/pbtree/cache/CacheManager.java | 286 ++-
.../mtree/impl/pbtree/cache/ICacheManager.java | 10 +-
.../impl/pbtree/flush/PBTreeFlushExecutor.java | 104 +
.../mnode/container/CachedMNodeContainer.java | 5 +
.../mnode/container/ICachedMNodeContainer.java | 4 +-
.../pbtree/mnode/factory/CacheMNodeFactory.java | 3 +-
.../mtree/impl/pbtree/schemafile/RecordUtils.java | 97 +-
.../mtree/impl/pbtree/schemafile/SchemaFile.java | 35 +-
.../schemafile/pagemgr/BTreePageManager.java | 6 +-
.../pbtree/schemafile/pagemgr/PageManager.java | 71 +-
.../schemaregion/mtree/traverser/Traverser.java | 52 +-
.../mtree/traverser/basic/DatabaseTraverser.java | 10 +-
.../mtree/traverser/basic/EntityTraverser.java | 11 +-
.../mtree/traverser/basic/MNodeTraverser.java | 11 +-
.../traverser/basic/MeasurementTraverser.java | 25 +-
.../traverser/collector/DatabaseCollector.java | 9 +-
.../mtree/traverser/collector/EntityCollector.java | 9 +-
.../traverser/collector/MNodeAboveDBCollector.java | 9 +-
.../mtree/traverser/collector/MNodeCollector.java | 9 +-
.../traverser/collector/MeasurementCollector.java | 14 +-
.../mtree/traverser/counter/DatabaseCounter.java | 10 +-
.../mtree/traverser/counter/EntityCounter.java | 10 +-
.../traverser/counter/MeasurementCounter.java | 9 +-
.../mtree/traverser/updater/EntityUpdater.java | 11 +-
.../traverser/updater/MeasurementUpdater.java | 10 +-
.../schemaregion/read/req/IShowSchemaPlan.java | 3 +
.../read/req/SchemaRegionReadPlanFactory.java | 69 +-
.../read/req/impl/AbstractShowSchemaPlanImpl.java | 13 +-
.../read/req/impl/ShowDevicesPlanImpl.java | 6 +-
.../read/req/impl/ShowNodesPlanImpl.java | 6 +-
.../read/req/impl/ShowTimeSeriesPlanImpl.java | 6 +-
.../schemaregion/utils/ResourceByPathUtils.java | 20 +-
.../template/ClusterTemplateManager.java | 26 +-
.../db/schemaengine/template/ITemplateManager.java | 10 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 114 +-
.../db/service/DataNodeInternalRPCService.java | 3 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 10 +-
.../apache/iotdb/db/service/MLNodeRPCService.java | 98 -
.../iotdb/db/service/MLNodeRPCServiceMBean.java | 22 -
.../org/apache/iotdb/db/service/MQTTService.java | 7 +-
.../org/apache/iotdb/db/service/RPCService.java | 40 +-
.../db/service/metrics/CompactionMetrics.java | 412 +++-
.../db/service/metrics/DataNodeMetricsHelper.java | 4 +
.../iotdb/db/service/metrics/FileMetrics.java | 542 +---
.../metrics/IoTDBInternalLocalReporter.java | 11 +-
.../metrics/file/CompactionFileMetrics.java | 165 ++
.../db/service/metrics/file/ModsFileMetrics.java | 86 +
.../metrics/file/SystemRelatedFileMetrics.java | 109 +
.../db/service/metrics/file/TsFileMetrics.java | 414 ++++
.../db/service/metrics/file/WalFileMetrics.java | 58 +
.../iotdb/db/storageengine/StorageEngine.java | 42 +-
.../db/storageengine/buffer/BloomFilterCache.java | 56 +-
.../storageengine/buffer/CacheHitRatioMonitor.java | 3 +-
.../iotdb/db/storageengine/buffer/ChunkCache.java | 155 +-
.../buffer/TimeSeriesMetadataCache.java | 125 +-
.../db/storageengine/dataregion/DataRegion.java | 408 +--
.../dataregion/HashLastFlushTimeMap.java | 12 +-
.../compaction/constant/CompactionTaskType.java | 3 +-
.../constant/CompactionValidationLevel.java | 26 -
.../exception/CompactionRecoverException.java | 30 +
.../FileCannotTransitToCompactingException.java | 49 +
.../impl/ReadChunkCompactionPerformer.java | 10 +-
.../execute/recover/CompactionRecoverManager.java | 54 +-
.../execute/recover/CompactionRecoverTask.java | 238 +-
.../execute/task/AbstractCompactionTask.java | 273 +-
.../execute/task/CompactionTaskPriorityType.java | 32 +
.../execute/task/CrossSpaceCompactionTask.java | 281 ++-
.../execute/task/InnerSpaceCompactionTask.java | 344 +--
.../task/InsertionCrossSpaceCompactionTask.java | 357 +++
.../compaction/execute/utils/CompactionUtils.java | 245 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 29 +-
.../fast/AlignedSeriesCompactionExecutor.java | 18 +-
.../fast/NonAlignedSeriesCompactionExecutor.java | 9 +-
.../executor/fast/SeriesCompactionExecutor.java | 11 +-
.../utils/executor/fast/element/PageElement.java | 9 +-
.../utils/executor/fast/element/PointElement.java | 7 +-
.../execute/utils/log/CompactionLogAnalyzer.java | 121 +-
.../execute/utils/log/CompactionLogger.java | 63 +-
.../execute/utils/log/CompactionTaskStage.java | 39 +
.../execute/utils/log/SimpleCompactionLogger.java | 54 +
.../execute/utils/log/TsFileIdentifier.java | 62 +-
.../execute/utils/reader/PointPriorityReader.java | 14 +-
.../utils/validator/CompactionValidator.java | 51 -
.../utils/validator/NoneCompactionValidator.java | 49 -
.../ResourceAndTsfileCompactionValidator.java | 57 -
.../validator/ResourceOnlyCompactionValidator.java | 56 -
.../compaction/io/CompactionTsFileWriter.java | 45 +-
.../schedule/CompactionScheduleSummary.java | 72 +
.../compaction/schedule/CompactionScheduler.java | 120 +-
.../compaction/schedule/CompactionTaskManager.java | 24 +-
.../compaction/schedule/CompactionWorker.java | 74 +-
.../DefaultCompactionTaskComparatorImpl.java | 16 +
.../compaction/selector/ICompactionSelector.java | 7 +-
.../selector/IInnerSeqSpaceSelector.java | 3 +-
.../selector/IInnerUnseqSpaceSelector.java | 3 +-
.../estimator/AbstractCompactionEstimator.java | 121 +-
.../estimator/AbstractCrossSpaceEstimator.java | 27 +-
.../estimator/AbstractInnerSpaceEstimator.java | 77 +-
.../estimator/CompactionEstimateUtils.java | 3 +-
.../selector/estimator/CompactionTaskInfo.java | 101 +
.../FastCompactionInnerCompactionEstimator.java | 72 +-
.../FastCrossSpaceCompactionEstimator.java | 81 +
.../estimator/InplaceCompactionEstimator.java | 172 --
.../ReadChunkInnerCompactionEstimator.java | 38 +-
.../ReadPointCrossCompactionEstimator.java | 197 --
.../impl/RewriteCrossSpaceCompactionSelector.java | 238 +-
.../impl/SizeTieredCompactionSelector.java | 121 +-
.../utils/CrossCompactionTaskResource.java | 6 +-
.../utils/CrossSpaceCompactionCandidate.java | 116 -
.../compaction/selector/utils/DeviceInfo.java | 32 +
.../InsertionCrossCompactionTaskResource.java | 44 +
.../selector/utils/TsFileResourceCandidate.java | 130 +
.../compaction/settle/SettleRequestHandler.java | 1 -
.../dataregion/compaction/tool/ITimeRange.java | 30 +
.../dataregion/compaction/tool/Interval.java | 49 +
.../compaction/tool/ListTimeRangeImpl.java | 89 +
.../compaction/tool/OverlapStatistic.java | 91 +
.../compaction/tool/OverlapStatisticTool.java | 248 ++
.../dataregion/compaction/tool/PrintUtil.java | 209 ++
.../tool/SequenceFileSubTaskThreadExecutor.java | 41 +
.../compaction/tool/SequenceFileTaskSummary.java | 58 +
.../compaction/tool/SingleSequenceFileTask.java | 104 +
.../compaction/tool/TimePartitionProcessTask.java | 143 ++
.../tool/TimePartitionProcessWorker.java | 58 +
.../compaction/tool/TsFileStatisticReader.java | 96 +
.../compaction/tool/UnseqSpaceStatistics.java | 84 +
.../dataregion/flush/CompressionRatio.java | 132 +-
.../dataregion/flush/FlushManager.java | 7 +-
.../dataregion/memtable/AbstractMemTable.java | 71 +-
.../memtable/AlignedWritableMemChunk.java | 57 +-
.../dataregion/memtable/IMemTable.java | 6 +
.../dataregion/memtable/PrimitiveMemTable.java | 18 +-
.../dataregion/memtable/TsFileProcessor.java | 47 +-
.../dataregion/memtable/WritableMemChunk.java | 18 +-
.../io/LocalTextModificationAccessor.java | 36 +-
.../modification/io/ModificationWriter.java | 3 +
.../read/reader/chunk/DiskAlignedChunkLoader.java | 26 +-
.../read/reader/chunk/DiskChunkLoader.java | 27 +-
.../metadata/DiskAlignedChunkMetadataLoader.java | 18 +-
.../chunk/metadata/DiskChunkMetadataLoader.java | 17 +-
.../metadata/MemAlignedChunkMetadataLoader.java | 4 +-
.../chunk/metadata/MemChunkMetadataLoader.java | 4 +-
.../dataregion/snapshot/SnapshotLoader.java | 20 +-
.../dataregion/snapshot/SnapshotLogger.java | 6 +-
.../storageengine/dataregion/tsfile/TsFileID.java | 96 +
.../dataregion/tsfile/TsFileManager.java | 64 +-
.../dataregion/tsfile/TsFileResource.java | 300 +--
.../dataregion/tsfile/TsFileResourceBlockType.java | 52 +
.../tsfile/timeindex/DeviceTimeIndex.java | 9 +-
.../dataregion/tsfile/timeindex/FileTimeIndex.java | 6 +-
.../dataregion/utils/TsFileResourceUtils.java | 378 +++
.../validate/TsFileResourceAndDataValidator.java | 58 +
.../utils/validate/TsFileResourceValidator.java | 59 +
.../dataregion/utils/validate/TsFileValidator.java | 47 +
.../storageengine/dataregion/wal/WALManager.java | 43 +-
.../dataregion/wal/buffer/WALBuffer.java | 30 +-
.../wal/checkpoint/CheckpointManager.java | 13 +-
.../dataregion/wal/checkpoint/MemTableInfo.java | 7 +
.../storageengine/dataregion/wal/node/WALNode.java | 59 +-
.../dataregion/wal/recover/WALNodeRecoverTask.java | 61 +-
.../dataregion/wal/recover/WALRecoverManager.java | 15 +-
.../file/AbstractTsFileRecoverPerformer.java | 5 +
.../wal/recover/file/TsFilePlanRedoer.java | 13 +-
.../file/UnsealedTsFileRecoverPerformer.java | 73 +-
.../dataregion/wal/utils/WALEntryHandler.java | 45 +-
.../dataregion/wal/utils/WALEntryPosition.java | 59 +-
.../dataregion/wal/utils/WALInsertNodeCache.java | 239 +-
.../wal/utils/listener/AbstractResultListener.java | 2 +
.../wal/utils/listener/WALFlushListener.java | 2 +-
.../storageengine/rescon/disk/FolderManager.java | 2 +
.../db/storageengine/rescon/disk/TierManager.java | 7 +-
.../rescon/memory/MemTableManager.java | 8 +-
.../db/storageengine/rescon/memory/SystemInfo.java | 62 +-
.../rescon/memory/TimePartitionManager.java | 6 +
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 10 +-
.../TsFileOverlapValidationAndRepairTool.java | 275 +++
.../org/apache/iotdb/db/utils/CommonUtils.java | 17 +-
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 145 +-
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 41 +-
.../java/org/apache/iotdb/db/utils/MemUtils.java | 3 +-
.../apache/iotdb/db/utils/TimePartitionUtils.java | 43 -
.../apache/iotdb/db/utils/TimeValuePairUtils.java | 3 +-
.../iotdb/db/utils/TimestampPrecisionUtils.java | 59 +-
.../db/utils/datastructure/AlignedTVList.java | 62 +-
.../db/utils/datastructure/MergeSortHeap.java | 4 +
.../iotdb/db/utils/datastructure/MergeSortKey.java | 3 +-
.../iotdb/db/utils/sort/FileSpillerReader.java | 6 +-
.../iotdb/db/utils/sort/SortBufferManager.java | 5 +-
.../handler/SlidingWindowEvaluationHandler.java | 3 +-
.../iotdb/db/auth/AuthorizerManagerTest.java | 187 +-
.../auth/authorizer/LocalFileAuthorizerTest.java | 78 +-
.../iotdb/db/auth/entity/PathPrivilegeTest.java | 52 +-
.../org/apache/iotdb/db/auth/entity/RoleTest.java | 23 +-
.../org/apache/iotdb/db/auth/entity/UserTest.java | 11 +-
.../db/auth/role/LocalFileRoleAccessorTest.java | 78 +-
.../db/auth/role/LocalFileRoleManagerTest.java | 98 +-
.../db/auth/user/LocalFileUserAccessorTest.java | 81 +-
.../db/auth/user/LocalFileUserManagerTest.java | 155 +-
.../apache/iotdb/db/conf/IoTDBDescriptorTest.java | 40 +-
.../db/metadata/cache/DataNodeSchemaCacheTest.java | 73 +-
.../cache/dualkeycache/DualKeyCacheTest.java | 185 +-
.../mtree/lock/StampedWriterPreferredLockTest.java | 43 +
.../mtree/schemafile/SchemaFileLogTest.java | 13 +
.../schemaRegion/SchemaRegionAliasAndTagTest.java | 21 +-
.../schemaRegion/SchemaRegionBasicTest.java | 220 +-
.../schemaRegion/SchemaRegionManagementTest.java | 22 +-
.../schemaRegion/SchemaRegionTemplateTest.java | 88 +-
.../schemaRegion/SchemaRegionTestUtil.java | 90 +-
.../apache/iotdb/db/metric/MetricServiceTest.java | 48 +-
.../db/pipe/agent/plugin/PipePluginAgentTest.java | 6 +-
.../iotdb/db/pipe/connector/PipeConnectorTest.java | 76 +-
.../pipe/event/PipeTabletInsertionEventTest.java | 9 +-
.../PipeConnectorSubtaskExecutorTest.java | 3 +
.../PipeProcessorSubtaskExecutorTest.java | 3 +
.../extractor/CachedSchemaPatternMatcherTest.java | 2 +-
.../extractor/IoTDBDataRegionExtractorTest.java | 8 +-
.../db/pipe/extractor/PipeRealtimeExtractTest.java | 4 +-
.../resource/PipeTsFileResourceManagerTest.java | 2 +-
.../db/protocol/mqtt/BrokerAuthenticatorTest.java | 15 +-
.../db/protocol/rest/GrafanaApiServiceTest.java | 92 +-
.../db/qp/utils/DatetimeQueryDataSetUtilsTest.java | 238 --
.../common/schematree/ClusterSchemaTreeTest.java | 121 +-
.../db/queryengine/execution/DataDriverTest.java | 8 +-
.../aggregation/TimeRangeIteratorTest.java | 183 +-
.../execution/exchange/SharedTsBlockQueueTest.java | 2 +-
.../execution/exchange/SinkChannelTest.java | 5 +-
.../operator/AggregationOperatorTest.java | 12 +-
.../AlignedSeriesAggregationScanOperatorTest.java | 27 +-
.../operator/AlignedSeriesScanOperatorTest.java | 2 +
.../execution/operator/AlignedSeriesTestUtil.java | 5 +-
.../execution/operator/DeviceViewOperatorTest.java | 3 +-
.../execution/operator/FillOperatorTest.java | 175 +-
.../operator/HorizontallyConcatOperatorTest.java | 12 +-
.../execution/operator/LastQueryOperatorTest.java | 5 +-
.../operator/LastQuerySortOperatorTest.java | 5 +-
.../execution/operator/LimitOperatorTest.java | 2 +
.../execution/operator/MergeSortOperatorTest.java | 244 +-
.../execution/operator/OffsetOperatorTest.java | 4 +
.../execution/operator/OperatorMemoryTest.java | 30 +-
.../operator/RawDataAggregationOperatorTest.java | 21 +-
.../SeriesAggregationScanOperatorTest.java | 27 +-
.../operator/SingleDeviceViewOperatorTest.java | 2 +
.../SlidingWindowAggregationOperatorTest.java | 8 +-
.../execution/operator/SortOperatorTest.java | 50 +-
.../execution/operator/TopKOperatorTest.java | 1361 ++++++++++
.../operator/UpdateLastCacheOperatorTest.java | 5 +-
.../fill/filter/MonthIntervalFillFilterTest.java | 163 ++
.../schema/CountGroupByLevelMergeOperatorTest.java | 4 +-
.../operator/schema/SchemaCountOperatorTest.java | 3 +-
.../schema/SchemaFetchScanOperatorTest.java | 21 +-
.../schema/SchemaQueryScanOperatorTest.java | 12 +-
.../schedule/DefaultDriverSchedulerTest.java | 28 +-
.../DriverTaskTimeoutSentinelThreadTest.java | 19 +-
.../queue/MultilevelPriorityQueueTest.java | 199 ++
.../queryengine/plan/analyze/AnalyzeFailTest.java | 38 +-
.../db/queryengine/plan/analyze/AnalyzeTest.java | 25 +-
.../plan/analyze/FakePartitionFetcherImpl.java | 6 +-
.../plan/analyze/cache/PartitionCacheTest.java | 33 +-
.../plan/optimization/TestPlanBuilder.java | 8 +-
.../plan/parser/StatementGeneratorTest.java | 377 ++-
.../queryengine/plan/plan/PipelineBuilderTest.java | 91 +
.../plan/plan/QueryLogicalPlanUtil.java | 2 +-
.../AlignByDeviceOrderByLimitOffsetTest.java | 278 +++
.../plan/distribution/AlignedByDeviceTest.java | 23 +
.../distribution/DistributionPlannerBasicTest.java | 10 +-
.../distribution/DistributionPlannerCycleTest.java | 81 +
.../plan/plan/distribution/LastQueryTest.java | 2 +-
.../queryengine/plan/plan/distribution/Util.java | 7 +-
.../queryengine/plan/plan/distribution/Util2.java | 309 +++
.../plan/plan/node/PlanGraphPrinterTest.java | 70 +
.../plan/plan/node/load/LoadTsFileNodeTest.java | 2 +-
.../read/DeviceSchemaScanNodeSerdeTest.java | 4 +-
.../NodeManagementMemoryMergeNodeSerdeTest.java | 6 +-
.../read/PathsUsingTemplateScanNodeTest.java | 6 +-
.../metadata/read/SchemaCountNodeSerdeTest.java | 12 +-
.../read/TimeSeriesSchemaScanNodeSerdeTest.java | 4 +-
.../node/process/AggregationNodeSerdeTest.java | 3 +-
.../plan/plan/node/process/FillNodeSerdeTest.java | 2 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 3 +-
.../plan/node/process/GroupByTagNodeSerdeTest.java | 3 +-
.../source/SeriesAggregationScanNodeSerdeTest.java | 3 +-
.../write/InsertMultiTabletsNodeSerdeTest.java | 3 +-
.../plan/node/write/WritePlanNodeSplitTest.java | 110 +-
.../ElasticSerializableRowRecordListTest.java | 8 +-
.../ElasticSerializableTVListTest.java | 5 +-
.../SerializableBinaryTVListTest.java | 3 +-
.../SerializableRowRecordListTest.java | 4 +-
.../security/encrypt/MessageDigestEncryptTest.java | 2 +-
.../iotdb/db/storageengine/StorageEngineTest.java | 14 +
.../storageengine/buffer/BloomFilterCacheTest.java | 40 +-
.../db/storageengine/buffer/ChunkCacheTest.java | 65 +-
.../buffer/TimeSeriesMetadataCacheTest.java | 28 -
.../storageengine/dataregion/DataRegionTest.java | 260 +-
.../dataregion/LastFlushTimeMapTest.java | 84 +
.../TsFileResourceProgressIndexTest.java | 162 +-
.../compaction/AbstractCompactionTest.java | 87 +
.../compaction/CompactionSchedulerTest.java | 7 +-
.../CompactionSchedulerWithFastPerformerTest.java | 5 +
.../compaction/CompactionTaskComparatorTest.java | 124 +-
.../compaction/CompactionTaskManagerTest.java | 26 +-
.../compaction/CompactionValidationTest.java | 45 +-
.../compaction/CompactionWorkerTest.java | 217 ++
.../CrossSpaceCompactionWithUnusualCasesTest.java | 129 +-
.../compaction/FastAlignedCrossCompactionTest.java | 47 -
.../FastCompactionPerformerWithEmptyPageTest.java | 135 +
...InconsistentCompressionTypeAndEncodingTest.java | 7 -
.../FastCrossCompactionPerformerTest.java | 21 +-
.../FastInnerCompactionPerformerTest.java | 121 +-
.../FastNonAlignedCrossCompactionTest.java | 47 -
.../dataregion/compaction/MemoryControlTest.java | 219 --
.../compaction/ReadChunkInnerCompactionTest.java | 316 ++-
.../ReadPointAlignedCrossCompactionTest.java | 47 -
.../ReadPointCompactionPerformerTest.java | 8 +-
.../ReadPointNonAlignedCrossCompactionTest.java | 47 -
.../TsFileValidationCorrectnessTests.java | 296 +++
.../cross/CrossSpaceCompactionExceptionTest.java | 4 +
.../cross/CrossSpaceCompactionSelectorTest.java | 92 +-
.../CrossSpaceCompactionWithFastPerformerTest.java | 30 +-
...eCompactionWithFastPerformerValidationTest.java | 183 +-
...sSpaceCompactionWithReadPointPerformerTest.java | 30 +-
...actionWithReadPointPerformerValidationTest.java | 160 +-
.../InsertionCrossSpaceCompactionRecoverTest.java | 372 +++
.../InsertionCrossSpaceCompactionSelectorTest.java | 2372 ++++++++++++++++++
.../cross/InsertionCrossSpaceCompactionTest.java | 516 ++++
...eCrossSpaceCompactionWithFastPerformerTest.java | 43 +-
...sSpaceCompactionWithReadPointPerformerTest.java | 31 +-
.../inner/InnerCompactionEmptyTsFileTest.java | 2 -
.../inner/InnerCompactionSchedulerTest.java | 10 +-
.../compaction/inner/InnerCompactionTest.java | 2 +
.../InnerSeqCompactionWithFastPerformerTest.java | 28 +-
...nerSeqCompactionWithReadChunkPerformerTest.java | 15 +-
.../inner/InnerSpaceCompactionSelectorTest.java | 112 +-
.../InnerUnseqCompactionWithFastPerformerTest.java | 2 +
...rUnseqCompactionWithReadPointPerformerTest.java | 2 +
.../ReadChunkCompactionPerformerAlignedTest.java | 3 +-
.../SizeTieredCompactionRecoverTest.java | 2 -
...eCrossSpaceCompactionRecoverCompatibleTest.java | 413 ----
.../SizeTieredCompactionRecoverCompatibleTest.java | 276 ---
.../recover/SizeTieredCompactionRecoverTest.java | 591 +++--
.../settle/SettleRequestHandlerTest.java | 2 +-
.../compaction/tools/ListTimeRangeImplTest.java | 138 ++
.../compaction/tools/UnseqSpaceStatisticsTest.java | 63 +
.../compaction/utils/CompactionConfigRestorer.java | 4 +
.../utils/CompactionFileGeneratorUtils.java | 30 +-
.../utils/CompactionTaskMemCostEstimatorTest.java | 22 +-
.../compaction/utils/CompactionTestFileWriter.java | 103 +-
.../utils/CompactionUpdateFileCountTest.java | 109 +
.../utils/MultiTsFileDeviceIteratorTest.java | 7 -
.../compaction/utils/TsFileGeneratorUtils.java | 132 +-
.../dataregion/flush/CompressionRatioTest.java | 108 +-
.../dataregion/memtable/MemTableFlushTaskTest.java | 4 +-
.../dataregion/memtable/MemtableBenchmark.java | 4 +-
.../dataregion/memtable/PrimitiveMemTableTest.java | 20 +-
.../dataregion/memtable/TsFileProcessorTest.java | 7 +-
.../reader/chunk/MemAlignedChunkLoaderTest.java | 3 +-
.../read/reader/chunk/MemChunkLoaderTest.java | 5 +-
.../AlignedSeriesScanLimitOffsetPushDownTest.java | 6 +
.../read/reader/series/SeriesReaderTestUtil.java | 2 +
.../dataregion/wal/WALManagerTest.java | 5 +-
.../wal/allocation/ElasticStrategyTest.java | 3 +-
.../wal/allocation/FirstCreateStrategyTest.java | 3 +-
.../wal/allocation/RoundRobinStrategyTest.java | 3 +-
.../dataregion/wal/buffer/WALBufferCommonTest.java | 3 +-
.../wal/checkpoint/CheckpointManagerTest.java | 8 +-
.../dataregion/wal/io/CheckpointFileTest.java | 8 +-
.../dataregion/wal/io/WALFileTest.java | 5 +-
.../wal/node/ConsensusReqReaderTest.java | 5 +-
.../dataregion/wal/node/WALEntryHandlerTest.java | 34 +-
.../dataregion/wal/node/WALNodeTest.java | 13 +-
.../wal/recover/WALRecoverManagerTest.java | 16 +-
.../wal/recover/WALRecoverWriterTest.java | 3 +-
.../wal/recover/file/TsFilePlanRedoerTest.java | 53 +-
.../wal/utils/WALInsertNodeCacheTest.java | 166 +-
.../rescon/memory/ResourceManagerTest.java | 2 +
.../TsFileOverlapValidationAndRepairToolTest.java | 193 ++
.../apache/iotdb/db/utils/DateTimeUtilsTest.java | 265 ++
.../apache/iotdb/db/utils/EnvironmentUtils.java | 18 +-
.../org/apache/iotdb/db/utils/MemUtilsTest.java | 6 +-
.../iotdb/db/utils/QueryDataSetUtilsTest.java | 6 +-
.../apache/iotdb/db/utils/SerializeUtilsTest.java | 68 +-
.../db/utils/TimestampPrecisionUtilsTest.java | 87 +
.../db/utils/datastructure/AlignedTVListTest.java | 7 +-
.../db/utils/datastructure/BinaryTVListTest.java | 15 +-
.../db/utils/datastructure/MergeSortHeapTest.java | 117 +
.../apache/iotdb/db/utils/sort/SortUtilTest.java | 9 +
.../datanode1conf/iotdb-datanode.properties | 3 +-
.../src/test/resources/datanode1conf/logback.xml | 40 +-
.../datanode2conf/iotdb-datanode.properties | 3 +-
.../src/test/resources/datanode2conf/logback.xml | 40 +-
.../datanode3conf/iotdb-datanode.properties | 3 +-
.../src/test/resources/datanode3conf/logback.xml | 40 +-
.../src/test/resources/iotdb-datanode.properties | 1 +
iotdb-core/metrics/ReadMe.md | 18 +-
iotdb-core/metrics/core/pom.xml | 50 +
.../iotdb/metrics/core/IoTDBMetricManager.java | 157 ++
.../metrics/core/reporter/IoTDBJmxReporter.java | 183 ++
.../iotdb/metrics/core/type/IoTDBAutoGauge.java | 45 +
.../metrics/core/type/IoTDBAutoGaugeMBean.java | 28 +
.../iotdb/metrics/core/type/IoTDBCounter.java | 48 +
.../iotdb/metrics/core/type/IoTDBCounterMBean.java | 28 +
.../apache/iotdb/metrics/core/type/IoTDBGauge.java | 53 +
.../iotdb/metrics/core/type/IoTDBGaugeMBean.java | 28 +
.../iotdb/metrics/core/type/IoTDBHistogram.java | 72 +
.../metrics/core/type/IoTDBHistogramMBean.java | 38 +
.../metrics/core/type/IoTDBHistogramSnapshot.java | 77 +
.../apache/iotdb/metrics/core/type/IoTDBRate.java | 68 +
.../iotdb/metrics/core/type/IoTDBRateMBean.java | 32 +
.../apache/iotdb/metrics/core/type/IoTDBTimer.java | 80 +
.../core/type/IoTDBTimerHistogramSnapshot.java | 81 +
.../iotdb/metrics/core/type/IoTDBTimerMBean.java | 40 +
.../iotdb/metrics/core/uitls/IoTDBCachedGauge.java | 111 +
.../metrics/core/uitls/IoTDBCachedGaugeMBean.java | 28 +
.../core/uitls/IoTDBMetricObjNameFactory.java | 104 +
.../metrics/core/uitls/IoTDBMovingAverage.java | 86 +
.../metrics/core/uitls/ObjectNameFactory.java | 34 +
.../org.apache.iotdb.metrics.AbstractMetricManager | 18 +
.../org.apache.iotdb.metrics.reporter.JmxReporter | 18 +
iotdb-core/metrics/dropwizard-metrics/pom.xml | 52 -
.../dropwizard/DropwizardMetricManager.java | 129 -
.../dropwizard/DropwizardMetricNameTool.java | 82 -
.../dropwizard/reporter/DropwizardJmxReporter.java | 83 -
.../dropwizard/type/DropwizardAutoGauge.java | 49 -
.../metrics/dropwizard/type/DropwizardCounter.java | 45 -
.../metrics/dropwizard/type/DropwizardGauge.java | 72 -
.../dropwizard/type/DropwizardHistogram.java | 47 -
.../type/DropwizardHistogramSnapshot.java | 58 -
.../metrics/dropwizard/type/DropwizardRate.java | 94 -
.../metrics/dropwizard/type/DropwizardTimer.java | 48 -
.../org.apache.iotdb.metrics.AbstractMetricManager | 18 -
.../org.apache.iotdb.metrics.reporter.JmxReporter | 18 -
iotdb-core/metrics/interface/pom.xml | 89 +-
.../iotdb/metrics/AbstractMetricManager.java | 79 +-
.../iotdb/metrics/AbstractMetricService.java | 70 +-
.../iotdb/metrics/DoNothingMetricService.java | 10 +
.../apache/iotdb/metrics/config/MetricConfig.java | 17 +-
.../metrics/config/MetricConfigDescriptor.java | 9 +-
.../iotdb/metrics/impl/DoNothingAutoGauge.java | 5 +-
.../iotdb/metrics/impl/DoNothingCounter.java | 5 +-
.../apache/iotdb/metrics/impl/DoNothingGauge.java | 5 +-
.../iotdb/metrics/impl/DoNothingHistogram.java | 5 +-
.../metrics/impl/DoNothingHistogramSnapshot.java | 4 +-
.../iotdb/metrics/impl/DoNothingMetricManager.java | 10 +-
.../apache/iotdb/metrics/impl/DoNothingRate.java | 13 +-
.../apache/iotdb/metrics/impl/DoNothingTimer.java | 3 +-
.../metrics/metricsets/cpu/CpuUsageMetrics.java | 2 +-
.../disk/DoNothingDiskMetricsManager.java | 22 +
.../metricsets/disk/IDiskMetricsManager.java | 24 +-
.../metricsets/net/DoNothingNetMetricManager.java | 22 +
.../metrics/metricsets/net/INetMetricManager.java | 33 +-
.../metrics/metricsets/system/SystemMetrics.java | 71 +-
.../apache/iotdb/metrics/reporter/JmxReporter.java | 7 +-
.../reporter/prometheus/PrometheusReporter.java | 12 +-
.../org/apache/iotdb/metrics/type/AutoGauge.java | 4 +-
.../org/apache/iotdb/metrics/type/Counter.java | 4 +-
.../java/org/apache/iotdb/metrics/type/Gauge.java | 4 +-
.../org/apache/iotdb/metrics/type/Histogram.java | 4 +-
.../org/apache/iotdb/metrics/type/IMetric.java | 4 +
.../java/org/apache/iotdb/metrics/type/Rate.java | 8 -
.../iotdb/metrics/utils/AbstractMetricMBean.java | 35 +
.../iotdb/metrics/utils/MetricFrameType.java | 30 -
.../apache/iotdb/metrics/utils/MetricLevel.java | 2 +-
.../apache/iotdb/metrics/utils/SystemMetric.java | 1 +
.../iotdb/metrics/config/MetricConfigTest.java | 5 -
iotdb-core/metrics/micrometer-metrics/pom.xml | 58 -
.../micrometer/MicrometerMetricManager.java | 153 --
.../micrometer/reporter/MicrometerJmxConfig.java | 29 -
.../micrometer/reporter/MicrometerJmxReporter.java | 90 -
.../micrometer/type/MicrometerAutoGauge.java | 52 -
.../metrics/micrometer/type/MicrometerCounter.java | 45 -
.../metrics/micrometer/type/MicrometerGauge.java | 57 -
.../micrometer/type/MicrometerHistogram.java | 47 -
.../type/MicrometerHistogramSnapshot.java | 70 -
.../metrics/micrometer/type/MicrometerRate.java | 81 -
.../metrics/micrometer/type/MicrometerTimer.java | 49 -
.../type/MicrometerTimerHistogramSnapshot.java | 74 -
.../org.apache.iotdb.metrics.AbstractMetricManager | 18 -
.../org.apache.iotdb.metrics.reporter.JmxReporter | 18 -
iotdb-core/metrics/pom.xml | 11 +-
iotdb-core/mlnode/.flake8 | 33 -
iotdb-core/mlnode/.gitignore | 8 -
iotdb-core/mlnode/README.md | 47 -
iotdb-core/mlnode/iotdb/__init__.py | 17 -
iotdb-core/mlnode/iotdb/mlnode/__init__.py | 17 -
iotdb-core/mlnode/iotdb/mlnode/client.py | 317 ---
iotdb-core/mlnode/iotdb/mlnode/config.py | 132 -
iotdb-core/mlnode/iotdb/mlnode/constant.py | 33 -
iotdb-core/mlnode/iotdb/mlnode/exception.py | 31 -
iotdb-core/mlnode/iotdb/mlnode/handler.py | 44 -
iotdb-core/mlnode/iotdb/mlnode/log.py | 34 -
iotdb-core/mlnode/iotdb/mlnode/script.py | 36 -
iotdb-core/mlnode/iotdb/mlnode/serde.py | 439 ----
iotdb-core/mlnode/iotdb/mlnode/service.py | 62 -
iotdb-core/mlnode/iotdb/mlnode/storage.py | 102 -
iotdb-core/mlnode/iotdb/mlnode/util.py | 57 -
iotdb-core/mlnode/pom.xml | 159 --
iotdb-core/mlnode/pyproject.toml | 55 -
iotdb-core/mlnode/requirements.txt | 27 -
iotdb-core/mlnode/requirements_dev.txt | 28 -
iotdb-core/mlnode/resources/conf/iotdb-mlnode.toml | 58 -
.../mlnode/resources/conf/logging_config.ini | 40 -
iotdb-core/mlnode/test/test_model_storage.py | 93 -
iotdb-core/mlnode/test/test_serde.py | 171 --
iotdb-core/node-commons/pom.xml | 311 +--
.../resources/conf/iotdb-common.properties | 122 +-
.../commons/auth/authorizer/BasicAuthorizer.java | 153 +-
.../iotdb/commons/auth/authorizer/IAuthorizer.java | 28 +-
.../commons/auth/authorizer/OpenIdAuthorizer.java | 2 +-
.../iotdb/commons/auth/entity/PathPrivilege.java | 152 +-
.../commons/auth/entity/PriPrivilegeType.java | 159 ++
.../iotdb/commons/auth/entity/PrivilegeType.java | 95 +-
.../org/apache/iotdb/commons/auth/entity/Role.java | 230 +-
.../org/apache/iotdb/commons/auth/entity/User.java | 171 +-
.../iotdb/commons/auth/role/BasicRoleManager.java | 174 +-
.../iotdb/commons/auth/role/IRoleAccessor.java | 9 +-
.../iotdb/commons/auth/role/IRoleManager.java | 19 +-
.../commons/auth/role/LocalFileRoleAccessor.java | 174 +-
.../commons/auth/role/LocalFileRoleManager.java | 7 +
.../iotdb/commons/auth/user/BasicUserManager.java | 232 +-
.../iotdb/commons/auth/user/IUserAccessor.java | 3 +
.../iotdb/commons/auth/user/IUserManager.java | 13 +-
.../commons/auth/user/LocalFileUserAccessor.java | 319 ++-
.../commons/auth/user/LocalFileUserManager.java | 6 +
.../apache/iotdb/commons/client/ThriftClient.java | 13 +-
.../async/AsyncConfigNodeIServiceClient.java | 6 +-
.../async/AsyncDataNodeInternalServiceClient.java | 6 +-
.../AsyncDataNodeMPPDataExchangeServiceClient.java | 6 +-
.../async/AsyncPipeDataTransferServiceClient.java | 6 +-
.../client/property/ThriftClientProperty.java | 3 +-
.../concurrent/ExceptionalCountDownLatch.java | 54 +
.../iotdb/commons/concurrent/ThreadName.java | 4 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 185 +-
.../iotdb/commons/conf/CommonDescriptor.java | 103 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 17 +-
.../commons/consensus/index/ProgressIndex.java | 148 +-
.../consensus/index/impl/HybridProgressIndex.java | 38 +-
.../consensus/index/impl/IoTProgressIndex.java | 19 +-
.../consensus/index/impl/MinimumProgressIndex.java | 20 +-
.../consensus/index/impl/RecoverProgressIndex.java | 22 +-
.../consensus/index/impl/SimpleProgressIndex.java | 11 +-
.../exception/IllegalPrivilegeException.java | 39 +
.../PipeRuntimeConnectorCriticalException.java | 6 +-
.../pipe/PipeRuntimeCriticalException.java | 5 -
.../exception/pipe/PipeRuntimeExceptionType.java | 5 +
.../pipe/PipeRuntimeNonCriticalException.java | 5 -
.../PipeRuntimeOutOfMemoryCriticalException.java | 100 +
.../runtime/UnSupportedDataTypeException.java | 31 -
.../commons/executable/ExecutableManager.java | 1 +
.../iotdb/commons/model/ModelHyperparameter.java | 81 -
.../iotdb/commons/model/ModelInformation.java | 288 ---
.../org/apache/iotdb/commons/model/ModelTable.java | 91 -
.../iotdb/commons/model/TrailInformation.java | 106 -
.../model/exception/ModelManagementException.java | 26 -
.../iotdb/commons/partition/DataPartition.java | 17 +-
.../iotdb/commons/partition/QueryExecutor.java | 6 +
.../org/apache/iotdb/commons/path/AlignedPath.java | 8 +-
.../apache/iotdb/commons/path/PathPatternNode.java | 6 +-
.../apache/iotdb/commons/path/PathPatternTree.java | 36 +-
.../apache/iotdb/commons/path/fa/FAFactory.java | 2 +-
.../apache/iotdb/commons/path/fa/dfa/DFAState.java | 6 +-
.../iotdb/commons/path/fa/dfa/PatternDFA.java | 63 +-
.../iotdb/commons/path/fa/dfa/graph/DFAGraph.java | 80 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 75 +-
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 42 +
.../plugin/builtin/connector/OpcUaConnector.java | 28 +
.../builtin/connector/WebSocketConnector.java | 28 +
.../builtin/connector/WriteBackConnector.java | 28 +
.../iotdb/commons/pipe/task/meta/PipeTaskMeta.java | 26 +-
.../iotdb/commons/schema/SchemaConstant.java | 18 +-
.../commons/schema/node/utils/IMNodeFactory.java | 3 +-
.../commons/schema/node/utils/IMNodeIterator.java | 2 +
.../commons/schema/tree/AbstractTreeVisitor.java | 50 +-
.../service/AbstractThriftServiceThread.java | 36 +
.../iotdb/commons/service/RegisterManager.java | 6 +
.../apache/iotdb/commons/service/ServiceType.java | 1 -
.../iotdb/commons/service/ThriftServiceThread.java | 28 +
.../service/metric/JvmGcMonitorMetrics.java | 35 +-
.../commons/service/metric/MetricService.java | 49 +
.../iotdb/commons/service/metric/enums/Metric.java | 41 +-
.../iotdb/commons/service/metric/enums/Tag.java | 4 +-
.../commons/udf/builtin/String/UDTFConcat.java | 63 +-
.../commons/udf/builtin/String/UDTFEndsWith.java | 20 +
.../commons/udf/builtin/String/UDTFLower.java | 23 +-
.../commons/udf/builtin/String/UDTFStartsWith.java | 36 +-
.../commons/udf/builtin/String/UDTFStrCompare.java | 40 +-
.../commons/udf/builtin/String/UDTFStrLength.java | 36 +-
.../commons/udf/builtin/String/UDTFStrLocate.java | 37 +-
.../iotdb/commons/udf/builtin/String/UDTFTrim.java | 36 +-
.../commons/udf/builtin/String/UDTFUpper.java | 23 +-
.../apache/iotdb/commons/udf/builtin/UDTFAbs.java | 85 +
.../iotdb/commons/udf/builtin/UDTFConst.java | 130 +-
.../iotdb/commons/udf/builtin/UDTFConstE.java | 34 +-
.../iotdb/commons/udf/builtin/UDTFConstPi.java | 34 +-
.../iotdb/commons/udf/builtin/UDTFContains.java | 36 +-
.../iotdb/commons/udf/builtin/UDTFInRange.java | 121 +-
.../iotdb/commons/udf/builtin/UDTFMatches.java | 35 +-
.../apache/iotdb/commons/udf/builtin/UDTFMath.java | 85 +
.../iotdb/commons/udf/builtin/UDTFOnOff.java | 85 +
.../commons/udf/utils/UDFDataTypeTransformer.java | 5 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 258 +-
.../iotdb/commons/utils/CommonDateTimeUtils.java | 15 +
.../org/apache/iotdb/commons/utils/IOUtils.java | 115 +-
.../apache/iotdb/commons/utils/NodeUrlUtils.java | 88 +-
.../iotdb/commons/utils/TimePartitionUtils.java | 79 +
.../iotdb/commons/path/PathPatternTreeTest.java | 9 +-
.../apache/iotdb/commons/path/PatternDFATest.java | 35 +-
.../iotdb/commons/pipe/PipeMetaDeSerTest.java | 6 +-
.../apache/iotdb/commons/utils/AuthUtilsTest.java | 203 ++
.../iotdb/commons/utils/NodeUrlUtilsTest.java | 33 +
iotdb-core/pom.xml | 3 +-
iotdb-core/tsfile/pom.xml | 193 +-
.../write/UnSupportedDataTypeException.java | 31 -
.../iotdb/tsfile/file/header/ChunkGroupHeader.java | 3 +
.../iotdb/tsfile/file/header/ChunkHeader.java | 50 +-
.../tsfile/file/metadata/AlignedChunkMetadata.java | 10 -
.../iotdb/tsfile/file/metadata/ChunkMetadata.java | 112 +-
.../iotdb/tsfile/file/metadata/IChunkMetadata.java | 2 -
.../tsfile/file/metadata/TimeseriesMetadata.java | 55 +-
.../iotdb/tsfile/file/metadata/TsFileMetadata.java | 31 -
.../tsfile/file/metadata/enums/TSDataType.java | 183 --
.../file/metadata/statistics/BinaryStatistics.java | 27 +-
.../metadata/statistics/BooleanStatistics.java | 17 +-
.../file/metadata/statistics/DoubleStatistics.java | 17 +-
.../file/metadata/statistics/FloatStatistics.java | 17 +-
.../metadata/statistics/IntegerStatistics.java | 17 +-
.../file/metadata/statistics/LongStatistics.java | 17 +-
.../file/metadata/statistics/Statistics.java | 18 +-
.../file/metadata/statistics/TimeStatistics.java | 16 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 30 +-
.../org/apache/iotdb/tsfile/read/common/Chunk.java | 28 +-
.../iotdb/tsfile/read/common/block/TsBlock.java | 66 +-
.../tsfile/read/common/block/TsBlockBuilder.java | 13 +-
.../read/common/block/TsBlockBuilderStatus.java | 78 -
.../block/column/Int32ArrayColumnEncoder.java | 20 +-
.../read/common/block/column/TsBlockSerde.java | 7 +-
.../iotdb/tsfile/read/filter/GroupByFilter.java | 5 +
.../tsfile/read/filter/GroupByMonthFilter.java | 183 +-
.../read/reader/chunk/AlignedChunkReader.java | 6 +-
.../tsfile/read/reader/page/AlignedPageReader.java | 206 +-
.../page/LazyLoadAlignedPagePointReader.java | 97 +
.../tsfile/read/reader/page/ValuePageReader.java | 131 +
.../read/reader/series/PaginationController.java | 8 +
.../java/org/apache/iotdb/tsfile/utils/Binary.java | 129 -
.../org/apache/iotdb/tsfile/utils/BloomFilter.java | 95 +-
.../org/apache/iotdb/tsfile/utils/BytesUtils.java | 4 +
.../apache/iotdb/tsfile/utils/FilePathUtils.java | 38 -
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 5 +
.../apache/iotdb/tsfile/utils/TimeDuration.java | 202 ++
.../iotdb/tsfile/utils/TsFileGeneratorUtils.java | 9 +-
.../tsfile/write/chunk/AlignedChunkWriterImpl.java | 5 +
.../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 5 +
.../iotdb/tsfile/write/chunk/IChunkWriter.java | 3 +
.../apache/iotdb/tsfile/write/record/Tablet.java | 6 +-
.../tsfile/write/record/datapoint/DataPoint.java | 4 +-
.../tsfile/write/writer/LocalTsFileOutput.java | 6 +
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 16 +-
.../iotdb/tsfile/write/writer/TsFileOutput.java | 3 +
.../common/block/RunLengthColumnEncoderTest.java | 5 +-
.../tsfile/common/block/TsBlockSerdeTest.java | 3 +-
.../iotdb/tsfile/common/block/TsBlockTest.java | 17 +-
.../encoding/decoder/DictionaryDecoderTest.java | 5 +-
.../metadata/statistics/StringStatisticsTest.java | 37 +-
.../tsfile/file/metadata/utils/TestHelper.java | 1 -
.../org/apache/iotdb/tsfile/read/ReadTest.java | 3 +-
.../iotdb/tsfile/read/TimePlainEncodeReadTest.java | 9 +-
.../apache/iotdb/tsfile/read/TsFileReaderTest.java | 2 +-
.../tsfile/read/TsFileSequenceReaderTest.java | 11 +-
.../iotdb/tsfile/read/common/ColumnTest.java | 4 +-
.../tsfile/read/filter/FilterSerializeTest.java | 18 +-
.../tsfile/read/filter/GroupByMonthFilterTest.java | 60 +-
.../iotdb/tsfile/read/filter/OperatorTest.java | 9 +-
.../read/query/executor/QueryExecutorTest.java | 3 +-
.../query/timegenerator/TimeGeneratorTest.java | 3 +-
.../reader/LazyLoadAlignedPagePointReaderTest.java | 177 ++
.../iotdb/tsfile/read/reader/PageReaderTest.java | 3 +-
.../org/apache/iotdb/tsfile/utils/RecordUtils.java | 2 +-
.../iotdb/tsfile/utils/TimeDurationTest.java | 67 +
.../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 2 +
.../iotdb/tsfile/utils/TsPrimitiveTypeTest.java | 8 +-
.../iotdb/tsfile/write/TsFileWriteApiTest.java | 5 +-
.../iotdb/tsfile/write/writer/PageWriterTest.java | 5 +-
.../write/writer/RestorableTsFileIOWriterTest.java | 37 +
.../tsfile/write/writer/TestTsFileOutput.java | 5 +
.../writer/TsFileIOWriterMemoryControlTest.java | 6 +-
iotdb-protocol/openapi/pom.xml | 104 +-
.../openapi/src/main/openapi3/iotdb_rest_v1.yaml | 52 +
.../openapi/src/main/openapi3/iotdb_rest_v2.yaml | 52 +
iotdb-protocol/pom.xml | 3 +-
iotdb-protocol/thrift-commons/pom.xml | 17 +-
.../thrift-commons/src/main/thrift/common.thrift | 24 +-
iotdb-protocol/thrift-confignode/pom.xml | 31 +-
.../src/main/thrift/confignode.thrift | 212 +-
iotdb-protocol/thrift-consensus/pom.xml | 31 +-
iotdb-protocol/thrift-datanode/pom.xml | 51 +-
.../thrift-datanode/src/main/thrift/client.thrift | 1 +
.../src/main/thrift/datanode.thrift | 116 +-
iotdb-protocol/thrift-mlnode/pom.xml | 66 -
.../thrift-mlnode/src/main/thrift/mlnode.thrift | 58 -
library-udf/pom.xml | 53 +-
library-udf/src/assembly/tools/register-UDF.bat | 4 +
library-udf/src/assembly/tools/register-UDF.sh | 4 +-
.../apache/iotdb/library/anomaly/UDTFRange.java | 9 +-
.../apache/iotdb/library/dprofile/UDTFSample.java | 8 +-
.../library/series/UDTFConsecutiveSequences.java | 23 +-
.../library/series/UDTFConsecutiveWindows.java | 23 +-
.../iotdb/library/series/util/ConsecutiveUtil.java | 23 +-
.../iotdb/library/string/UDTFRegexMatch.java | 44 +-
.../iotdb/library/string/UDTFRegexReplace.java | 46 +-
.../iotdb/library/string/UDTFRegexSplit.java | 64 +-
.../iotdb/library/string/UDTFStrReplace.java | 45 +-
pom.xml | 2599 +++++++++++++++-----
1667 files changed, 75556 insertions(+), 30131 deletions(-)
delete mode 100644 .github/workflows/iotdb-ml.yml
create mode 100644 .github/workflows/sonar-codecov.yml
delete mode 100644 .github/workflows/sonar-coveralls.yml
create mode 100644 .mvn/extensions.xml
create mode 100644 .mvn/gradle-enterprise.xml
create mode 100644 distribution/src/assembly/flink-sql-connector.xml
create mode 100644 example/flink-sql/pom.xml
create mode 100644 example/flink-sql/src/main/java/org/apache/iotdb/example/BatchSinkExample.java
create mode 100644 example/flink-sql/src/main/java/org/apache/iotdb/example/BoundedScanExample.java
create mode 100644 example/flink-sql/src/main/java/org/apache/iotdb/example/CDCExample.java
create mode 100644 example/flink-sql/src/main/java/org/apache/iotdb/example/LookupExample.java
create mode 100644 example/flink-sql/src/main/java/org/apache/iotdb/example/StreamingSinkExample.java
create mode 100644 example/pipe-count-point-processor/pom.xml
create mode 100644 example/pipe-count-point-processor/src/main/java/org/apache/iotdb/CountPointProcessor.java
create mode 100644 example/pipe-opc-ua-sink/pom.xml
create mode 100644 example/pipe-opc-ua-sink/src/main/java/org/apache/iotdb/opcua/ClientExample.java
create mode 100644 example/pipe-opc-ua-sink/src/main/java/org/apache/iotdb/opcua/ClientExampleRunner.java
create mode 100644 example/pipe-opc-ua-sink/src/main/java/org/apache/iotdb/opcua/ClientTest.java
create mode 100644 example/pipe-opc-ua-sink/src/main/java/org/apache/iotdb/opcua/IoTDBKeyStoreLoaderClient.java
create mode 100644 example/schema/pom.xml
create mode 100644 example/schema/src/main/java/org/apache/iotdb/schema/PathCheckExample.java
create mode 100644 integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/TwoSum.java
create mode 100644 integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/TwoSumBlock.java
create mode 100644 integration-test/src/main/java/org/apache/iotdb/it/framework/IoTDBTestConstants.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/it/framework/IoTDBTestListener.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBClusterAuthorityIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBAuthIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/IoTDBOrderByLimitOffsetAlignByDeviceIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQuery5IT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/auth/IoTDBAuthIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/auth/IoTDBClusterAuthorityIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/auth/IoTDBSeriesPermissionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/auth/IoTDBSystemPermissionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/auth/IoTDBTemplatePermissionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/fill/IoTDBFillWithThresholdInMSIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/fill/IoTDBFillWithThresholdInNSIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/fill/IoTDBFillWithThresholdInUSIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/groupby/IoTDBGroupByNaturalMonthNsPrecisionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/groupby/IoTDBGroupByNaturalMonthUsPrecisionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/metric/IoTDBMetricIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBClusterDeviceQuotaIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBClusterMeasurementQuotaIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/schema/quota/IoTDBClusterDeviceQuotaIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/schema/quota/IoTDBClusterMixQuotaIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/schema/quota/IoTDBClusterQuotaIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/schema/quota/IoTDBClusterTimeSeriesQuotaIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/strangepath/IoTDBStrangePathIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/udf/IoTDBUDFBlockQueryIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/flink/it/AbstractTest.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/flink/it/SinkTest.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/flink/it/SourceTest.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/flink/it/Utils.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/it/framework/IoTDBTestListener.java
rename integration-test/src/{main => test}/java/org/apache/iotdb/it/framework/IoTDBTestRunner.java (100%)
rename integration-test/src/{main => test}/java/org/apache/iotdb/it/framework/IoTDBTestRunnerWithParameters.java (100%)
rename integration-test/src/{main => test}/java/org/apache/iotdb/it/framework/IoTDBTestRunnerWithParametersFactory.java (100%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeClusterIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeConnectorParallelIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeLifeCycleIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeProtocolIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeSwitchStatusIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeSyntaxIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/pipe/it/extractor/IoTDBPipeExtractorIT.java
create mode 100644 iotdb-api/common-api/pom.xml
create mode 100644 iotdb-api/common-api/src/main/java/org/apache/iotdb/tsfile/exception/write/UnSupportedDataTypeException.java
create mode 100644 iotdb-api/common-api/src/main/java/org/apache/iotdb/tsfile/file/metadata/enums/TSDataType.java
create mode 100644 iotdb-api/common-api/src/main/java/org/apache/iotdb/tsfile/read/common/block/TsBlockBuilderStatus.java
rename {iotdb-core/tsfile => iotdb-api/common-api}/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/Column.java (100%)
rename {iotdb-core/tsfile => iotdb-api/common-api}/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/ColumnBuilder.java (100%)
rename {iotdb-core/tsfile => iotdb-api/common-api}/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/ColumnBuilderStatus.java (100%)
rename {iotdb-core/tsfile => iotdb-api/common-api}/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/ColumnEncoding.java (100%)
create mode 100644 iotdb-api/common-api/src/main/java/org/apache/iotdb/tsfile/utils/Binary.java
rename {iotdb-core/tsfile => iotdb-api/common-api}/src/main/java/org/apache/iotdb/tsfile/utils/TsPrimitiveType.java (100%)
create mode 100644 iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/PipeSink.java
create mode 100644 iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/PipeSource.java
create mode 100644 iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/configuration/PipeSinkRuntimeConfiguration.java
create mode 100644 iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/configuration/PipeSourceRuntimeConfiguration.java
create mode 100644 iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeSinkException.java
create mode 100644 iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/utils/RowImpl.java
create mode 100644 iotdb-client/client-py/resources/setup.py
delete mode 100644 iotdb-client/client-py/setup.py
create mode 100644 iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/UrlUtils.java
create mode 100644 iotdb-client/service-rpc/src/test/java/org/apache/iotdb/rpc/RpcUtilsTest.java
create mode 100644 iotdb-client/service-rpc/src/test/java/org/apache/iotdb/rpc/UrlUtilsTest.java
create mode 100644 iotdb-client/session/src/test/java/org/apache/iotdb/session/SessionConnectionTest.java
create mode 100644 iotdb-client/session/src/test/java/org/apache/iotdb/session/SessionTest.java
create mode 100644 iotdb-client/session/src/test/java/org/apache/iotdb/session/pool/SessionPoolExceptionTest.java
create mode 100644 iotdb-client/session/src/test/java/org/apache/iotdb/session/util/SessionUtilsTest.java
create mode 100644 iotdb-connector/flink-sql-iotdb-connector/pom.xml
create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/client/IoTDBWebSocketClient.java
create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/common/Options.java
create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/common/Utils.java
create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/IllegalIoTDBPathException.java
create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/IllegalOptionException.java
create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/IllegalSchemaException.java
create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/IllegalUrlPathException.java
create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/exception/UnsupportedDataTypeException.java
create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/factory/IoTDBDynamicTableFactory.java
create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/function/IoTDBBoundedScanFunction.java
create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/function/IoTDBCDCSourceFunction.java
create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/function/IoTDBLookupFunction.java
create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/function/IoTDBSinkFunction.java
create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/provider/IoTDBDynamicTableSink.java
create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/provider/IoTDBDynamicTableSource.java
create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/wrapper/SchemaWrapper.java
create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/java/org/apache/iotdb/flink/sql/wrapper/TabletWrapper.java
create mode 100644 iotdb-connector/flink-sql-iotdb-connector/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
create mode 100644 iotdb-connector/flink-tsfile-connector/src/test/resources/log4j.properties
delete mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/model/ShowModelPlan.java
delete mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/model/ShowTrailPlan.java
delete mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/model/CreateModelPlan.java
delete mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/model/DropModelPlan.java
delete mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/model/UpdateModelInfoPlan.java
delete mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/model/UpdateModelStatePlan.java
delete mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/ModelTableResp.java
delete mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/TrailTableResp.java
delete mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ModelManager.java
create mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/task/PipeTaskCoordinatorLock.java
delete mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/ModelInfo.java
delete mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/model/CreateModelProcedure.java
delete mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/model/DropModelProcedure.java
create mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/sync/AuthOperationProcedure.java
create mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/auth/AuthOperationProcedureState.java
delete mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/model/CreateModelState.java
delete mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/model/DropModelState.java
create mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/sync/AuthOperationProcedureTest.java
create mode 100644 iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/DiskGuardian.java
delete mode 100644 iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/utils/RatisLogMonitor.java
create mode 100644 iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/utils/Retriable.java
create mode 100644 iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/utils/RetryPolicy.java
create mode 100644 iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/ratis/DiskGuardianTest.java
delete mode 100644 iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/ratis/UtilsTest.java
create mode 100644 iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/ratis/utils/UtilsTest.java
create mode 100644 iotdb-core/datanode/src/assembly/resources/tools/tsfile/check-overlap-sequence-files-and-repair.bat
create mode 100644 iotdb-core/datanode/src/assembly/resources/tools/tsfile/check-overlap-sequence-files-and-repair.sh
create mode 100644 iotdb-core/datanode/src/assembly/resources/tools/tsfile/overlap-statistic-tool.bat
create mode 100644 iotdb-core/datanode/src/assembly/resources/tools/tsfile/overlap-statistic-tool.sh
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/auth/AuthorizerManager.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/IntoProcessException.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/LoadReadOnlyException.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/WriteLockFailedException.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/runtime/IntoProcessException.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/runtime/WriteLockFailedException.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/PipeConnectorConstructor.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/PipeExtractorConstructor.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/PipePluginConstructor.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/PipeProcessorConstructor.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/PipePeriodicalJobExecutor.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/airgap/AirGapELanguageConstant.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/opcua/OpcUaConnector.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/opcua/OpcUaKeyStoreLoader.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/opcua/OpcUaServerBuilder.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/websocket/WebSocketConnector.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/websocket/WebSocketConnectorServer.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/writeback/WriteBackConnector.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeAssignerMetrics.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeConnectorMetrics.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeEventCounter.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeExtractorMetrics.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeHeartbeatEventMetrics.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeMetrics.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeProcessorMetrics.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeResourceMetrics.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeWALInsertNodeCacheMetrics.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/memory/PipeMemoryBlock.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/resource/memory/PipeMemoryManager.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/connection/EnrichedDeque.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/client/MLNodeClient.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/impl/PingApiServiceImpl.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/utils/InsertRowDataUtils.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/RestClientSession.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/handler/MLNodeRPCServiceThriftHandler.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/IMLNodeRPCServiceWithHandler.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/MLNodeRPCServiceImpl.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/common/schematree/visitor/SchemaTreeDeviceUsingTemplateVisitor.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/TopKOperator.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/fill/IFillFilter.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/fill/filter/AbstractMonthIntervalFillFilter.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/fill/filter/FixedIntervalFillFilter.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/fill/filter/MonthIntervalMSFillFilter.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/fill/filter/MonthIntervalNSFillFilter.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/fill/filter/MonthIntervalUSFillFilter.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/last/LastQueryTransformOperator.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/model/CreateModelTask.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/model/DropModelTask.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/model/ShowModelsTask.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/model/ShowTrailsTask.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/RemoveRootPrefixVisitor.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/process/TopKNode.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/process/last/LastQueryTransformNode.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/AuthorityInformationStatement.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/CreatePipePluginStatement.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DropPipePluginStatement.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/ShowPipePluginsStatement.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/CreateModelStatement.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/DropModelStatement.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/ShowModelsStatement.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/ShowTrailsStatement.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/CreatePipePluginStatement.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/DropPipePluginStatement.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/ShowPipePluginsStatement.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/flush/PBTreeFlushExecutor.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/MLNodeRPCService.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/MLNodeRPCServiceMBean.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/metrics/file/CompactionFileMetrics.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/metrics/file/ModsFileMetrics.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/metrics/file/SystemRelatedFileMetrics.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/metrics/file/TsFileMetrics.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/metrics/file/WalFileMetrics.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/constant/CompactionValidationLevel.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/exception/CompactionRecoverException.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/exception/FileCannotTransitToCompactingException.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/task/CompactionTaskPriorityType.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/task/InsertionCrossSpaceCompactionTask.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/log/CompactionTaskStage.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/log/SimpleCompactionLogger.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/validator/CompactionValidator.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/validator/NoneCompactionValidator.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/validator/ResourceAndTsfileCompactionValidator.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/validator/ResourceOnlyCompactionValidator.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/schedule/CompactionScheduleSummary.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/estimator/CompactionTaskInfo.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/estimator/FastCrossSpaceCompactionEstimator.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/estimator/InplaceCompactionEstimator.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/estimator/ReadPointCrossCompactionEstimator.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/utils/DeviceInfo.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/utils/InsertionCrossCompactionTaskResource.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/utils/TsFileResourceCandidate.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tool/ITimeRange.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tool/Interval.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tool/ListTimeRangeImpl.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tool/OverlapStatistic.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tool/OverlapStatisticTool.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tool/PrintUtil.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tool/SequenceFileSubTaskThreadExecutor.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tool/SequenceFileTaskSummary.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tool/SingleSequenceFileTask.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tool/TimePartitionProcessTask.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tool/TimePartitionProcessWorker.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tool/TsFileStatisticReader.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tool/UnseqSpaceStatistics.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/TsFileID.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/TsFileResourceBlockType.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/TsFileResourceUtils.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/validate/TsFileResourceAndDataValidator.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/validate/TsFileResourceValidator.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/validate/TsFileValidator.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/validate/TsFileOverlapValidationAndRepairTool.java
delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/TimePartitionUtils.java
delete mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/qp/utils/DatetimeQueryDataSetUtilsTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/TopKOperatorTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/fill/filter/MonthIntervalFillFilterTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/schedule/queue/MultilevelPriorityQueueTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/plan/distribution/AlignByDeviceOrderByLimitOffsetTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/plan/distribution/DistributionPlannerCycleTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/plan/distribution/Util2.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/plan/node/PlanGraphPrinterTest.java
delete mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/buffer/TimeSeriesMetadataCacheTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/CompactionWorkerTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/FastCompactionPerformerWithEmptyPageTest.java
delete mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/MemoryControlTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/TsFileValidationCorrectnessTests.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/cross/InsertionCrossSpaceCompactionRecoverTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/cross/InsertionCrossSpaceCompactionSelectorTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/cross/InsertionCrossSpaceCompactionTest.java
delete mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/recover/RewriteCrossSpaceCompactionRecoverCompatibleTest.java
delete mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/recover/SizeTieredCompactionRecoverCompatibleTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tools/ListTimeRangeImplTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/tools/UnseqSpaceStatisticsTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/utils/CompactionUpdateFileCountTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/tools/TsFileOverlapValidationAndRepairToolTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/DateTimeUtilsTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/TimestampPrecisionUtilsTest.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/datastructure/MergeSortHeapTest.java
create mode 100644 iotdb-core/metrics/core/pom.xml
create mode 100644 iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/IoTDBMetricManager.java
create mode 100644 iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/reporter/IoTDBJmxReporter.java
create mode 100644 iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/type/IoTDBAutoGauge.java
create mode 100644 iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/type/IoTDBAutoGaugeMBean.java
create mode 100644 iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/type/IoTDBCounter.java
create mode 100644 iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/type/IoTDBCounterMBean.java
create mode 100644 iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/type/IoTDBGauge.java
create mode 100644 iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/type/IoTDBGaugeMBean.java
create mode 100644 iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/type/IoTDBHistogram.java
create mode 100644 iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/type/IoTDBHistogramMBean.java
create mode 100644 iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/type/IoTDBHistogramSnapshot.java
create mode 100644 iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/type/IoTDBRate.java
create mode 100644 iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/type/IoTDBRateMBean.java
create mode 100644 iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/type/IoTDBTimer.java
create mode 100644 iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/type/IoTDBTimerHistogramSnapshot.java
create mode 100644 iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/type/IoTDBTimerMBean.java
create mode 100644 iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/uitls/IoTDBCachedGauge.java
create mode 100644 iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/uitls/IoTDBCachedGaugeMBean.java
create mode 100644 iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/uitls/IoTDBMetricObjNameFactory.java
create mode 100644 iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/uitls/IoTDBMovingAverage.java
create mode 100644 iotdb-core/metrics/core/src/main/java/org/apache/iotdb/metrics/core/uitls/ObjectNameFactory.java
create mode 100644 iotdb-core/metrics/core/src/main/resources/META-INF/services/org.apache.iotdb.metrics.AbstractMetricManager
create mode 100644 iotdb-core/metrics/core/src/main/resources/META-INF/services/org.apache.iotdb.metrics.reporter.JmxReporter
delete mode 100644 iotdb-core/metrics/dropwizard-metrics/pom.xml
delete mode 100644 iotdb-core/metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/DropwizardMetricManager.java
delete mode 100644 iotdb-core/metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/DropwizardMetricNameTool.java
delete mode 100644 iotdb-core/metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter/DropwizardJmxReporter.java
delete mode 100644 iotdb-core/metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/type/DropwizardAutoGauge.java
delete mode 100644 iotdb-core/metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/type/DropwizardCounter.java
delete mode 100644 iotdb-core/metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/type/DropwizardGauge.java
delete mode 100644 iotdb-core/metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/type/DropwizardHistogram.java
delete mode 100644 iotdb-core/metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/type/DropwizardHistogramSnapshot.java
delete mode 100644 iotdb-core/metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/type/DropwizardRate.java
delete mode 100644 iotdb-core/metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/type/DropwizardTimer.java
delete mode 100644 iotdb-core/metrics/dropwizard-metrics/src/main/resources/META-INF/services/org.apache.iotdb.metrics.AbstractMetricManager
delete mode 100644 iotdb-core/metrics/dropwizard-metrics/src/main/resources/META-INF/services/org.apache.iotdb.metrics.reporter.JmxReporter
create mode 100644 iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/disk/DoNothingDiskMetricsManager.java
create mode 100644 iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/net/DoNothingNetMetricManager.java
create mode 100644 iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/AbstractMetricMBean.java
delete mode 100644 iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/MetricFrameType.java
delete mode 100644 iotdb-core/metrics/micrometer-metrics/pom.xml
delete mode 100644 iotdb-core/metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/MicrometerMetricManager.java
delete mode 100644 iotdb-core/metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/reporter/MicrometerJmxConfig.java
delete mode 100644 iotdb-core/metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/reporter/MicrometerJmxReporter.java
delete mode 100644 iotdb-core/metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/type/MicrometerAutoGauge.java
delete mode 100644 iotdb-core/metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/type/MicrometerCounter.java
delete mode 100644 iotdb-core/metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/type/MicrometerGauge.java
delete mode 100644 iotdb-core/metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/type/MicrometerHistogram.java
delete mode 100644 iotdb-core/metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/type/MicrometerHistogramSnapshot.java
delete mode 100644 iotdb-core/metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/type/MicrometerRate.java
delete mode 100644 iotdb-core/metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/type/MicrometerTimer.java
delete mode 100644 iotdb-core/metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/type/MicrometerTimerHistogramSnapshot.java
delete mode 100644 iotdb-core/metrics/micrometer-metrics/src/main/resources/META-INF/services/org.apache.iotdb.metrics.AbstractMetricManager
delete mode 100644 iotdb-core/metrics/micrometer-metrics/src/main/resources/META-INF/services/org.apache.iotdb.metrics.reporter.JmxReporter
delete mode 100644 iotdb-core/mlnode/.flake8
delete mode 100644 iotdb-core/mlnode/.gitignore
delete mode 100644 iotdb-core/mlnode/README.md
delete mode 100644 iotdb-core/mlnode/iotdb/__init__.py
delete mode 100644 iotdb-core/mlnode/iotdb/mlnode/__init__.py
delete mode 100644 iotdb-core/mlnode/iotdb/mlnode/client.py
delete mode 100644 iotdb-core/mlnode/iotdb/mlnode/config.py
delete mode 100644 iotdb-core/mlnode/iotdb/mlnode/constant.py
delete mode 100644 iotdb-core/mlnode/iotdb/mlnode/exception.py
delete mode 100644 iotdb-core/mlnode/iotdb/mlnode/handler.py
delete mode 100644 iotdb-core/mlnode/iotdb/mlnode/log.py
delete mode 100644 iotdb-core/mlnode/iotdb/mlnode/script.py
delete mode 100644 iotdb-core/mlnode/iotdb/mlnode/serde.py
delete mode 100644 iotdb-core/mlnode/iotdb/mlnode/service.py
delete mode 100644 iotdb-core/mlnode/iotdb/mlnode/storage.py
delete mode 100644 iotdb-core/mlnode/iotdb/mlnode/util.py
delete mode 100644 iotdb-core/mlnode/pom.xml
delete mode 100644 iotdb-core/mlnode/pyproject.toml
delete mode 100644 iotdb-core/mlnode/requirements.txt
delete mode 100644 iotdb-core/mlnode/requirements_dev.txt
delete mode 100644 iotdb-core/mlnode/resources/conf/iotdb-mlnode.toml
delete mode 100644 iotdb-core/mlnode/resources/conf/logging_config.ini
delete mode 100644 iotdb-core/mlnode/test/test_model_storage.py
delete mode 100644 iotdb-core/mlnode/test/test_serde.py
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/auth/entity/PriPrivilegeType.java
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/concurrent/ExceptionalCountDownLatch.java
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/IllegalPrivilegeException.java
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/pipe/PipeRuntimeOutOfMemoryCriticalException.java
delete mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/runtime/UnSupportedDataTypeException.java
delete mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/model/ModelHyperparameter.java
delete mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/model/ModelInformation.java
delete mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/model/ModelTable.java
delete mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/model/TrailInformation.java
delete mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/model/exception/ModelManagementException.java
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/OpcUaConnector.java
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/WebSocketConnector.java
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/WriteBackConnector.java
create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/TimePartitionUtils.java
create mode 100644 iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/utils/AuthUtilsTest.java
delete mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/exception/write/UnSupportedDataTypeException.java
delete mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/file/metadata/enums/TSDataType.java
delete mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/TsBlockBuilderStatus.java
create mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/page/LazyLoadAlignedPagePointReader.java
delete mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/utils/Binary.java
create mode 100644 iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/utils/TimeDuration.java
create mode 100644 iotdb-core/tsfile/src/test/java/org/apache/iotdb/tsfile/read/reader/LazyLoadAlignedPagePointReaderTest.java
create mode 100644 iotdb-core/tsfile/src/test/java/org/apache/iotdb/tsfile/utils/TimeDurationTest.java
delete mode 100644 iotdb-protocol/thrift-mlnode/pom.xml
delete mode 100644 iotdb-protocol/thrift-mlnode/src/main/thrift/mlnode.thrift