You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by gi...@apache.org on 2022/11/16 03:11:32 UTC
[iotdb] branch dependabot/maven/master/org.scalatest-scalatest_2.12-3.0.9 updated (d168ab3a5d -> bab95b54ac)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/maven/master/org.scalatest-scalatest_2.12-3.0.9
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard d168ab3a5d Bump scalatest_2.12 from 3.0.2 to 3.0.9
add cbf51cc26f Optimizing regex matching in Regexp (#7618)
add 26d6c9e265 [IOTDB-4658] Fix ConfigNode restart bug and add Cluster restart IT (#7623)
add c1c8fbaa77 Fix time unit in the ttl log (#7628)
add 0ebc42fd83 [IOTDB-4654] Fix concurrent bug caused by sharing same ChunkMetadata
add c912f937cd [IODB-4657] Fix PatternTreeMap#getOverlapped does not return correct values (#7625)
add a4fe367436 [IOTDB-4643] Add Unknown_DataNode_Detector (#7585)
add 53a436f93a Refactor IT classes and packages (#7626)
add d1358dd09f [IOTDB-4647] Fix CSV import error when import header name with type (#7600)
add 4eaa59103c [IOTDB-4650] Support starting reading from tail in RewriteTsFileTool (#7604)
add 5836e07d6d Add detailed error messages while query is time out (#7632)
add cf6d85062d [IOTDB-4656] Expose client retry configurations in RatisConsensus
add e18af3de47 update construct method of pendingBatch. (#7548)
add f33130b9fc [IOTDB-4653] add time precision units when setting TTL (#7639)
add dbef84905a [IOTDB-4649] Fix the problem that constants which have same valueString but different types can not be distinguished. (#7619)
add 08b6c1514b [IOTDB-4636] Add check to avoid flush empty chunk group (#7635)
add 2cb85a9286 [IOTDB-4636] Fix IndexOutOfBoundsException when compacting aligned series (#7638)
add aac98fec73 [IOTDB-3656] mpp load supports modification (#7354)
add 5b91cecdeb [IOTDB-4680] fix error msg "%s" in load statement (#7645)
add a078e88daa [IOTDB-4256] Implement analyzer for SELECT INTO statement (#7588)
add 79bfe4d123 [IOTDB-3462] Update ratis version to 2.4.0 (#7651)
add 1b71c37754 [IOTDB-4647] Fix CSV import error when import header name with type (#7636)
add 993782d2de [IOTDB-4679] Make MPPDataExchangeService use internal_address instead of rpc_address (#7648)
add a639c09875 Added changes and user docs to rpc sqls (#7633)
add 40779e48ad [IOTDB-4381] Implement Trigger fire process (#7355)
add 84aa99226a [IOTDB-4683] Fix REJECT_THERSHOLD init error in SystemInfo (#7649)
add 75d853837c [IOTDB-4250][IOTDB-4628] Support multiple pipes and update drop semantics (#7581)
add 127263dd3b [IOTDB-4627]Trigger transfer (#7643)
add f2ffb494a2 Perfect add/remove confignode process (#7656)
add 80dca5c7bb [IOTDB-4688] use streaming md5 computing to replace blocking md5
add b20f49525e [IOTDB-4689] Use seperate channel for heartbeat / appendEntries
add 88903b3189 Make default timeout parameter in SessionIT from 1s to 60s (#7647)
add fd8ced4f07 [IOTDB-4690] Add new configs for RatisConsensus (2.4.0)
add 723ecb42cf [IOTDB-4534] Add IT for Trigger Execution (#7657)
add 40571eb259 [IOTDB-4698]Implement interface of getLocationOfStatefulTrigger (#7663)
add d0d2ec30a8 Disable StandaloneMppIT (#7667)
add 66e01dfcfc [IOTDB-4699] Override peer's equals and hashcode
add a12f45e42e [IOTDB-4669] Scheduled task for checking trigger-table of DataNode (#7660)
add 8303f187b6 [IOTDB-4694] Make sure memTable snapshot is made before flush operation (#7662)
add e489286abe [github-7180] refactor seriesNumberMonitor and additional properties, cherry pick from rel/0.13 (#7661)
add 895ab3bc8c [IOTDB-4532] Add ITs for Trigger Management (#7671)
add d89fbfaa48 [IOTDB-4535] Chinese vesion of Trigger user doc (#7680)
add 63768fb039 Grafana plugin Modify pluginId and readme files (#7679)
add 22c07901f7 Disable the IT of the original standalone architecture (#7681)
add 3cfa037755 update website about release-0.13.3 (#7686)
add 0396163fcf [IOTDB-4685] Refactor ConfigNode Consensus heartbeat statistics (#7642)
add e6fb0a51d9 [IOTDB-4705] English version of Trigger user doc (#7688)
add aabb052dca [IOTDB-4711] Bind DataNodeInternalService to correct address (#7683)
add 30bf896095 [IOTDB-4706] Call Trigger.restore() when recovering trigger instances
add 81237589e8 New distribution package structure (#7672)
add d66d6445ed [IOTDB-4714] Rename TPipeInfo to TCreatePipeReq (#7692)
add 631fad8860 Fix schema region recover bug (#7696)
add 2fea01176c Bump flink.version from 1.14.5 to 1.14.6 (#7614)
add ca7b2b8311 [IOTDB-4641] New Standalone Sync Receiver TsFile Loader Implement (#7610)
add f9f9721969 [IOTDB-3562] Support Deactivate Template in cluster (#7674)
add 6101e132d6 [IOTDB-4293] BufferedPipeDataQueue supports discontinuous serialNumber (#7664)
add 083b241b84 Integrate dockerfile from rel/0.12, rel/0.13 (#7701)
add bcc9c3be79 [IOTDB-4712]Add size limit of trigger jar when create Trigger on ConfigNode (#7684)
add d913886a80 [IOTDB-4717] Refactor UDFRegistrationService for new Cluster (#7700)
add 22e0c55a27 Change previous IT from server module to integration-test (#7705)
add e9a5850eb4 Use 1c1d docker to run python and influxdb protocal IT (#7703)
add 6d4173ebb6 [IOTDB-4720] Refactor UDFExecutableManager for new UDF management
add fcfe89a51b [RatisConsensus] fix conf name
add cbc622573f [IOTDB-4664] add updatePeer interface in IConsensus (#7634)
add c416f43d6c Add MLogLoad-Tool document to website config (#7715)
add b0263f0c57 Update IoTDB nifi process doc (#7637)
add 2bcb19da0c [IOTDB-4678] Sync DataNode start-up process (#7691)
add fb6568790b [IOTDB-4692] SchemaFile adaptation for cluster metadata validation (#7658)
add eb051006ba Lowering Partition related logs' level (#7714)
add 6f27466c9a Use 1c1d docker to run go client IT (#7718)
add 82253fa242 [IOTDB-4734] Modify create function grammar and process (#7719)
add 8c2b803ce4 Rerun a new query execution thread while previous one is interrupted (#7722)
add 8a68f3a8ce [IOTDB-4751] Fix GROUP BY TAGS being without any error message (#7720)
add 531f8b3533 [IOTDB-4732] Optimize client borrow logic in ClusterIT environment (#7713)
add 5297117206 [IOTDB-4736] Refactor process of show functions (#7727)
add c69748d613 [IOTDB-4742] [Consensus] add new api: addNewNodeToExistedGroup (#7712)
add 55c1ea0edf [IOTDB-4721] Modify Create UDF process on ConfigNode (#7730)
add b268472003 [IOTDB-4756] Register UDF when restart/register DataNode
add ac8283a814 [IOTDB-4616] Support serialization and deserialization for confignode standalone mode (#7731)
add 3dda1ab202 [IOTDB-4757][IOTDB-4754]Fix concurrent register schema bug and show timeseries null element (#7728)
add 9f8bcc7692 [IOTDB-4651] Remove Predefined Metric Sets and Add MultiLeader metrics. (#7602)
add 3130ce9a5f [IOTDB-4660] Implement IntoOperator & ITs (#7665)
add da959a6f24 [IOTDB-4713] Log TException in ConfigNodeClient (#7729)
add 56ef925047 [IOTDB-4667] update the detailed usage method to the cpp-client readme doc (#7640)
add c26f6559e8 [IOTDB-4722][IOTDB-4723]modify Show & Drop UDF process on ConfigNode
add baed39decc [IOTDB-4693] Support broken tsfile rewrite (#7677)
add 89e5957683 Change AsyncDataNodeInternalServiceClient level from info to error and make it simple (#7747)
add dff3d3727e [IOTDB-4679] Unable to connect to iotdb in private-network using port-mapping (#7721)
add 0767935311 [IOTDB-4758]Delete snapshot after region migration (#7739)
add e259e26cd2 Ignore some old standalone style IT (#7753)
add 0fba3c55ef Update grafana dashboard (#7746)
add 8ff0b58ccb [IOTDB-4520] The tag schema region is implemented and supports the influxdb protocol (#7424)
add 72c8c18cd5 [IOTDB-4616] Support serialization and deserialization for confignode standalone mode (#7670)
add 43cbe3a2b8 [IOTDB-4631] [IOTDB-4777] Fixed the bug of concurrent DataNode deletion (#7744)
add fb1e23b574 [IOTDB-4633] Fix bugs of longToBytes in BytesUtils of tsfile (#7669)
add 4320baa030 [RatisConsensus] fix snapshot param mistake
add a78085d313 [IOTDB-4644] Support modifying DataNode's RPC IP:Port (#7620)
add f70343946d [IOTDB-4237] Add new wal node allocation strategy to reduce wal size (#7767)
add 62c707132d [IOTDB-4747][IOTDB-4776] Modify default write path of iotdb metric reporter (#7757)
add 6d1dff2421 [IOTDB-4779] Fix remove metrics in Metric Module (#7762)
add 2536fda09b [IOTDB-4718] Update user guide of SELECT INTO statement (#7771)
add 7980a76f2e [IOTDB-4773] new session cause memory-leak (#7752)
add 3648dbea7a [IOTDB-4774]Register/recover UDF when registering/restart a datanode (ConfigNode Process) (#7751)
add 576331b99b [IOTDB-4619] Support CQ in Cluster Mode (#7749)
add ebe53d1bd8 [IOTDB-4787] Make Using clause in CREATE FUNCTION optional (#7777)
add fb60f603fa [IOTDB-4790] Make error message of ASTVisitor more specific (#7781)
add 4800c36e01 [IOTDB-3562] Support Unset Template in cluster (#7735)
add c2ba3ae3d5 Add wait logic to ensure no data lost when remove a Peer from MultiLeader consensus group (#7759)
add ad570418ad [IOTDB-4341] Refactor LoadBalancing framework and maintain RegionRouteMap in RouteBalancer (#7766)
add 32f1674e11 [IOTDB-4737] Modify user doc of UDF && Trigger (#7782)
add 07210c64c8 [IOTDB-4788] Make Using clause in CREATE TRIGGER optional (#7780)
add 9d9ef04b5a [IOTDB-3976] Support Drop Schema Template in cluster (#7769)
add 69582de2b5 [IOTDB-4787] Make Using clause in CREATE FUNCTION optional (ConfigNode) (#7785)
add 8cdfa446d7 [IOTDB-4743] OperatePipeProcedure support rollback (#7750)
add af1a000c91 [IOTDB-4782] Fix systemMetrics in confignode (#7768)
add 2ca857db14 [IOTDB-3936]Add an interface in IClientRPCService to directly return bytebuffer instead of TSQueryDataSet
add a78b9c2ee5 [IOTDB-4750] Refactor the configuration file structure (#7779)
add 561a4aaf64 [IOTDB-4788] Make Using clause in CREATE TRIGGER optional (ConfigNode) (#7788)
add aaf595de63 [IOTDB-3397] Support Template Session and Add Session IT (#7789)
add 9fb49a57b9 [IOTDB-4793] Prevent compatibility problems in ConfigNode (#7784)
add 9e48049e54 [IOTDB-4710] Update Keyword list (#7790)
add 1f151ba1cf SELECT INTO: implement explain & ignore ORDER BY (#7794)
add 9cc5e9ee98 [IOTDB-4763]Implement snapshot of UDFInfo (#7760)
add ca844c043a [IOTDB-4728] Unify APIs in session and sessionPool (#7707)
add 50e0139e7d [IOTDB-4728] Unify APIs in session and sessionPool (#7707)
add 04aebce3ef [IOTDB-4750] Refactor the configuration name (#7796)
add 093ae53c23 remove Ignore of UDFManagementIT
add a77f7bb3db [IOTDB-4137][IOTDB-4799] Update sync-tool docs and print more detailed pipe information in show pipe (#7797)
add 1fb1bdb1d7 Add UT for CreateCQProcedure (#7793)
add 2e9fa3c91c [IOTDB-4796] Remove LoadStatistics consensus feature (#7799)
add bd907c0b79 [IOTDB-4741] [IOTDB-4767] Support fetching all connection info in Session & SessionPool (#7795)
add 8eaadfc497 Enable time partition by default (#7800)
add 76b947f56b Add built-in M4 UDF (#7755)
add a78cd55c89 Update download doc (#7801)
add 1e0f3300e0 Fix shell problem in start-confignode.sh/bat and start-datanode.sh/bat (#7811)
add caca66ada7 [IOTDB-2884]Redo Log for SchemaFile (#7726)
add 0e843a7614 Rename mpprest to rest (#7804)
add 21963788ad [IOTDB-4719] SchemaFile adaptation for cluster delete timeseries (#7709)
add a2ccdeb91d [IOTDB-4652] Add retry logic of borrow client in MultiLeaderImpl (#7741)
add 021056c1bd [IOTDB-4802] Optimize the logical plan of query with only time filter (#7805)
add 8f78e26799 Fix IoTDBConfigNodeSnapshotIT.testCreateUDF
add 2ee98de984 [IOTDB-4797] Supplement and improve the metedata plannode tostring function (#7786)
add a3df3a1b14 Rename time_partition to time_partition_interval_for_storage in system.properties file (#7810)
add c034d4cbce [IOTDB-4142] Add delete generated file logic in pom of antlr (#7820)
add 1b1d9bffad Unify thread number configurations to thread_count && Fix clusterIT NPE (#7817)
add 773c963a15 [IOTDB-4806] Add size limit of UDF jar when create UDF on ConfigNode
add b023bb390c [IOTDB-4744] Fix schema register validation bug (#7816)
add a12f66885e fix ConfigNodeSnapshotIT
add 0460a054a1 fix client bug during deactivate template (#7833)
add 07bdbddf16 [IOTDB-4810] Fix print-tsfile-sketch.bat bug when reading measurementID containing Chinese (#7831)
add 952ffcf87d [IOTDB-4527] [IOTDB-4748] Make IoTDB-SQL syntax more flexible (#7806)
add 6e089fb200 Add docs for udf accuracy (#7824)
add b8a20c4078 Change log level of some messages from INFO to DEBUG (#7834)
add 521f9b5f8e [IOTDB-4738]TsFile damaged after writing empty value pages (#7827)
add 60133208c7 Bump actions/first-interaction from 1.1.0 to 1.1.1 (#7836)
add bc0e88b878 [IOTDB-4695] GROUP LEVEL query de-duplicates result columns unexpected (#7736)
add 6485242274 fix doc typo (#7850)
add cfe0fcfa07 Transfer IoTDBQueryWithRecreatedTimeseriesIT (#7851)
add 36c32c7347 Modify default path of iotdb metric reporter (#7819)
add 954a33f9e1 Rename StandAloneConsensus to OneCopyConsensus (#7832)
add 27c0d99eb2 Bump jetty.version from 9.4.48.v20220622 to 9.4.49.v20220914 (#7837)
add 3ee59e33cb Bump reactor-netty-http from 1.0.4 to 1.0.24 (#7838)
add 426d9344a1 remove (#7856)
add 4efeabeb21 [IOTDB-4791] Optimize the endFile in `TsFileIOWriter` (#7826)
add 3904afce17 [IOTDB-4822]Migrate Query tests to the new IT framework
add 933d51bf04 Fix conflicts in path constructor (#7859)
add d7b2fc48ac Change log level (#7861)
add 520467804c Update IoTDBSessionAlignedInsertIT.java (#7857)
add 3ab613f854 [IOTDB-3149] There is a difference between adding ** path and without a path to list user privileges (#7808)
add 2407a5ae65 [IOTDB-4230] add -p pid, -v version feature into start-server.sh (#7802)
add 267ab13524 Fix isBlocked bug of schema query (#7862)
add 2d9dd5be83 [IOTDB-4814] Using 1C1D as the default mode in integration test (#7855)
add 388c988eb4 [IOTDB-4230]fix start-cli.sh does not support -e (#7866)
add b419918d50 Change log level (#7868)
add 09e256656f Change to Debug level (#7871)
add 6823e6ec57 Add debug level judgement firstly (#7872)
add ff5b62f113 init (#7863)
add b73f8d07a2 Rename iotdb-engine.properties to iotdb-datanode.properties in UTs (#7869)
add dbfacd9c1c [IOTDB-4616] Add conf for ConfigNode OneCopy protocol (#7815)
add 37a0423f24 Hide all SchemaFile options in config file (#7867)
add 78a6b10226 [IOTDB-4801] rewrite UT PipeDataTest & BufferedPipeDataQueueTest
add 71c55e9abd Complete document of Data Write chapter and add ways of loading (#7876)
add 2c1b4e93ce Rename OneCopyConsensus to SimpleConsensus (#7882)
add 695dd65fc7 [IOTDB-3773] [IOTDB-4831] Optimize the rpc call numbers in query processing & make query cost time print more accurate (#7875)
add bc96c312dd Rename and simplify cluster IT actions (#7873)
add 9d0a312585 [IOTDB-4828] Implement TestOnly RPC interface setDataNodeStatus (#7877)
add 5874879e54 [IOTDB-4824] Fix error when insert a null value into a non-existed timeseries (#7884)
add 0c34ee1d9c add: define a constant instead load manager metrics. (#7835)
add 3badb017a9 [IOTDB-4813] Update the doc of metric module and grafana dashboard (#7883)
add 5a448c6e21 [IOTDB-4842] Fix type infer error when insert a large number (#7887)
add ae83e89676 [IOTDB-4616] Support snapshot serialization and deserialization for confignode standalone mode (#7874)
add 617fd5ad99 Upgrade github action version (#7890)
add 9663127db1 [IOTDB-4821]Move settleIT (#7853)
add f857667c9d [IOTDB-4597] add option to set query timeout in Cli
add a9858c9e2c Disable compiling library-udf by default when package distribution (#7896)
add 876564ddc1 [IOTDB-4778][IOTDB-4031][IOTDB-4764][IOTDB-4514] restServer module adaptation and optimization (#7897)
add 31f8eeec26 Bump caffeine from 2.9.1 to 2.9.3 (#7615)
add 1dd2e47c59 [IOTDB-4827][IOTDB-4840] Adaptation and fix mlog logic for for cluster template (#7885)
add b0f68c5801 [IOTDB-4800] [Rewrite UT] Rewrite some UT in compaction module
add 2c8f898988 [IOTDB-4826] Move some IT to integration-test (#7891)
add 37a40629c5 Fix shell scripts in tools and change -b to -d (#7905)
add 62edbd431a [IOTDB-4769] When modifying an alias, you need to add back quotes when the alias is a special character. (#7745)
add 2ef642275c Adjusted location of trigger section, added an example of REST API (#7906)
add 8d0c685b07 Improve query performance (#7894)
add b135ebdeca [IOTDB-4848] fix Bug: TimeSeries cannot be used in logical operator
add 5dd8d88103 Bump reload4j from 1.2.19 to 1.2.22 (#7892)
add f58cc6c223 Add a function quantile in UDF library (#7912)
add abbb45b891 Adjust configuration files (#7909)
add 96c860f876 [IOTDB-4807] Check nodes' status at the INVALIDATE_CACHE state (#7895)
add 95fa01f4fe Update client-go commit to fix CI
add 523e82a437 Fixed the bugs of shell (#7910)
add 24d99ef5d3 [IOTDB-4829] Let NoMoreTsBlockEvent RPC is called in async way (#7911)
add 1b1c57b6d8 [IOTDB-4857] Fix the problem when remove-datanode for ratis 1 replica (#7917)
add 0a9259f489 [IOTDB-4861] Show DataNodes' Internal Address:Port when executing show cluster (#7920)
add 2f9123bc00 [IOTDB-4846][IOTDB-4053] Fix docs and error msg (#7919)
add c8b50b8938 use cached thread pool to accelerate short-lived asynchronous tasks (#7870)
add 3734242d57 [IOTDB-4632] Fix Ratis time out when registering timeseries with each request taking huge measurements (#7913)
add 3e86379d82 [IOTDB-4681] speed up mpp load (#7725)
add cb74d4983d [IOTDB-4673]Removes the space character from both the start and the end of the parameter value (#7921)
add 1f8085c65d [IOTDB-4768] Balancing cluster RegionGroup leader distribution by MinimumCostFlow algorithm (#7774)
add c17c0479ef [IOTDB-4866] Fix schema tree bug when append nested device (#7925)
add f67a8c28d8 Chapter-adjustment (#7922)
add 6abecabfad fix the NPE when addPeer to a MultiLeader Group with 1 replic (#7927)
add bbc910b087 [IOTDB-4868] Drop trigger should fail when trigger.OnDrop throws an exception (#7928)
add 91d475c9b8 Add class which are inspired by Trino into LICENSE (#7926)
add 14cd9c4666 [IOTDB-4871] Only call restore method for stateful trigger
add 7e16003793 Rollback modification of FrangmentInstanceDispatherImpl.dispatchWriteSync (#7933)
add cec66b62f5 Use CAS way to reserve memory (#7939)
add ebad1dd5bf Grafana plugin code optimization (#7934)
add c29f46ac03 Change initBeforeClass to initBeforeTest (#7938)
add 9c271753fd fix: submodule url (#7940)
add fe0fa38d8a [IOTDB-4880] Fix memory leak in query (#7937)
add f4e73491f1 cleanup spotless workaround code and doc (#7942)
add ff2541bf6b [IOTDB-4865] Cluster tool — show cluster details (#7935)
add 939bc592aa Remove old storage engine code and refactor UTs (#7932)
add 87a416e6d2 [IOTDB-4666]Get the devices on one leaf node at a time while compacting (#7646)
add 9ac112433e [IOTDB-4576]Add NULL Operand and modify operations about it & Use False if the series in the predicate does not exist (#7924)
add 072835c94a [IOTDB-4819] Record concrete failure info in FI State and pass it to client
add 2c5f012540 [IOTDB-4745] Add ADD_NEW_NODE state for ConfigNodeProcedure (#7743)
add c04d3fa9cc [IOTDB-4835] Fix InnerSpaceCompaction may be blocked (#7901)
add 887e49fb2b optimize transfer leader implementation (#7923)
add b22ed4b4ad [IOTDB-4811]Fix snapshot file name error (#7900)
add 05633d6e8c [IOTDB-4894] Fix bug that TsFileSketchTool prints only the first page info when there are multiple pages in a chunk (#7955)
add a5d6e97259 [IOTDB-4726]show cluster return with msg: 500 null (#7952)
add 9f9975eac5 [IOTDB-4876] Fix PathPatternTree missing information on subpaths (#7943)
add 7bc44b5db6 [IOTDB-4753] Error serialized data size in TsFileData (#7953)
add fa4613221a Bump swagger-jersey2-jaxrs from 1.5.18 to 1.5.24 (#7893)
add 43cc564aa5 [IOTDB-4558] Use insertRowsOfOneDevice to execute insert multi rows sql statement (#7918)
add 1bd98662c2 [IOTDB-4887] Tidy the UDF and Trigger folders (#7945)
add c1dafdd072 [IOTDB-4851] Perfect ChangeLeader method in RegionMigrateProcedure (#7948)
add 487b3edc16 [IOTDB-4784] Control total memory for enabling time partition for storage engine (#7792)
add 18fc3f391e [IOTDB-4771]BufferedPipeDataQueueTest.testOfferWhileTakingWithDiscontinuousSerialNumber fail (#7954)
add 6a85f6c60c [IOTDB-4838] Adapt SchemaRegionSchemaFileImpl's recovery to Ratis. (#7936)
add 3614ca7899 Remove old storage engine step two (#7959)
add 5e5de92c6c Remove the entry of setting tsfile size (#7962)
add 44c090592b [ISSUE-7941] Fix NumberFormatException when JDK version is 17-internal (#7947)
add 6dcd5a59d5 Fix the problem in greedySelectLeader (#7964)
add 600e376bce [IOTDB-4908] Clear deprecated code related to sync in old standalone (#7965)
add f9c46222b7 [IOTDB-4789]Fix the bug of termination timing log can not be logged (#7775)
add bdf0398436 rename PartitionRegion to ConfigNodeRegion (#7970)
add e4779618c4 [IOTDB-4913] Fix NPE when insert multi rows with null by sql (#7967)
add 665242103d [IOTDB-4891] Rename storage group to database (#7946)
add ee3319e634 [IOTDB-4772][IOTDB-4402] Avoid multiple IoTDB processes accessing same dir (#7562)
add 747786133b Remove redundant isMppMode configuration (#7974)
add 34524ba5db [IOTDB-4920] Fixed the bug that show cluster returns wrong answer
add 2c9c03aa66 [IOTDB-4849] Fix the problem that internal_address is not consistent with target_confignode when first starts Seed-ConfigNode. (#7975)
add 5596e7ccf0 [IOTDB-4922] Support auth in create & drop trigger (#7980)
add 2ffcaefe39 Rename storage group to database in sync module (#7972)
add 4f22e14a22 [IOTDB-4601] Add configuration to close swagger (#7966)
add 89268825f8 [IOTDB-4875][IOTDB-4918] Fix timeseries creation check bug (#7987)
add 09ab7fae87 Resolve some TODO in ITs (#7981)
add e46df71015 [IOTDB-4896] Fix error in closing a TsFileProcessor with an empty memtable (#7971)
add ba7814d6ac Rename storage_groups dir name to databases (#7990)
add 8d9a021da6 [IOTDB-3831] Fix TTL doesn't take effect in last query (#7988)
add 058ca73097 [IOTDB-4921]Add auth check to deactivate and unset and drop template (#7994)
add 4f65f89698 [IOTDB-4941] Prevent compatibility problems in PipeData (#7996)
add d3d50e49bf [IOTDB-4893] modify the data type check of IN operation (#7979)
add a46e565a5d [IOTDB-4704] Modified sync data node retry wait (#7982)
add 7f01748284 [IOTDB-4942] Only checkDirectory when start DataNode (#7999)
add 917c8cff42 [IOTDB-4901][IOTDB-4860] Fix concurrent auto create schema bug (#7993)
add 8b5d429ea7 [IOTDB-4900] Add check for URI when create Trigger/UDF (#8000)
add 37c2792ab8 [IOTDB-4823] Adjust maxRegionGroupCount failed because StorageGroup doesn't exist (#7984)
add bab95b54ac Bump scalatest_2.12 from 3.0.2 to 3.0.9
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (d168ab3a5d)
\
N -- N -- N refs/heads/dependabot/maven/master/org.scalatest-scalatest_2.12-3.0.9 (bab95b54ac)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.dockerignore | 1 +
.github/dependabot.yml | 52 -
.github/workflows/client-cpp.yml | 14 +-
.github/workflows/client-go.yml | 9 +-
.github/workflows/client-python.yml | 9 +-
.github/workflows/cluster-it-1c1d.yml | 85 +
.github/workflows/cluster-it-1c3d.yml | 80 +
.github/workflows/cluster-it.yml | 79 -
.github/workflows/e2e.yml | 4 +-
.github/workflows/grafana-plugin.yml | 12 +-
.github/workflows/greetings.yml | 2 +-
.github/workflows/influxdb-protocol.yml | 9 +-
.github/workflows/main-unix.yml | 14 +-
.github/workflows/main-win.yml | 11 +-
.github/workflows/sonar-coveralls.yml | 33 +-
.github/workflows/standalone-it-for-mpp.yml | 81 -
.github/workflows/sync.yml | 7 +-
.gitignore | 2 +
.gitmodules | 4 +-
LICENSE | 15 +-
README.md | 19 +-
README_ZH.md | 29 +-
antlr/pom.xml | 17 +
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 24 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 127 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 42 +-
cli/src/assembly/resources/conf/logback-cli.xml | 32 +
cli/src/assembly/resources/sbin/start-cli.sh | 118 +-
cli/src/assembly/resources/tools/export-csv.sh | 7 +
cli/src/assembly/resources/tools/export-tsfile.sh | 7 +
cli/src/assembly/resources/tools/import-csv.sh | 7 +
.../java/org/apache/iotdb/cli/AbstractCli.java | 32 +-
cli/src/main/java/org/apache/iotdb/cli/Cli.java | 5 +
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 24 +-
.../org/apache/iotdb/cli/StartClientScriptIT.java | 3 +
client-cpp/README.md | 41 +-
client-go | 2 +-
client-py/README.md | 12 +-
client-py/SessionAlignedTimeseriesExample.py | 4 +-
client-py/SessionExample.py | 4 +-
client-py/iotdb/Session.py | 16 +-
client-py/iotdb/dbapi/tests/test_cursor.py | 8 +-
client-py/iotdb/sqlalchemy/IoTDBDialect.py | 2 +-
client-py/iotdb/sqlalchemy/tests/test_dialect.py | 8 +-
client-py/requirements.txt | 4 +-
client-py/setup.py | 2 +-
client-py/tests/test_aligned_timeseries.py | 6 +-
client-py/tests/test_dataframe.py | 20 +-
client-py/tests/test_one_device.py | 2 +-
client-py/tests/test_session.py | 6 +-
client-py/tests/test_tablet.py | 4 +-
client-py/tests/test_template.py | 127 +-
client-py/tests/test_todf.py | 6 +-
confignode/pom.xml | 5 +
confignode/src/assembly/confignode.xml | 18 +-
.../src/assembly/resources/conf/confignode-env.bat | 27 +-
.../src/assembly/resources/conf/confignode-env.sh | 10 +
.../resources/conf/iotdb-confignode.properties | 361 +---
.../assembly/resources/conf/logback-confignode.xml | 140 ++
.../src/assembly/resources/conf/logback-tool.xml | 16 +-
confignode/src/assembly/resources/conf/logback.xml | 140 --
.../assembly/resources/sbin/remove-confignode.bat | 2 +-
.../assembly/resources/sbin/remove-confignode.sh | 59 +-
.../assembly/resources/sbin/start-confignode.bat | 43 +-
.../assembly/resources/sbin/start-confignode.sh | 169 +-
.../assembly/resources/sbin/stop-confignode.bat | 13 +-
.../src/assembly/resources/sbin/stop-confignode.sh | 10 +-
.../confignode/client/ConfigNodeRequestType.java | 2 +-
.../confignode/client/DataNodeRequestType.java | 14 +-
.../client/async/AsyncDataNodeClientPool.java | 89 +-
.../client/async/handlers/AsyncClientHandler.java | 35 +-
.../heartbeat/ConfigNodeHeartbeatHandler.java | 4 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 55 +-
.../rpc/CountPathsUsingTemplateRPCHandler.java | 87 +
.../async/handlers/rpc/DeleteSchemaRPCHandler.java | 84 +
.../handlers/rpc/DeleteTimeSeriesRPCHandler.java | 84 -
.../async/handlers/rpc/OperatePipeRPCHandler.java | 60 +
.../client/sync/SyncConfigNodeClientPool.java | 5 +-
.../client/sync/SyncDataNodeClientPool.java | 116 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 438 ++++-
.../iotdb/confignode/conf/ConfigNodeConstant.java | 10 +-
.../confignode/conf/ConfigNodeDescriptor.java | 798 +++++---
.../confignode/conf/ConfigNodeRemoveCheck.java | 6 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 22 +-
.../confignode/conf/SystemPropertiesUtils.java | 48 +-
.../consensus/request/ConfigPhysicalPlan.java | 248 ++-
.../consensus/request/ConfigPhysicalPlanType.java | 210 +-
.../consensus/request/auth/AuthorPlan.java | 41 +-
.../request/read/CountStorageGroupPlan.java | 88 -
.../request/read/GetDataNodeConfigurationPlan.java | 70 -
.../request/read/GetDataPartitionPlan.java | 133 --
.../request/read/GetNodePathsPartitionPlan.java | 85 -
.../request/read/GetOrCreateDataPartitionPlan.java | 52 -
.../read/GetOrCreateSchemaPartitionPlan.java | 37 -
.../request/read/GetRegionInfoListPlan.java | 84 -
.../consensus/request/read/GetRoutingPlan.java | 112 --
.../request/read/GetSchemaPartitionPlan.java | 106 -
.../request/read/GetSeriesSlotListPlan.java | 84 -
.../request/read/GetStorageGroupPlan.java | 34 -
.../request/read/GetTimeSlotListPlan.java | 109 --
.../consensus/request/read/GetTriggerJarPlan.java | 68 -
.../request/read/GetTriggerTablePlan.java | 42 -
.../datanode/GetDataNodeConfigurationPlan.java | 70 +
.../read/function/GetFunctionTablePlan.java | 42 +
.../read/partition/GetDataPartitionPlan.java | 133 ++
.../read/partition/GetNodePathsPartitionPlan.java | 85 +
.../partition/GetOrCreateDataPartitionPlan.java | 52 +
.../partition/GetOrCreateSchemaPartitionPlan.java | 37 +
.../read/partition/GetSchemaPartitionPlan.java | 106 +
.../read/partition/GetSeriesSlotListPlan.java | 84 +
.../read/partition/GetTimeSlotListPlan.java | 109 ++
.../request/read/region/GetRegionIdPlan.java | 112 ++
.../request/read/region/GetRegionInfoListPlan.java | 84 +
.../read/storagegroup/CountStorageGroupPlan.java | 88 +
.../read/storagegroup/GetStorageGroupPlan.java | 34 +
.../read/template/CheckTemplateSettablePlan.java | 2 +-
.../read/template/GetAllSchemaTemplatePlan.java | 2 +-
.../read/template/GetAllTemplateSetInfoPlan.java | 2 +-
.../read/template/GetPathsSetTemplatePlan.java | 2 +-
.../read/template/GetSchemaTemplatePlan.java | 2 +-
.../read/template/GetTemplateSetInfoPlan.java | 68 +
.../read/trigger/GetTransferringTriggersPlan.java | 42 +
.../request/read/trigger/GetTriggerJarPlan.java | 68 +
.../read/trigger/GetTriggerLocationPlan.java | 62 +
.../request/read/trigger/GetTriggerTablePlan.java | 62 +
.../consensus/request/read/udf/GetUDFJarPlan.java | 68 +
.../request/write/CreateFunctionPlan.java | 86 -
.../request/write/DeleteProcedurePlan.java | 69 -
.../consensus/request/write/DropFunctionPlan.java | 57 -
.../request/write/RegisterDataNodePlan.java | 71 -
.../request/write/RemoveDataNodePlan.java | 96 -
.../request/write/UpdateProcedurePlan.java | 74 -
.../request/write/UpdateRegionLocationPlan.java | 86 -
.../write/confignode/ApplyConfigNodePlan.java | 2 +-
.../write/confignode/RemoveConfigNodePlan.java | 2 +-
.../consensus/request/write/cq/ActiveCQPlan.java | 85 +
.../consensus/request/write/cq/AddCQPlan.java | 98 +
.../consensus/request/write/cq/DropCQPlan.java | 93 +
.../consensus/request/write/cq/ShowCQPlan.java | 42 +
.../request/write/cq/UpdateCQLastExecTimePlan.java | 95 +
.../write/datanode/RegisterDataNodePlan.java | 71 +
.../request/write/datanode/RemoveDataNodePlan.java | 83 +
.../request/write/datanode/UpdateDataNodePlan.java | 71 +
.../request/write/function/CreateFunctionPlan.java | 76 +
.../request/write/function/DropFunctionPlan.java | 57 +
.../write/partition/CreateDataPartitionPlan.java | 2 +-
.../write/partition/CreateSchemaPartitionPlan.java | 2 +-
.../write/partition/UpdateRegionLocationPlan.java | 86 +
.../write/procedure/DeleteProcedurePlan.java | 69 +
.../write/procedure/UpdateProcedurePlan.java | 79 +
.../write/region/CreateRegionGroupsPlan.java | 6 +-
.../write/region/OfferRegionMaintainTasksPlan.java | 4 +-
.../write/region/PollRegionMaintainTaskPlan.java | 2 +-
.../AdjustMaxRegionGroupCountPlan.java | 2 +-
.../write/storagegroup/DeleteStorageGroupPlan.java | 2 +-
.../storagegroup/PreDeleteStorageGroupPlan.java | 2 +-
.../storagegroup/SetDataReplicationFactorPlan.java | 2 +-
.../SetSchemaReplicationFactorPlan.java | 2 +-
.../write/storagegroup/SetStorageGroupPlan.java | 2 +-
.../request/write/storagegroup/SetTTLPlan.java | 2 +-
.../storagegroup/SetTimePartitionIntervalPlan.java | 2 +-
.../request/write/sync/CreatePipeSinkPlan.java | 2 +-
.../consensus/request/write/sync/DropPipePlan.java | 56 +
.../request/write/sync/DropPipeSinkPlan.java | 2 +-
.../request/write/sync/GetPipeSinkPlan.java | 2 +-
.../request/write/sync/PreCreatePipePlan.java | 2 +-
.../request/write/sync/SetPipeStatusPlan.java | 2 +-
.../consensus/request/write/sync/ShowPipePlan.java | 2 +-
.../write/template/CreateSchemaTemplatePlan.java | 2 +-
.../write/template/DropSchemaTemplatePlan.java | 57 +
.../write/template/PreUnsetSchemaTemplatePlan.java | 67 +
.../RollbackPreUnsetSchemaTemplatePlan.java | 67 +
.../write/template/SetSchemaTemplatePlan.java | 2 +-
.../write/template/UnsetSchemaTemplatePlan.java | 67 +
.../write/trigger/AddTriggerInTablePlan.java | 2 +-
.../write/trigger/DeleteTriggerInTablePlan.java | 2 +-
.../write/trigger/UpdateTriggerLocationPlan.java | 76 +
.../trigger/UpdateTriggerStateInTablePlan.java | 2 +-
.../trigger/UpdateTriggersOnTransferNodesPlan.java | 75 +
.../consensus/response/DataNodeRegisterResp.java | 17 +-
.../consensus/response/FunctionTableResp.java | 70 +
.../consensus/response/GetRegionIdResp.java | 59 +
.../consensus/response/GetRoutingResp.java | 59 -
.../confignode/consensus/response/JarResp.java | 52 +
.../confignode/consensus/response/ShowCQResp.java | 55 +
.../consensus/response/TemplateSetInfoResp.java | 53 +
.../response/TransferringTriggersResp.java | 43 +
.../consensus/response/TriggerJarResp.java | 52 -
.../consensus/response/TriggerLocationResp.java | 49 +
.../statemachine/ConfigNodeRegionStateMachine.java | 369 ++++
.../statemachine/PartitionRegionStateMachine.java | 209 --
.../confignode/manager/ClusterSchemaManager.java | 140 +-
.../iotdb/confignode/manager/ConfigManager.java | 337 +++-
.../iotdb/confignode/manager/ConsensusManager.java | 223 ++-
.../apache/iotdb/confignode/manager/IManager.java | 105 +-
.../iotdb/confignode/manager/ProcedureManager.java | 167 +-
.../iotdb/confignode/manager/SyncManager.java | 123 +-
.../iotdb/confignode/manager/TriggerManager.java | 150 +-
.../iotdb/confignode/manager/UDFManager.java | 163 +-
.../iotdb/confignode/manager/cq/CQManager.java | 186 ++
.../confignode/manager/cq/CQScheduleTask.java | 276 +++
.../iotdb/confignode/manager/load/LoadManager.java | 192 +-
.../manager/load/LoadManagerMetrics.java | 22 +-
.../manager/load/balancer/RouteBalancer.java | 382 +++-
.../manager/load/balancer/router/IRouter.java | 6 +-
.../load/balancer/router/LazyGreedyRouter.java | 159 --
.../manager/load/balancer/router/LeaderRouter.java | 36 +-
.../balancer/router/LoadScoreGreedyRouter.java | 32 +-
.../load/balancer/router/RegionRouteMap.java | 166 ++
.../manager/load/balancer/router/mcf/MCFEdge.java | 34 +
.../balancer/router/mcf/MCFLeaderBalancer.java | 305 +++
.../confignode/manager/node/BaseNodeCache.java | 80 -
.../manager/node/ConfigNodeHeartbeatCache.java | 78 -
.../manager/node/DataNodeHeartbeatCache.java | 80 -
.../manager/node/NodeHeartbeatSample.java | 87 -
.../iotdb/confignode/manager/node/NodeManager.java | 362 +++-
.../manager/node/heartbeat/BaseNodeCache.java | 140 ++
.../node/heartbeat/ConfigNodeHeartbeatCache.java | 83 +
.../node/heartbeat/DataNodeHeartbeatCache.java | 63 +
.../node/heartbeat/NodeHeartbeatSample.java | 87 +
.../manager/node/heartbeat/NodeStatistics.java | 139 ++
.../manager/partition/PartitionManager.java | 141 +-
.../confignode/manager/partition/RegionCache.java | 91 -
.../manager/partition/RegionGroupCache.java | 122 --
.../manager/partition/RegionHeartbeatSample.java | 68 -
.../manager/partition/heartbeat/RegionCache.java | 73 +
.../partition/heartbeat/RegionGroupCache.java | 157 ++
.../partition/heartbeat/RegionGroupStatistics.java | 135 ++
.../partition/heartbeat/RegionHeartbeatSample.java | 49 +
.../partition/heartbeat/RegionStatistics.java | 86 +
.../iotdb/confignode/persistence/AuthorInfo.java | 6 +-
.../iotdb/confignode/persistence/NodeInfo.java | 534 -----
.../confignode/persistence/ProcedureInfo.java | 4 +-
.../iotdb/confignode/persistence/TriggerInfo.java | 98 +-
.../iotdb/confignode/persistence/UDFInfo.java | 229 ++-
.../iotdb/confignode/persistence/cq/CQInfo.java | 501 +++++
.../persistence/executor/ConfigPlanExecutor.java | 150 +-
.../persistence/metric/NodeInfoMetrics.java | 6 +-
.../persistence/metric/PartitionInfoMetrics.java | 4 +-
.../confignode/persistence/node/NodeInfo.java | 523 +++++
.../persistence/partition/PartitionInfo.java | 71 +-
.../persistence/partition/RegionCreateTask.java | 135 --
.../persistence/partition/RegionDeleteTask.java | 98 -
.../persistence/partition/RegionGroup.java | 3 +
.../persistence/partition/RegionMaintainTask.java | 131 --
.../persistence/partition/RegionMaintainType.java | 24 -
.../partition/StorageGroupPartitionTable.java | 50 +-
.../partition/maintainer/RegionCreateTask.java | 135 ++
.../partition/maintainer/RegionDeleteTask.java | 98 +
.../partition/maintainer/RegionMaintainTask.java | 131 ++
.../partition/maintainer/RegionMaintainType.java | 24 +
.../persistence/schema/ClusterSchemaInfo.java | 140 +-
.../persistence/schema/TemplateTable.java | 34 +-
.../persistence/sync/ClusterSyncInfo.java | 66 +-
.../iotdb/confignode/procedure/Procedure.java | 8 +-
.../confignode/procedure/ProcedureExecutor.java | 4 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 236 ++-
.../procedure/env/DataNodeRemoveHandler.java | 189 +-
.../procedure/impl/CreateTriggerProcedure.java | 296 ---
.../procedure/impl/DropTriggerProcedure.java | 176 --
.../procedure/impl/cq/CreateCQProcedure.java | 263 +++
.../impl/node/AddConfigNodeProcedure.java | 43 +-
.../impl/node/RemoveConfigNodeProcedure.java | 4 +-
.../impl/node/RemoveDataNodeProcedure.java | 29 +-
.../impl/schema/DataNodeRegionGroupUtil.java | 81 +
.../procedure/impl/schema/DataNodeRegionTask.java | 195 ++
.../impl/schema/DeactivateTemplateProcedure.java | 488 +++++
.../impl/schema/DeleteStorageGroupProcedure.java | 211 ++
.../impl/schema/DeleteTimeSeriesProcedure.java | 549 ++++++
.../impl/schema/UnsetTemplateProcedure.java | 426 ++++
.../statemachine/CreateRegionGroupsProcedure.java | 21 +-
.../statemachine/DeleteStorageGroupProcedure.java | 210 --
.../statemachine/DeleteTimeSeriesProcedure.java | 658 -------
.../impl/statemachine/RegionMigrateProcedure.java | 34 +-
.../impl/sync/AbstractOperatePipeProcedure.java | 9 +-
.../procedure/impl/sync/CreatePipeProcedure.java | 79 +-
.../procedure/impl/sync/DropPipeProcedure.java | 56 +-
.../OperatePipeProcedureRollbackProcessor.java | 122 ++
.../procedure/impl/sync/StartPipeProcedure.java | 103 +-
.../procedure/impl/sync/StopPipeProcedure.java | 103 +-
.../impl/trigger/CreateTriggerProcedure.java | 288 +++
.../impl/trigger/DropTriggerProcedure.java | 176 ++
.../confignode/procedure/scheduler/LockQueue.java | 10 +-
.../procedure/state/AddConfigNodeState.java | 3 +-
.../procedure/state/CreateRegionGroupsState.java | 13 +-
.../procedure/state/DeleteStorageGroupState.java | 27 -
.../procedure/state/DeleteTimeSeriesState.java | 27 -
.../procedure/state/RemoveDataNodeState.java | 1 +
.../procedure/state/cq/CreateCQState.java | 25 +
.../state/schema/DeactivateTemplateState.java | 27 +
.../state/schema/DeleteStorageGroupState.java | 27 +
.../state/schema/DeleteTimeSeriesState.java | 27 +
.../procedure/state/schema/UnsetTemplateState.java | 27 +
.../procedure/store/ConfigProcedureStore.java | 8 +-
.../procedure/store/ProcedureFactory.java | 62 +-
.../confignode/procedure/store/ProcedureType.java | 82 +
.../iotdb/confignode/service/ConfigNode.java | 69 +-
.../confignode/service/ConfigNodeCommandLine.java | 5 +-
.../service/thrift/ConfigNodeRPCService.java | 6 +-
.../thrift/ConfigNodeRPCServiceHandler.java | 2 +-
.../thrift/ConfigNodeRPCServiceHandlerMetrics.java | 4 +-
.../thrift/ConfigNodeRPCServiceMetrics.java | 4 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 161 +-
.../confignode/writelog/io/BatchLogReader.java | 76 +
.../iotdb/confignode/writelog/io/ILogReader.java | 46 +
.../writelog/io/SingleFileLogReader.java | 156 ++
.../request/ConfigPhysicalPlanSerDeTest.java | 331 +++-
.../request/write/RemoveDataNodePlanTest.java | 173 --
.../iotdb/confignode/cq/CQScheduleTaskTest.java | 44 +
.../load/balancer/router/LazyGreedyRouterTest.java | 166 --
.../load/balancer/router/LeaderRouterTest.java | 155 +-
.../balancer/router/LoadScoreGreedyRouterTest.java | 40 +-
.../load/balancer/router/RegionRouteMapTest.java | 82 +
.../balancer/router/mcf/MCFLeaderBalancerTest.java | 216 ++
.../confignode/manager/node/NodeCacheTest.java | 67 +
.../manager/partition/RegionGroupCacheTest.java | 109 +-
.../confignode/persistence/AuthorInfoTest.java | 36 +-
.../iotdb/confignode/persistence/CQInfoTest.java | 102 +
.../persistence/ClusterSchemaInfoTest.java | 2 +-
.../iotdb/confignode/persistence/NodeInfoTest.java | 56 +-
.../confignode/persistence/PartitionInfoTest.java | 25 +-
.../confignode/persistence/TriggerInfoTest.java | 5 +
.../iotdb/confignode/persistence/UDFInfoTest.java | 82 +
.../persistence/node/NodeStatisticsTest.java | 49 +
.../statistics/RegionGroupStatisticsTest.java | 58 +
.../partition/statistics/RegionStatisticsTest.java | 49 +
.../procedure/impl/CreateCQProcedureTest.java | 87 +
.../impl/CreateRegionGroupsProcedureTest.java | 4 +-
.../procedure/impl/CreateTriggerProcedureTest.java | 6 +
.../impl/DeactivateTemplateProcedureTest.java | 88 +
.../impl/DeleteStorageGroupProcedureTest.java | 2 +-
.../impl/DeleteTimeSeriesProcedureTest.java | 6 +-
.../procedure/impl/DropTriggerProcedureTest.java | 1 +
.../procedure/impl/OperatePipeProcedureTest.java | 60 +-
.../procedure/impl/UnsetTemplateProcedureTest.java | 75 +
.../impl/node/AddConfigNodeProcedureTest.java | 50 +
.../impl/node/RemoveConfigNodeProcedureTest.java | 50 +
.../impl/node/RemoveDataNodeProcedureTest.java | 55 +
.../statemachine/RegionMigrateProcedureTest.java | 65 +
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 338 ----
.../confignode1conf/iotdb-common.properties | 27 +
.../confignode1conf/iotdb-confignode-metric.yml | 48 +
.../confignode1conf/iotdb-confignode.properties | 21 +-
.../resources/confignode1conf/iotdb-metric.yml | 53 -
.../confignode2conf/iotdb-common.properties | 27 +
.../confignode2conf/iotdb-confignode-metric.yml | 48 +
.../confignode2conf/iotdb-confignode.properties | 20 +-
.../resources/confignode2conf/iotdb-metric.yml | 53 -
.../confignode3conf/iotdb-common.properties | 27 +
.../confignode3conf/iotdb-confignode-metric.yml | 48 +
.../confignode3conf/iotdb-confignode.properties | 20 +-
.../resources/confignode3conf/iotdb-metric.yml | 53 -
consensus/README.md | 2 +-
consensus/pom.xml | 2 +-
.../apache/iotdb/consensus/ConsensusFactory.java | 7 +-
.../org/apache/iotdb/consensus/IConsensus.java | 34 +
.../org/apache/iotdb/consensus/IStateMachine.java | 12 +
.../org/apache/iotdb/consensus/common/Peer.java | 16 +-
.../apache/iotdb/consensus/config/RatisConfig.java | 122 +-
.../exception/ConsensusGroupAddPeerException.java | 34 -
.../ConsensusGroupModifyPeerException.java | 34 +
.../multileader/MultiLeaderConsensus.java | 37 +-
.../multileader/MultiLeaderServerImpl.java | 214 +-
.../multileader/MultiLeaderServerMetrics.java | 88 +
.../multileader/client/DispatchLogHandler.java | 17 +
.../multileader/logdispatcher/LogDispatcher.java | 70 +-
.../logdispatcher/LogDispatcherThreadMetrics.java | 95 +
.../logdispatcher/MultiLeaderMemoryManager.java | 50 +-
.../MultiLeaderMemoryManagerMetrics.java | 52 +
.../multileader/logdispatcher/PendingBatch.java | 11 +-
.../service/MultiLeaderRPCServiceProcessor.java | 63 +-
.../ratis/ApplicationStateMachineProxy.java | 3 +-
.../ratis/FileInfoWithDelayedMd5Computing.java | 75 -
.../iotdb/consensus/ratis/RatisConsensus.java | 95 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 2 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 8 +
.../iotdb/consensus/simple/SimpleConsensus.java | 246 +++
.../iotdb/consensus/simple/SimpleServerImpl.java | 84 +
.../consensus/standalone/StandAloneConsensus.java | 243 ---
.../consensus/standalone/StandAloneServerImpl.java | 84 -
.../multileader/MultiLeaderConsensusTest.java | 4 +-
.../iotdb/consensus/multileader/RecoveryTest.java | 4 +-
.../multileader/logdispatcher/SyncStatusTest.java | 25 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 36 +-
.../apache/iotdb/consensus/ratis/SnapshotTest.java | 3 +
.../apache/iotdb/consensus/ratis/UtilsTest.java | 4 +-
.../iotdb/consensus/simple/RecoveryTest.java | 96 +
.../consensus/simple/SimpleConsensusTest.java | 301 +++
.../iotdb/consensus/standalone/RecoveryTest.java | 96 -
.../standalone/StandAloneConsensusTest.java | 301 ---
.../tests/tools/importCsv/ImportCsvTestIT.java | 6 +-
.../tests/tools/tsfile/ExportTsFileTestIT.java | 6 +-
.../src/test/resources/iotdb-datanode.properties | 23 +
.../src/test/resources/iotdb-engine.properties | 21 -
distribution/src/assembly/all.xml | 53 +-
distribution/src/assembly/confignode.xml | 17 +-
distribution/src/assembly/datanode.xml | 11 +-
.../GrafanaPlugin/iotdb/conf/iotdb-rest.properties | 3 +
docker/src/main/DockerCompose/start-1c1d.sh | 22 +
docker/src/main/Dockerfile-0.10.0 | 39 -
docker/src/main/Dockerfile-0.11.0 | 39 -
docker/src/main/Dockerfile-0.11.1 | 39 -
docker/src/main/Dockerfile-0.11.2 | 41 -
docker/src/main/Dockerfile-0.11.3 | 41 -
docker/src/main/Dockerfile-0.12.0-cluster | 53 -
docker/src/main/Dockerfile-0.12.0-node | 45 -
docker/src/main/Dockerfile-0.12.1-cluster | 53 -
docker/src/main/Dockerfile-0.12.1-node | 45 -
docker/src/main/Dockerfile-0.12.2-cluster | 53 -
docker/src/main/Dockerfile-0.12.2-grafana | 41 -
docker/src/main/Dockerfile-0.12.2-node | 45 -
docker/src/main/Dockerfile-0.12.6-cluster | 53 +
docker/src/main/Dockerfile-0.12.6-grafana | 41 +
docker/src/main/Dockerfile-0.12.6-node | 45 +
docker/src/main/Dockerfile-0.13.0-cluster | 53 +
.../src/main/Dockerfile-0.13.3-grafana-connector | 41 +
docker/src/main/Dockerfile-0.13.3-node | 45 +
.../src/main/Dockerfile-0.13.3-node-multi-platform | 45 +
docker/src/main/Dockerfile-0.9.0 | 41 -
docker/src/main/Dockerfile-1c1d | 50 +
docker/src/main/Dockerfile-1c1d-influxdb | 51 +
docs/Blog/Release0_93.md | 2 +-
docs/Development/VoteRelease.md | 4 +-
docs/Download/README.md | 178 +-
docs/UserGuide/API/InfluxDB-Protocol.md | 12 +-
docs/UserGuide/API/Interface-Comparison.md | 44 +-
docs/UserGuide/API/Programming-Cpp-Native-API.md | 6 +-
docs/UserGuide/API/Programming-JDBC.md | 8 +-
docs/UserGuide/API/Programming-Java-Native-API.md | 16 +-
.../UserGuide/API/Programming-Python-Native-API.md | 16 +-
docs/UserGuide/API/Programming-Thrift.md | 2 +-
docs/UserGuide/API/RestService.md | 24 +-
docs/UserGuide/API/Status-Codes.md | 8 +-
.../Administration-Management/Administration.md | 18 +-
docs/UserGuide/Alert/Alerting.md | 385 ----
docs/UserGuide/Alert/Triggers.md | 1000 ----------
docs/UserGuide/Cluster/Cluster-Concept.md | 22 +-
docs/UserGuide/Cluster/Cluster-Setup.md | 62 +-
docs/UserGuide/Data-Concept/Compression.md | 2 +-
.../Data-Concept/Data-Model-and-Terminology.md | 18 +-
docs/UserGuide/Data-Concept/Schema-Template.md | 2 +-
docs/UserGuide/Data-Concept/Time-Partition.md | 2 +-
docs/UserGuide/Data-Modeling/DataRegion.md | 22 +-
docs/UserGuide/Delete-Data/Delete-Data.md | 2 +-
docs/UserGuide/Delete-Data/TTL.md | 28 +-
.../Ecosystem-Integration/Grafana-Plugin.md | 2 +-
docs/UserGuide/Ecosystem-Integration/NiFi-IoTDB.md | 56 +-
.../Ecosystem-Integration/Zeppelin-IoTDB.md | 2 +-
.../Edge-Cloud-Collaboration/Sync-Tool.md | 373 ++++
.../Frequently-asked-questions.md | 0
.../Integration-Test-refactoring-tutorial.md | 12 +-
.../Maintenance-Tools/Maintenance-Command.md | 193 +-
docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 483 -----
docs/UserGuide/Maintenance-Tools/NodeTool.md | 14 +-
docs/UserGuide/Maintenance-Tools/Sync-Tool.md | 447 -----
docs/UserGuide/Monitor-Alert/Alerting.md | 401 ++++
docs/UserGuide/Monitor-Alert/Metric-Tool.md | 519 +++++
.../Operate-Metadata/Auto-Create-MetaData.md | 10 +-
docs/UserGuide/Operate-Metadata/Node.md | 20 +-
docs/UserGuide/Operate-Metadata/Storage-Group.md | 73 +-
docs/UserGuide/Operate-Metadata/Template.md | 70 +-
docs/UserGuide/Operate-Metadata/Timeseries.md | 36 +-
docs/UserGuide/Process-Data/Continuous-Query.md | 678 +++++--
docs/UserGuide/Process-Data/Select-Into.md | 425 ++--
docs/UserGuide/Process-Data/Triggers.md | 469 +++++
.../Process-Data/UDF-User-Defined-Function.md | 23 +-
docs/UserGuide/Query-Data/Aggregate-Query.md | 6 +-
docs/UserGuide/Query-Data/Select-Expression.md | 164 +-
.../UserGuide/QuickStart/Command-Line-Interface.md | 8 +-
docs/UserGuide/QuickStart/QuickStart.md | 49 +-
docs/UserGuide/QuickStart/ServerFileList.md | 53 +-
.../Reference/ConfigNode-Config-Manual.md | 28 +-
docs/UserGuide/Reference/DataNode-Config-Manual.md | 8 +-
docs/UserGuide/Reference/Keywords.md | 54 +-
docs/UserGuide/Reference/SQL-Reference.md | 50 +-
docs/UserGuide/Reference/Syntax-Conventions.md | 135 +-
docs/UserGuide/Reference/TSDB-Comparison.md | 4 +-
docs/UserGuide/UDF-Library/Data-Profiling.md | 73 +
docs/UserGuide/UDF-Library/Data-Quality.md | 57 +-
docs/UserGuide/UDF-Library/M4.md | 101 +-
docs/UserGuide/Write-Data/CSV-Tool.md | 6 +-
docs/UserGuide/Write-Data/Load-External-Tsfile.md | 2 +-
docs/UserGuide/Write-Data/MQTT.md | 24 +
docs/UserGuide/Write-Data/REST-API.md | 58 +
docs/UserGuide/Write-Data/Session.md | 37 +
docs/zh/Development/VoteRelease.md | 4 +-
docs/zh/Download/README.md | 173 +-
docs/zh/UserGuide/API/InfluxDB-Protocol.md | 12 +-
docs/zh/UserGuide/API/Interface-Comparison.md | 44 +-
.../zh/UserGuide/API/Programming-Cpp-Native-API.md | 6 +-
docs/zh/UserGuide/API/Programming-JDBC.md | 8 +-
.../UserGuide/API/Programming-Java-Native-API.md | 14 +-
.../UserGuide/API/Programming-Python-Native-API.md | 14 +-
docs/zh/UserGuide/API/Programming-Thrift.md | 4 +-
docs/zh/UserGuide/API/RestService.md | 22 +-
.../Administration-Management/Administration.md | 18 +-
docs/zh/UserGuide/Alert/Alerting.md | 374 ----
docs/zh/UserGuide/Alert/Triggers.md | 935 ---------
docs/zh/UserGuide/Cluster/Cluster-Concept.md | 4 +-
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 62 +-
docs/zh/UserGuide/Data-Concept/Compression.md | 2 +-
.../Data-Concept/Data-Model-and-Terminology.md | 20 +-
docs/zh/UserGuide/Data-Concept/Schema-Template.md | 4 +-
docs/zh/UserGuide/Data-Concept/Time-Partition.md | 2 +-
docs/zh/UserGuide/Data-Modeling/DataRegion.md | 12 +-
docs/zh/UserGuide/Delete-Data/Delete-Data.md | 2 +-
docs/zh/UserGuide/Delete-Data/TTL.md | 34 +-
.../Ecosystem-Integration/Grafana-Plugin.md | 2 +-
.../UserGuide/Ecosystem-Integration/NiFi-IoTDB.md | 53 +-
.../Ecosystem-Integration/Zeppelin-IoTDB.md | 2 +-
.../Edge-Cloud-Collaboration/Sync-Tool.md | 359 ++++
.../Frequently-asked-questions.md | 0
.../Integration-Test-refactoring-tutorial.md | 8 +-
.../Maintenance-Tools/Maintenance-Command.md | 173 +-
docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 480 -----
docs/zh/UserGuide/Maintenance-Tools/NodeTool.md | 10 +-
.../Maintenance-Tools/SchemaFileSketch-Tool.md | 2 +-
docs/zh/UserGuide/Maintenance-Tools/Sync-Tool.md | 453 -----
docs/zh/UserGuide/Monitor-Alert/Alerting.md | 370 ++++
docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md | 517 +++++
.../Operate-Metadata/Auto-Create-MetaData.md | 10 +-
docs/zh/UserGuide/Operate-Metadata/Node.md | 18 +-
.../zh/UserGuide/Operate-Metadata/Storage-Group.md | 73 +-
docs/zh/UserGuide/Operate-Metadata/Template.md | 58 +-
docs/zh/UserGuide/Operate-Metadata/Timeseries.md | 18 +-
docs/zh/UserGuide/Process-Data/Continuous-Query.md | 681 +++++--
docs/zh/UserGuide/Process-Data/Select-Into.md | 425 ++--
docs/zh/UserGuide/Process-Data/Triggers.md | 457 +++++
.../Process-Data/UDF-User-Defined-Function.md | 20 +-
docs/zh/UserGuide/Query-Data/Aggregate-Query.md | 8 +-
docs/zh/UserGuide/Query-Data/Select-Expression.md | 165 +-
.../UserGuide/QuickStart/Command-Line-Interface.md | 8 +-
docs/zh/UserGuide/QuickStart/QuickStart.md | 36 +-
docs/zh/UserGuide/QuickStart/ServerFileList.md | 46 +-
.../Reference/ConfigNode-Config-Manual.md | 24 +-
.../UserGuide/Reference/DataNode-Config-Manual.md | 6 +-
docs/zh/UserGuide/Reference/Keywords.md | 52 +-
docs/zh/UserGuide/Reference/SQL-Reference.md | 60 +-
docs/zh/UserGuide/Reference/Syntax-Conventions.md | 136 +-
docs/zh/UserGuide/UDF-Library/Data-Profiling.md | 74 +
docs/zh/UserGuide/UDF-Library/Data-Quality.md | 57 +-
docs/zh/UserGuide/UDF-Library/M4.md | 101 +-
docs/zh/UserGuide/Write-Data/CSV-Tool.md | 6 +-
.../UserGuide/Write-Data/Load-External-Tsfile.md | 2 +-
docs/zh/UserGuide/Write-Data/MQTT.md | 24 +
docs/zh/UserGuide/Write-Data/REST-API.md | 57 +
docs/zh/UserGuide/Write-Data/Session.md | 37 +
.../src/AlignedTimeseriesSessionExample.cpp | 2 +-
.../org/apache/iotdb/influxdb/InfluxDBExample.java | 2 +-
.../main/java/org/apache/iotdb/JDBCExample.java | 2 +-
.../iotdb/SyntaxConventionRelatedExample.java | 4 +-
.../server/CustomizedJsonPayloadFormatter.java | 2 +-
example/mqtt/README.md | 2 +-
example/rest-client-c-example/main.c | 4 +-
example/rocketmq/readme.md | 6 +-
.../org/apache/iotdb/DataMigrationExample.java | 4 +-
.../main/java/org/apache/iotdb/SessionExample.java | 2 +-
.../iotdb/SyntaxConventionRelatedExample.java | 6 +-
example/trigger/pom.xml | 2 +-
.../iotdb/trigger/ClusterAlertingExample.java | 6 +
.../org/apache/iotdb/trigger/LoggerTrigger.java | 86 +
.../java/org/apache/iotdb/tsfile/TsFileRead.java | 11 +-
example/udf/pom.xml | 3 +-
.../java/org/apache/iotdb/udf/UDTFExample.java | 2 +-
external-api/pom.xml | 8 +
.../iotdb/external/api/IPropertiesLoader.java | 12 +-
.../iotdb/external/api/ISeriesNumerLimiter.java | 48 -
.../iotdb/external/api/ISeriesNumerMonitor.java | 46 +
.../external/api/thrift/JudgableServerContext.java | 44 +
.../external/api/thrift/ServerContextFactory.java | 27 +
.../iotdb/flink/tsfile/util/TSFileConfigUtil.java | 1 +
.../util/TSFileConfigUtilCompletenessTest.java | 13 +-
.../Apache IoTDB ConfigNode Dashboard v0.14.0.json | 351 ++--
.../Apache IoTDB DataNode Dashboard v0.14.0.json | 2064 +++++++++++++++++---
.../standalone/Apache IoTDB Dashboard v0.14.0.json | 2 +-
grafana-plugin/README.md | 235 ++-
grafana-plugin/pkg/main.go | 2 +-
.../pkg/plugin/iotdb_resource_handler.go | 170 ++
grafana-plugin/pkg/plugin/plugin.go | 119 +-
grafana-plugin/src/ConfigEditor.tsx | 70 +-
grafana-plugin/src/datasource.ts | 47 +-
grafana-plugin/src/img/addIoTDBDataSource.png | Bin 0 -> 43760 bytes
grafana-plugin/src/img/showData.png | Bin 0 -> 170827 bytes
grafana-plugin/src/plugin.json | 6 +-
grafana-plugin/src/types.ts | 3 +-
.../iotdb/hadoop/tsfile/TSFRecordReader.java | 2 +-
.../influxdb/integration/IoTDBInfluxDBIT.java | 7 +-
integration-test/README.md | 61 +-
integration-test/checkstyle.xml | 8 +-
integration-test/import-control.xml | 97 +-
integration-test/pom.xml | 23 +-
integration-test/src/assembly/mpp-test.xml | 18 +-
.../trigger/example/TriggerFireTimesCounter.java | 87 +
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 148 +-
.../apache/iotdb/it/env/AbstractNodeWrapper.java | 42 +-
.../org/apache/iotdb/it/env/ConfigFactory.java | 41 +-
.../org/apache/iotdb/it/env/ConfigNodeWrapper.java | 50 +-
.../org/apache/iotdb/it/env/DataNodeWrapper.java | 72 +-
.../java/org/apache/iotdb/it/env/EnvFactory.java | 20 +-
.../main/java/org/apache/iotdb/it/env/EnvType.java | 30 +
.../java/org/apache/iotdb/it/env/MppConfig.java | 71 +-
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 45 +-
.../java/org/apache/iotdb/it/env/SimpleEnv.java | 45 +
.../iotdb/it/env/StandaloneDataNodeWrapper.java | 32 -
.../apache/iotdb/it/env/StandaloneOnMppEnv.java | 61 -
.../org/apache/iotdb/it/utils/TsFileGenerator.java | 232 +++
.../BuiltinTimeSeriesGeneratingFunctionEnum.java | 3 +-
.../apache/iotdb/itbase/constant/TestConstant.java | 11 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 84 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 75 +-
.../iotdb/confignode/IoTDBClusterPartitionIT.java | 755 -------
.../apache/iotdb/confignode/IoTDBConfigNodeIT.java | 848 --------
.../confignode/IoTDBConfigNodeSnapshotIT.java | 279 ---
.../confignode/it/IoTDBClusterAuthorityIT.java | 484 +++++
.../iotdb/confignode/it/IoTDBClusterNodeIT.java | 308 +++
.../confignode/it/IoTDBClusterPartitionIT.java | 781 ++++++++
.../it/IoTDBClusterRegionLeaderBalancingIT.java | 303 +++
.../iotdb/confignode/it/IoTDBClusterRestartIT.java | 233 +++
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 373 ++++
.../it/IoTDBConfigNodeSwitchLeaderIT.java | 191 ++
.../iotdb/confignode/it/IoTDBStorageGroupIT.java | 185 ++
.../confignode/it/utils/ConfigNodeTestUtils.java | 115 ++
.../org/apache/iotdb/db/it/IOTDBLoadTsFileIT.java | 361 ++--
.../java/org/apache/iotdb/db/it/IoTDBAuthIT.java | 45 +-
.../apache/iotdb/db/it/IoTDBDatetimeFormatIT.java | 131 ++
.../org/apache/iotdb/db/it/IoTDBDeletionIT.java | 6 +-
.../org/apache/iotdb/db/it/IoTDBEncodingIT.java | 405 ++++
.../org/apache/iotdb/db/it/IoTDBExampleIT.java | 6 +-
.../apache/iotdb/db/it/IoTDBExecuteBatchIT.java | 197 ++
.../apache/iotdb/db/it/IoTDBFilterBetweenIT.java | 20 +-
.../java/org/apache/iotdb/db/it/IoTDBFilterIT.java | 86 +-
.../org/apache/iotdb/db/it/IoTDBFilterNullIT.java | 13 +-
.../apache/iotdb/db/it/IoTDBFloatPrecisionIT.java | 175 ++
.../apache/iotdb/db/it/IoTDBFlushQueryMergeIT.java | 28 +-
.../apache/iotdb/db/it/IoTDBInsertMultiRowIT.java | 162 ++
.../org/apache/iotdb/db/it/IoTDBInsertNaNIT.java | 199 ++
.../org/apache/iotdb/db/it/IoTDBInsertNullIT.java | 207 ++
.../apache/iotdb/db/it/IoTDBInsertWithQueryIT.java | 466 +++++
.../iotdb/db/it/IoTDBInsertWithoutTimeIT.java | 2 +-
.../org/apache/iotdb/db/it/IoTDBMultiDeviceIT.java | 2 +-
.../org/apache/iotdb/db/it/IoTDBNestedQueryIT.java | 20 +-
.../iotdb/db/it/IoTDBPartialInsertionIT.java | 132 ++
.../db/it/IoTDBQueryWithRecreatedTimeseriesIT.java | 80 +
.../org/apache/iotdb/db/it/IoTDBQuotedPathIT.java | 7 +-
.../org/apache/iotdb/db/it/IoTDBRecoverIT.java | 413 ++++
.../apache/iotdb/db/it/IoTDBRecoverUnclosedIT.java | 289 +++
.../org/apache/iotdb/db/it/IoTDBRestartIT.java | 384 ++++
.../it/IoTDBSameMeasurementsDifferentTypesIT.java | 2 +-
.../java/org/apache/iotdb/db/it/IoTDBSettleIT.java | 99 +
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 57 +-
.../db/it/IoTDBSyntaxConventionIdentifierIT.java | 17 +-
.../it/IoTDBSyntaxConventionStringLiteralIT.java | 7 +-
.../org/apache/iotdb/db/it/IoTDBTimeZoneIT.java | 6 +-
.../java/org/apache/iotdb/db/it/IoTDBTtlIT.java | 8 +-
.../it/aggregation/IoTDBAggregationByLevelIT.java | 38 +-
.../it/aggregation/IoTDBAggregationDeleteIT.java | 3 +
.../db/it/aggregation/IoTDBAggregationIT.java | 9 +-
.../aggregation/IoTDBAggregationLargeDataIT.java | 2 +-
.../aggregation/IoTDBAggregationScanOrderIT.java | 3 +
.../aggregation/IoTDBAggregationSmallDataIT.java | 26 +-
.../db/it/aggregation/IoTDBTagAggregationIT.java | 25 +-
.../db/it/alignbydevice/IoTDBAlignByDeviceIT.java | 4 +-
.../iotdb/db/it/aligned/AlignedWriteUtil.java | 148 --
.../aligned/IoTDBAggregationWithDeletion2IT.java | 5 +-
.../it/aligned/IoTDBAggregationWithDeletionIT.java | 8 +-
.../db/it/aligned/IoTDBAlignedDataDeletionIT.java | 4 +-
.../db/it/aligned/IoTDBAlignedLastQuery2IT.java | 5 +-
.../db/it/aligned/IoTDBAlignedLastQuery3IT.java | 5 +-
.../db/it/aligned/IoTDBAlignedLastQueryIT.java | 14 +-
.../db/it/aligned/IoTDBAlignedSeriesQuery2IT.java | 1 +
.../db/it/aligned/IoTDBAlignedSeriesQuery3IT.java | 1 +
.../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 105 +-
.../IoTDBAlignedSeriesQueryWithDeletionIT.java | 1 +
.../db/it/aligned/IoTDBGroupByLevelQueryIT.java | 3 +-
...GroupByQueryWithValueFilterWithDeletion2IT.java | 5 +-
...BGroupByQueryWithValueFilterWithDeletionIT.java | 5 +-
...upByQueryWithoutValueFilterWithDeletion2IT.java | 5 +-
...oupByQueryWithoutValueFilterWithDeletionIT.java | 5 +-
.../db/it/aligned/IoTDBInsertAlignedValues2IT.java | 4 +-
.../db/it/aligned/IoTDBInsertAlignedValues3IT.java | 4 +-
.../db/it/aligned/IoTDBInsertAlignedValues4IT.java | 4 +-
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 16 +-
.../it/aligned/IoTDBLastQueryWithDeletion2IT.java | 9 +-
.../it/aligned/IoTDBLastQueryWithDeletionIT.java | 9 +-
.../aligned/IoTDBLastQueryWithoutLastCache2IT.java | 5 +-
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 5 +-
...DBLastQueryWithoutLastCacheWithDeletion2IT.java | 9 +-
...TDBLastQueryWithoutLastCacheWithDeletionIT.java | 9 +-
...BRawQueryWithoutValueFilterWithDeletion2IT.java | 4 +-
...DBRawQueryWithoutValueFilterWithDeletionIT.java | 19 +-
.../org/apache/iotdb/db/it/cq/IoTDBCQExecIT.java | 466 +++++
.../java/org/apache/iotdb/db/it/cq/IoTDBCQIT.java | 553 ++++++
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 29 +-
.../iotdb/db/it/env/StandaloneEnvConfig.java | 87 +-
.../apache/iotdb/db/it/groupby/IOTDBGroupByIT.java | 2 +-
.../iotdb/db/it/groupby/IoTDBGroupByUnseqIT.java | 4 +-
.../apache/iotdb/db/it/groupby/IoTDBHavingIT.java | 5 +-
.../iotdb/db/it/last/IoTDBLastWithTTLIT.java | 106 +
.../apache/iotdb/db/it/mqtt/IoTDBMQTTSinkIT.java | 212 ++
.../org/apache/iotdb/db/it/query/IoTDBAliasIT.java | 6 +-
.../iotdb/db/it/query/IoTDBArithmeticIT.java | 226 +++
.../iotdb/db/it/query/IoTDBFuzzyQueryIT.java | 273 +++
.../org/apache/iotdb/db/it/query/IoTDBInIT.java | 270 +++
.../iotdb/db/it/query/IoTDBNullOperandIT.java | 243 +++
.../iotdb/db/it/query/IoTDBNullValueFillIT.java | 5 +-
.../iotdb/db/it/query/IoTDBPaginationIT.java | 2 +-
.../apache/iotdb/db/it/query/IoTDBQueryDemoIT.java | 664 +++++++
.../query/IoTDBQueryWithComplexValueFilterIT.java | 2 +-
.../apache/iotdb/db/it/query/IoTDBResultSetIT.java | 32 +-
.../it/query/IoTDBSelectCompareExpressionIT.java | 485 +++++
.../iotdb/db/it/query/IoTDBSelectSchemaIT.java | 136 ++
.../db/it/schema/IoTDBAutoCreateSchemaIT.java | 40 +-
.../it/schema/IoTDBCreateAlignedTimeseriesIT.java | 21 +-
.../db/it/schema/IoTDBCreateStorageGroupIT.java | 24 +-
.../db/it/schema/IoTDBCreateTimeseriesIT.java | 12 +-
.../db/it/schema/IoTDBDeactivateTemplateIT.java | 231 +++
.../it/schema/IoTDBDeleteAlignedTimeseriesIT.java | 7 +-
.../db/it/schema/IoTDBDeleteStorageGroupIT.java | 54 +-
.../schema/IoTDBDeleteTimeseriesSchemaFileIT.java | 49 +
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 23 +-
.../it/schema/IoTDBMetadataFetchSchemaFileIT.java | 53 +
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 134 +-
.../db/it/schema/IoTDBSortedShowTimeseriesIT.java | 68 +-
.../apache/iotdb/db/it/schema/IoTDBTagAlterIT.java | 208 +-
.../org/apache/iotdb/db/it/schema/IoTDBTagIT.java | 275 +--
.../iotdb/db/it/selectinto/IoTDBSelectInto2IT.java | 57 +
.../iotdb/db/it/selectinto/IoTDBSelectInto3IT.java | 54 +
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 523 +++++
.../org/apache/iotdb/db/it/sync/IoTDBPipeIT.java | 121 +-
.../apache/iotdb/db/it/sync/IoTDBPipeSinkIT.java | 32 +-
.../apache/iotdb/db/it/sync/SyncTransportTest.java | 323 +++
.../db/it/trigger/IoTDBTriggerExecutionIT.java | 268 +++
.../db/it/trigger/IoTDBTriggerManagementIT.java | 634 ++++++
.../org/apache/iotdb/db/it/udf/IoTDBUDFM4IT.java | 283 +++
.../iotdb/db/it/udf/IoTDBUDFManagementIT.java | 49 +-
.../db/it/udf/IoTDBUDFOtherWindowQueryIT.java | 2 +-
.../iotdb/db/it/udf/IoTDBUDFWindowQueryIT.java | 2 +-
.../db/it/udf/IoTDBUDTFAlignByTimeQueryIT.java | 4 +-
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 8 +-
.../iotdb/db/it/udf/IoTDBUDTFHybridQueryIT.java | 6 +-
.../iotdb/db/it/udf/IoTDBUDTFNonAlignQueryIT.java | 2 +-
.../apache/iotdb/db/it/utils/AlignedWriteUtil.java | 148 ++
.../org/apache/iotdb/db/it/utils/TestUtils.java | 10 +
.../iotdb/db/it/watermark/IoTDBWatermarkIT.java | 247 +++
.../db/it/withoutNull/IoTDBWithoutAllNullIT.java | 20 +-
.../db/it/withoutNull/IoTDBWithoutAnyNullIT.java | 8 +-
.../withoutNull/IoTDBWithoutNullAllFilterIT.java | 47 +-
.../withoutNull/IoTDBWithoutNullAnyFilterIT.java | 63 +-
.../iotdb/session/IoTDBSessionAlignedInsertIT.java | 454 -----
.../iotdb/session/IoTDBSessionComplexIT.java | 557 ------
.../session/IoTDBSessionDisableMemControlIT.java | 220 ---
.../iotdb/session/IoTDBSessionInsertNulIT.java | 358 ----
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 1633 ----------------
.../session/IoTDBSessionSyntaxConventionIT.java | 428 ----
.../java/org/apache/iotdb/session/SessionTest.java | 180 --
.../iotdb/session/it/IoTDBConnectionInfoIT.java | 66 +
.../session/it/IoTDBSessionAlignedInsertIT.java | 455 +++++
.../iotdb/session/it/IoTDBSessionComplexIT.java | 559 ++++++
.../it/IoTDBSessionDisableMemControlIT.java | 222 +++
.../iotdb/session/it/IoTDBSessionInsertNullIT.java | 360 ++++
.../IoTDBSessionInsertWithTriggerExecutionIT.java | 340 ++++
.../session/it/IoTDBSessionSchemaTemplateIT.java | 223 +++
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 1451 ++++++++++++++
.../session/it/IoTDBSessionSyntaxConventionIT.java | 430 ++++
.../org/apache/iotdb/session/it/SessionIT.java | 185 ++
.../iotdb/session/it/pool/SessionPoolIT.java | 540 +++++
.../src/test/resources/TriggerFireTimesCounter.jar | Bin 0 -> 1324 bytes
.../src/test/resources/iotdb-datanode.properties | 24 +
.../src/test/resources/iotdb-engine.properties | 21 -
.../src/test/resources/logback-test.xml | 2 +-
.../src/test/resources/udf-example.jar | Bin 0 -> 10018 bytes
.../iotdb/integration/env/ClusterEnvBase.java | 4 +-
.../iotdb/integration/env/ClusterEnvConfig.java | 3 +-
.../apache/iotdb/integration/env/ClusterNode.java | 4 +-
.../iotdb/integration/env/RemoteServerEnv.java | 8 +-
.../apache/iotdb/db/integration/IOTDBInsertIT.java | 2 +-
.../IoTDBAlignedTimeSeriesCompactionIT.java | 4 +-
.../iotdb/db/integration/IoTDBArithmeticIT.java | 287 ---
.../iotdb/db/integration/IoTDBAuthorizationIT.java | 49 +-
.../iotdb/db/integration/IoTDBClearCacheIT.java | 4 +-
.../apache/iotdb/db/integration/IoTDBCloseIT.java | 2 +-
.../iotdb/db/integration/IoTDBCompactionIT.java | 8 +-
.../integration/IoTDBCompactionWithIDTableIT.java | 8 +-
.../apache/iotdb/db/integration/IoTDBDaemonIT.java | 4 +-
.../db/integration/IoTDBDatetimeFormatIT.java | 130 --
.../iotdb/db/integration/IoTDBDisableAlignIT.java | 4 +-
.../iotdb/db/integration/IoTDBEncodingIT.java | 492 -----
.../db/integration/IoTDBEngineTimeGeneratorIT.java | 2 +-
.../iotdb/db/integration/IoTDBExecuteBatchIT.java | 196 --
.../iotdb/db/integration/IoTDBFilePathUtilsIT.java | 99 -
.../apache/iotdb/db/integration/IoTDBFillIT.java | 4 +-
.../db/integration/IoTDBFloatPrecisionIT.java | 170 --
.../db/integration/IoTDBFlushQueryMergeIT.java | 18 +-
.../iotdb/db/integration/IoTDBFuzzyQueryIT.java | 294 ---
.../org/apache/iotdb/db/integration/IoTDBInIT.java | 252 ---
.../db/integration/IoTDBInsertMultiRowIT.java | 144 --
.../iotdb/db/integration/IoTDBInsertNaNIT.java | 197 --
.../iotdb/db/integration/IoTDBInsertNullIT.java | 207 --
.../db/integration/IoTDBInsertWithQueryIT.java | 465 -----
...IoTDBLoadExternalTsFileWithTimePartitionIT.java | 329 ----
.../db/integration/IoTDBLoadExternalTsfileIT.java | 15 +-
.../IoTDBLoadExternalTsfileWithVirtualSGIT.java | 7 +-
.../integration/IoTDBManageTsFileResourceIT.java | 291 ---
.../iotdb/db/integration/IoTDBMultiSeriesIT.java | 2 +-
.../db/integration/IoTDBMultiStatementsIT.java | 2 +-
.../db/integration/IoTDBNewTsFileCompactionIT.java | 2 +-
.../db/integration/IoTDBOverlappedPageIT.java | 2 +-
.../db/integration/IoTDBPartialInsertionIT.java | 131 --
.../iotdb/db/integration/IoTDBQueryDemoIT.java | 685 -------
.../db/integration/IoTDBQueryMemoryControlIT.java | 2 +-
.../iotdb/db/integration/IoTDBQueryTimeoutIT.java | 4 +-
.../db/integration/IoTDBQueryWithIDTableIT.java | 4 +-
.../IoTDBQueryWithRecreatedTimeseriesIT.java | 79 -
.../iotdb/db/integration/IoTDBRecoverIT.java | 436 -----
.../db/integration/IoTDBRecoverUnclosedIT.java | 302 ---
.../db/integration/IoTDBRemovePartitionIT.java | 622 +++---
.../db/integration/IoTDBRepeatPatternNameIT.java | 67 +
.../iotdb/db/integration/IoTDBRestartIT.java | 427 ----
.../db/integration/IoTDBRewriteTsFileToolIT.java | 525 ++++-
.../db/integration/IoTDBRpcCompressionIT.java | 2 +-
.../db/integration/IoTDBSchemaTemplateIT.java | 66 +-
.../IoTDBSelectCompareExpressionIT.java | 482 -----
.../iotdb/db/integration/IoTDBSelectSchemaIT.java | 133 --
.../iotdb/db/integration/IoTDBSensorUpdateIT.java | 2 +-
.../db/integration/IoTDBSequenceDataQueryIT.java | 2 +-
.../db/integration/IoTDBSessionTimeoutIT.java | 2 +-
.../IoTDBSetSystemReadOnlyWritableIT.java | 4 +-
.../apache/iotdb/db/integration/IoTDBSettleIT.java | 96 -
.../integration/IoTDBSizeTieredCompactionIT.java | 44 +-
.../iotdb/db/integration/IoTDBSnapshotIT.java | 8 +-
.../integration/IoTDBSortedShowTimeseriesIT.java | 69 +-
.../iotdb/db/integration/IoTDBTracingIT.java | 6 +-
.../apache/iotdb/db/integration/IoTDBTtlIT.java | 24 +-
.../db/integration/IoTDBUDFWindowQueryIT.java | 2 +-
.../db/integration/IoTDBUDTFHybridQueryIT.java | 2 +-
.../db/integration/IoTDBUDTFNonAlignQueryIT.java | 2 +-
.../db/integration/IoTDBUnseqOverlappedPageIT.java | 2 +-
.../iotdb/db/integration/IoTDBVersionIT.java | 4 +-
.../aggregation/IoTDBUDFNestAggregationIT.java | 14 +-
.../IoTDBUserDefinedAggregationFunctionIT.java | 8 +-
.../db/integration/aligned/AlignedWriteUtil.java | 2 +-
.../aligned/IoTDBGroupByFillQueryBigDataIT.java | 2 +-
.../aligned/IoTDBLoadExternalAlignedTsFileIT.java | 15 +-
.../db/integration/groupby/IoTDBGroupByFillIT.java | 2 +-
.../groupby/IoTDBGroupByFillMixPathsIT.java | 2 +-
.../groupby/IoTDBGroupByFillWithRangeIT.java | 2 +-
.../db/integration/sync/IoTDBSyncReceiverIT.java | 59 -
.../sync/IoTDBSyncReceiverLoaderIT.java | 76 +-
.../db/integration/sync/IoTDBSyncSenderIT.java | 58 +-
.../iotdb/db/integration/sync/SyncTestUtil.java | 4 +-
.../versionadaption/IoTDBDDLVersionAdaptionIT.java | 24 +-
.../IoTDBDeletionVersionAdaptionIT.java | 4 +-
.../IoTDBQueryVersionAdaptionIT.java | 4 +-
.../session/IoTDBSessionAlignedABDeviceIT.java | 6 +-
.../session/IoTDBSessionAlignedAggregationIT.java | 6 +-
.../IoTDBSessionAlignedAggregationWithUnSeqIT.java | 6 +-
.../apache/iotdb/session/pool/SessionPoolTest.java | 482 -----
.../apache/iotdb/session/template/TemplateUT.java | 400 ----
.../src/test/resources/iotdb-datanode.properties | 24 +
.../src/test/resources/iotdb-engine.properties | 21 -
integration/src/test/resources/logback-test.xml | 2 +-
jdbc/README.md | 10 +-
jdbc/src/main/feature/feature.xml | 2 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 929 +++++----
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 1165 ++++++++++-
.../org/apache/iotdb/jdbc/IoTDBResultMetadata.java | 4 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 31 +-
.../test/java/org/apache/iotdb/jdbc/BatchTest.java | 2 +-
.../iotdb/jdbc/IoTDBDatabaseMetadataTest.java | 10 +-
.../apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java | 182 +-
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 34 +-
library-udf/pom.xml | 115 +-
library-udf/src/assembly/tools/register-UDF.bat | 1 +
library-udf/src/assembly/tools/register-UDF.sh | 1 +
.../iotdb/library/dprofile/UDAFQuantile.java | 127 ++
.../library/dprofile/util/HeapLongKLLSketch.java | 356 ++++
.../dprofile/util/KLLSketchForQuantile.java | 172 ++
metrics/ReadMe.md | 9 +-
metrics/dropwizard-metrics/pom.xml | 8 +-
.../dropwizard/DropwizardMetricManager.java | 2 +-
.../resources/conf/iotdb-confignode-metric.yml | 51 +
.../resources/conf/iotdb-datanode-metric.yml | 51 +
.../main/assembly/resources/conf/iotdb-metric.yml | 56 -
.../iotdb/metrics/AbstractMetricManager.java | 47 +-
.../iotdb/metrics/AbstractMetricService.java | 19 +-
.../iotdb/metrics/DoNothingMetricService.java | 6 -
.../apache/iotdb/metrics/config/MetricConfig.java | 31 +-
.../metrics/config/MetricConfigDescriptor.java | 32 +-
.../iotdb/metrics/config/MetricConstant.java | 4 +-
.../iotdb/metrics/impl/DoNothingMetricManager.java | 2 +-
.../metricsets/jvm/JvmClassLoaderMetrics.java | 52 +
.../metrics/metricsets/jvm/JvmCompileMetrics.java | 54 +
.../iotdb/metrics/metricsets/jvm/JvmGcMetrics.java | 346 ++++
.../metrics/metricsets/jvm/JvmMemoryMetrics.java | 133 ++
.../iotdb/metrics/metricsets/jvm/JvmMetrics.java | 52 +
.../metrics/metricsets/jvm/JvmThreadMetrics.java | 102 +
.../iotdb/metrics/metricsets/jvm/JvmUtils.java | 46 +
.../metrics/metricsets/logback/LogbackMetrics.java | 104 +
.../metricsets/logback/MetricsTurboFilter.java | 98 +
.../metricsets/predefined/PredefinedMetric.java | 33 -
.../predefined/jvm/JvmClassLoaderMetrics.java | 52 -
.../predefined/jvm/JvmCompileMetrics.java | 54 -
.../metricsets/predefined/jvm/JvmGcMetrics.java | 346 ----
.../predefined/jvm/JvmMemoryMetrics.java | 133 --
.../metricsets/predefined/jvm/JvmMetrics.java | 52 -
.../predefined/jvm/JvmThreadMetrics.java | 102 -
.../metricsets/predefined/jvm/JvmUtils.java | 46 -
.../predefined/logback/LogbackMetrics.java | 104 -
.../predefined/logback/MetricsTurboFilter.java | 98 -
.../iotdb/metrics/utils/IoTDBMetricsUtils.java | 7 +-
.../org/apache/iotdb/metrics/utils/MetricInfo.java | 2 +-
.../iotdb/metrics/config/MetricConfigTest.java | 3 +-
.../interface/src/test/resources/iotdb-metric.yml | 10 +-
metrics/micrometer-metrics/pom.xml | 2 +-
.../micrometer/MicrometerMetricManager.java | 2 +-
node-commons/pom.xml | 21 +
.../resources/conf/iotdb-common.properties | 1107 +++++++++++
.../src/assembly/resources/sbin/iotdb-common.sh | 211 ++
.../iotdb/commons/client/ClientPoolFactory.java | 24 +-
.../async/AsyncDataNodeInternalServiceClient.java | 2 +-
.../apache/iotdb/commons/cluster/NodeStatus.java | 2 +-
.../iotdb/commons/cluster/RegionRoleType.java | 10 +-
.../apache/iotdb/commons/cluster/RegionStatus.java | 5 +
.../iotdb/commons/concurrent/ThreadName.java | 2 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 39 +-
.../iotdb/commons/conf/CommonDescriptor.java | 68 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 80 +-
.../commons/consensus/ConfigNodeRegionId.java | 34 +
.../iotdb/commons/consensus/ConsensusGroupId.java | 8 +-
.../iotdb/commons/consensus/PartitionRegionId.java | 34 -
.../java/org/apache/iotdb/commons/cq/CQState.java | 45 +
.../org/apache/iotdb/commons/cq/TimeoutPolicy.java | 45 +
.../exception/sync/PipeAlreadyExistException.java | 31 +
.../exception/sync/PipeNotExistException.java | 4 -
.../sync/PipeSinkAlreadyExistException.java | 25 +
.../exception/sync/PipeSinkBeingUsedException.java | 27 +
.../exception/sync/PipeSinkNotExistException.java | 25 +
.../commons/executable/ExecutableManager.java | 74 +-
.../iotdb/commons/partition/DataPartition.java | 10 +-
.../commons/partition/DataPartitionTable.java | 4 +-
.../commons/partition/SchemaPartitionTable.java | 2 +-
.../commons/partition/SeriesPartitionTable.java | 2 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 23 +-
.../apache/iotdb/commons/path/PathPatternNode.java | 58 +-
.../apache/iotdb/commons/path/PathPatternTree.java | 16 +-
.../apache/iotdb/commons/path/PatternTreeMap.java | 44 +-
.../apache/iotdb/commons/service/ServiceType.java | 31 +-
.../commons/service/metric/MetricService.java | 123 ++
.../commons/service/metric/MetricServiceMBean.java | 30 +
.../iotdb/commons/service/metric/enums/Metric.java | 69 +
.../commons/service/metric/enums/Operation.java | 39 +
.../iotdb/commons/service/metric/enums/Tag.java | 32 +
.../iotdb/commons/sync/metadata/SyncMetadata.java | 122 +-
.../commons/sync/persistence/SyncLogReader.java | 31 +-
.../apache/iotdb/commons/sync/pipe/PipeInfo.java | 6 +-
.../apache/iotdb/commons/sync/pipe/PipeStatus.java | 45 +-
.../iotdb/commons/sync/pipe/TsFilePipeInfo.java | 8 +-
.../iotdb/commons/trigger/TriggerInformation.java | 43 +-
.../apache/iotdb/commons/trigger/TriggerTable.java | 51 +-
.../trigger/service/TriggerExecutableManager.java | 2 +
.../apache/iotdb/commons/udf/UDFInformation.java | 173 ++
.../org/apache/iotdb/commons/udf/UDFTable.java | 138 ++
.../BuiltinTimeSeriesGeneratingFunction.java | 3 +-
.../apache/iotdb/commons/udf/builtin/UDTFM4.java | 311 +++
.../iotdb/commons/udf/service/SnapshotUtils.java | 96 -
.../commons/udf/service/UDFClassLoaderManager.java | 5 +-
.../commons/udf/service/UDFExecutableManager.java | 67 +-
.../iotdb/commons/udf/service/UDFLogWriter.java | 83 -
.../commons/udf/service/UDFManagementService.java | 341 ++++
.../udf/service/UDFRegistrationInformation.java | 82 -
.../udf/service/UDFRegistrationService.java | 513 -----
.../org/apache/iotdb/commons/utils/AuthUtils.java | 17 -
.../apache/iotdb/commons/utils/JVMCommonUtils.java | 2 +-
.../apache/iotdb/commons/utils/ProcessIdUtils.java | 35 +
.../apache/iotdb/commons/utils/StatusUtils.java | 6 +-
.../commons/utils/ThriftCommonsSerDeUtils.java | 19 +
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 19 -
.../iotdb/commons/path/PathPatternTreeTest.java | 19 +
.../commons/sync/metedata/SyncMetadataTest.java | 189 ++
.../iotdb/commons/utils/JVMCommonUtilsTest.java | 42 +
.../commons/utils/ThriftCommonsSerDeUtilsTest.java | 2 +-
openapi/pom.xml | 26 -
pom.xml | 20 +-
.../java/org/apache/iotdb/RewriteTsFileTool.java | 779 ++++++--
.../resources/conf/schema-rocksdb.properties | 8 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 166 +-
.../schemaregion/rocksdb/mnode/REntityMNode.java | 20 +
.../schemaregion/rocksdb/mnode/RMNode.java | 20 +
.../rocksdb/mnode/RStorageGroupMNode.java | 2 +-
schema-engine-tag/README.md | 190 ++
schema-engine-tag/pom.xml | 81 +
.../assembly/resources/conf/schema-tag.properties | 33 +
.../src/assembly/schema-engine-tag.xml | 44 +
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 907 +++++++++
.../tagSchemaRegion/config/TagSchemaConfig.java | 55 +
.../config/TagSchemaDescriptor.java | 93 +
.../idtable/IDTableWithDeviceIDListImpl.java | 138 ++
.../tagIndex/ITagInvertedIndex.java | 61 +
.../tagIndex/Request/DeletionRequest.java | 55 +
.../tagIndex/Request/InsertionRequest.java | 59 +
.../tagIndex/Request/QueryRequest.java | 46 +
.../tagSchemaRegion/tagIndex/TagInvertedIndex.java | 183 ++
.../tagIndex/deletion/MemChunkDeletion.java | 57 +
.../tagIndex/deletion/MemChunkGroupDeletion.java | 68 +
.../tagIndex/deletion/MemTableDeletion.java | 77 +
.../tagIndex/deletion/MemTableGroupDeletion.java | 66 +
.../tagIndex/insertion/MemChunkGroupInsertion.java | 65 +
.../tagIndex/insertion/MemChunkInsertion.java | 58 +
.../tagIndex/insertion/MemTableGroupInsertion.java | 74 +
.../tagIndex/insertion/MemTableInsertion.java | 67 +
.../tagIndex/memtable/MemChunk.java | 54 +
.../tagIndex/memtable/MemChunkGroup.java | 56 +
.../tagIndex/memtable/MemTable.java | 87 +
.../tagIndex/memtable/MemTableGroup.java | 102 +
.../tagIndex/query/MemChunkGroupQuery.java | 61 +
.../tagIndex/query/MemChunkQuery.java | 67 +
.../tagIndex/query/MemTableGroupQuery.java | 59 +
.../tagIndex/query/MemTableQuery.java | 72 +
.../tagIndex/response/QueryResponse.java | 71 +
.../tagSchemaRegion/tagIndex/wal/WALEntry.java | 134 ++
.../tagSchemaRegion/tagIndex/wal/WALManager.java | 141 ++
.../utils/MeasurementPathUtils.java | 80 +
.../utils/PathTagConverterUtils.java | 70 +
.../utils/ShowTimeSeriesResultUtils.java | 73 +
.../iotdb/lsm/annotation/DeletionProcessor.java | 36 +
.../iotdb/lsm/annotation/InsertionProcessor.java | 36 +
.../iotdb/lsm/annotation/QueryProcessor.java | 36 +
.../applicationcontext/ApplicationContext.java | 61 +
.../ApplicationContextGenerator.java | 119 ++
.../requestcontext/DeleteRequestContext.java | 34 +
.../requestcontext/FlushRequestContext.java | 33 +
.../requestcontext/InsertRequestContext.java | 34 +
.../requestcontext/QueryRequestContext.java | 34 +
.../lsm/context/requestcontext/RequestContext.java | 108 +
.../org/apache/iotdb/lsm/engine/ILSMEngine.java | 73 +
.../org/apache/iotdb/lsm/engine/IRecoverable.java | 34 +
.../org/apache/iotdb/lsm/engine/LSMEngine.java | 176 ++
.../apache/iotdb/lsm/engine/LSMEngineBuilder.java | 290 +++
.../lsm/levelProcess/BasicLevelProcessor.java | 79 +
.../lsm/levelProcess/DeleteLevelProcessor.java | 39 +
.../lsm/levelProcess/FlushLevelProcessor.java | 38 +
.../iotdb/lsm/levelProcess/ILevelProcessor.java | 41 +
.../lsm/levelProcess/InsertLevelProcessor.java | 39 +
.../lsm/levelProcess/LevelProcessorChain.java | 45 +
.../lsm/levelProcess/QueryLevelProcessor.java | 39 +
.../apache/iotdb/lsm/manager/BasicLSMManager.java | 55 +
.../apache/iotdb/lsm/manager/DeletionManager.java | 48 +
.../org/apache/iotdb/lsm/manager/ILSMManager.java | 58 +
.../apache/iotdb/lsm/manager/InsertionManager.java | 48 +
.../org/apache/iotdb/lsm/manager/QueryManager.java | 32 +
.../apache/iotdb/lsm/manager/RecoverManager.java | 49 +
.../org/apache/iotdb/lsm/manager/WALManager.java | 126 ++
.../apache/iotdb/lsm/request/IDeletionRequest.java | 30 +
.../iotdb/lsm/request/IInsertionRequest.java | 30 +
.../apache/iotdb/lsm/request/IQueryRequest.java | 35 +
.../org/apache/iotdb/lsm/request/IRequest.java | 61 +
.../org/apache/iotdb/lsm/request/RequestType.java | 27 +
.../org/apache/iotdb/lsm/response/IResponse.java | 46 +
.../iotdb/lsm/strategy/BFSAccessStrategy.java | 66 +
.../apache/iotdb/lsm/strategy/IAccessStrategy.java | 36 +
.../lsm/strategy/PostOrderAccessStrategy.java | 56 +
.../iotdb/lsm/strategy/PreOrderAccessStrategy.java | 54 +
.../iotdb/lsm/strategy/RBFSAccessStrategy.java | 85 +
.../java/org/apache/iotdb/lsm/wal/IWALReader.java | 48 +
.../java/org/apache/iotdb/lsm/wal/IWALRecord.java | 50 +
.../java/org/apache/iotdb/lsm/wal/IWALWriter.java | 47 +
.../java/org/apache/iotdb/lsm/wal/WALReader.java | 99 +
.../java/org/apache/iotdb/lsm/wal/WALWriter.java | 111 ++
.../tagSchemaRegion/TagSchemaRegionTest.java | 231 +++
.../idtable/IDTableWithDeviceIDListImplTest.java | 212 ++
.../tagIndex/TagTagInvertedIndexTest.java | 184 ++
server/pom.xml | 10 -
.../src/assembly/resources/conf/datanode-env.bat | 25 +-
server/src/assembly/resources/conf/datanode-env.sh | 10 +
.../resources/conf/iotdb-datanode.properties | 1124 +----------
.../assembly/resources/conf/iotdb-rest.properties | 3 +
.../assembly/resources/conf/logback-datanode.xml | 302 +++
.../src/assembly/resources/conf/logback-tool.xml | 16 +-
server/src/assembly/resources/conf/logback.xml | 302 ---
.../assembly/resources/sbin/remove-datanode.bat | 2 +-
.../src/assembly/resources/sbin/remove-datanode.sh | 45 +-
.../src/assembly/resources/sbin/start-datanode.bat | 44 +-
.../src/assembly/resources/sbin/start-datanode.sh | 194 +-
.../assembly/resources/sbin/start-new-server.bat | 57 +-
.../assembly/resources/sbin/start-new-server.sh | 182 +-
.../src/assembly/resources/sbin/start-server.bat | 126 --
server/src/assembly/resources/sbin/start-server.sh | 151 --
.../src/assembly/resources/sbin/stop-datanode.bat | 13 +-
.../src/assembly/resources/sbin/stop-datanode.sh | 12 +-
server/src/assembly/resources/sbin/stop-server.bat | 38 -
server/src/assembly/resources/sbin/stop-server.sh | 74 -
.../assembly/resources/tools/detect-watermark.sh | 9 +-
.../assembly/resources/tools/rocksdb-transfer.bat | 2 +-
.../assembly/resources/tools/rocksdb-transfer.sh | 2 +-
.../resources/tools/schema/SchemaFileSketcher.sh | 9 +-
.../assembly/resources/tools/schema/mLogParser.sh | 9 +-
.../assembly/resources/tools/start-WalChecker.bat | 2 +-
.../assembly/resources/tools/start-WalChecker.sh | 11 +-
.../tools/tsfileToolSet/print-iotdb-data-dir.sh | 10 +-
.../tsfileToolSet/print-tsfile-resource-files.sh | 11 +-
.../tools/tsfileToolSet/print-tsfile-sketch.bat | 7 +-
.../tools/tsfileToolSet/print-tsfile-sketch.sh | 10 +-
.../tools/tsfileToolSet/print-tsfile-visdata.sh | 9 +-
.../resources/tools/tsfileToolSet/settle.sh | 9 +-
.../tools/tsfileToolSet/split-tsfile-tool.sh | 9 +-
.../tools/tsfileToolSet/validate-tsfile.sh | 9 +-
server/src/assembly/server.xml | 31 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 22 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 14 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 558 +++++-
.../org/apache/iotdb/db/client/ConfigNodeInfo.java | 4 +-
.../iotdb/db/client/DataNodeClientPoolFactory.java | 14 +-
.../iotdb/db/client/DataNodeInternalClient.java | 119 ++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 452 +++--
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 488 ++---
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 150 +-
.../db/conf/directories/DirectoryChecker.java | 106 +
.../iotdb/db/conf/rest/IoTDBRestServiceConfig.java | 11 +
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 3 +
.../db/consensus/DataRegionConsensusImpl.java | 27 +-
.../db/consensus/SchemaRegionConsensusImpl.java | 25 +
.../statemachine/DataRegionStateMachine.java | 16 +
.../statemachine/SchemaRegionStateMachine.java | 2 +-
.../org/apache/iotdb/db/constant/TestConstant.java | 2 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 1017 +---------
.../apache/iotdb/db/engine/StorageEngineV2.java | 159 +-
.../iotdb/db/engine/TsFileMetricManager.java | 7 +-
.../apache/iotdb/db/engine/cache/ChunkCache.java | 2 +-
.../iotdb/db/engine/cache/ChunkCacheMetrics.java | 4 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 7 +-
.../cache/TimeSeriesMetadataCacheMetrics.java | 4 +-
.../engine/compaction/CompactionTaskManager.java | 20 +-
.../RewriteCrossSpaceCompactionSelector.java | 8 +-
.../compaction/inner/InnerSpaceCompactionTask.java | 7 +-
.../sizetiered/SizeTieredCompactionSelector.java | 78 +-
.../inner/utils/MultiTsFileDeviceIterator.java | 4 +-
.../db/engine/compaction/log/TsFileIdentifier.java | 10 +-
.../impl/ReadChunkCompactionPerformer.java | 23 +-
.../writer/CrossSpaceCompactionWriter.java | 2 +-
.../writer/InnerSpaceCompactionWriter.java | 2 +-
.../org/apache/iotdb/db/engine/cq/CQLogReader.java | 47 -
.../org/apache/iotdb/db/engine/cq/CQLogWriter.java | 74 -
.../engine/cq/ContinuousQuerySchemaCheckTask.java | 99 -
.../iotdb/db/engine/cq/ContinuousQueryService.java | 305 ---
.../iotdb/db/engine/cq/ContinuousQueryTask.java | 200 --
.../engine/cq/ContinuousQueryTaskPoolManager.java | 107 -
.../apache/iotdb/db/engine/flush/FlushManager.java | 2 +-
.../iotdb/db/engine/flush/FlushManagerMetrics.java | 4 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 36 +-
.../db/engine/flush/pool/FlushTaskPoolManager.java | 4 +-
.../iotdb/db/engine/load/AlignedChunkData.java | 348 ++--
.../org/apache/iotdb/db/engine/load/ChunkData.java | 39 +-
.../apache/iotdb/db/engine/load/DeletionData.java | 72 +
.../iotdb/db/engine/load/LoadTsFileManager.java | 46 +-
.../iotdb/db/engine/load/NonAlignedChunkData.java | 259 +--
.../apache/iotdb/db/engine/load/TsFileData.java | 45 +
.../iotdb/db/engine/load/TsFileSplitter.java | 454 +++++
.../iotdb/db/engine/memtable/AbstractMemTable.java | 210 +-
.../engine/memtable/AlignedWritableMemChunk.java | 10 +
.../memtable/AlignedWritableMemChunkGroup.java | 5 +
.../apache/iotdb/db/engine/memtable/IMemTable.java | 25 +-
.../db/engine/memtable/IWritableMemChunk.java | 6 +-
.../db/engine/memtable/IWritableMemChunkGroup.java | 2 +
.../iotdb/db/engine/memtable/WritableMemChunk.java | 9 +-
.../db/engine/memtable/WritableMemChunkGroup.java | 25 +-
.../db/engine/querycontext/QueryDataSource.java | 9 +-
.../selectinto/InsertTabletPlanGenerator.java | 252 ---
.../selectinto/InsertTabletPlansIterator.java | 190 --
.../iotdb/db/engine/snapshot/SnapshotLoader.java | 2 +-
.../iotdb/db/engine/snapshot/SnapshotLogger.java | 2 +-
.../iotdb/db/engine/snapshot/SnapshotTaker.java | 18 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 855 ++------
.../db/engine/storagegroup/DataRegionInfo.java | 6 +-
.../db/engine/storagegroup/DataRegionMetrics.java | 4 +-
.../engine/storagegroup/HashLastFlushTimeMap.java | 248 +++
.../storagegroup/IDTableFlushTimeManager.java | 207 --
.../storagegroup/IDTableLastFlushTimeMap.java | 187 ++
.../engine/storagegroup/ILastFlushTimeManager.java | 89 -
.../db/engine/storagegroup/ILastFlushTimeMap.java | 73 +
.../engine/storagegroup/LastFlushTimeManager.java | 268 ---
.../db/engine/storagegroup/TimePartitionInfo.java | 66 +
.../engine/storagegroup/TimePartitionManager.java | 165 ++
.../db/engine/storagegroup/TsFileManager.java | 11 +-
.../db/engine/storagegroup/TsFileProcessor.java | 237 +--
.../engine/storagegroup/TsFileProcessorInfo.java | 2 +-
.../storagegroup/TsFileProcessorInfoMetrics.java | 6 +-
.../db/engine/storagegroup/TsFileResource.java | 18 +-
.../dataregion/HashVirtualPartitioner.java | 58 -
.../dataregion/StorageGroupManager.java | 505 -----
.../dataregion/VirtualPartitioner.java | 39 -
.../storagegroup/timeindex/DeviceTimeIndex.java | 20 +-
.../storagegroup/timeindex/FileTimeIndex.java | 11 +-
.../engine/storagegroup/timeindex/ITimeIndex.java | 5 +
.../storagegroup/timeindex/V012FileTimeIndex.java | 6 +
.../db/engine/trigger/executor/TriggerEngine.java | 64 -
.../trigger/sink/local/LocalIoTDBHandler.java | 12 +-
.../version/SimpleFileVersionController.java | 2 +-
.../iotdb/db/engine/version/VersionController.java | 12 +-
.../iotdb/db/exception/IntoProcessException.java | 27 +
.../SchemaDirCreationFailureException.java | 2 +-
.../metadata/StorageGroupAlreadySetException.java | 4 +-
.../metadata/StorageGroupNotSetException.java | 6 +-
.../SchemaFileLogCorruptedException.java | 34 +
.../exception/query/PathNumOverLimitException.java | 2 +-
.../query/QueryTimeoutRuntimeException.java | 9 +
.../exception/sql/PathNumOverLimitException.java | 2 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 130 +-
.../db/localconfignode/LocalDataPartitionInfo.java | 4 +-
.../localconfignode/LocalDataPartitionTable.java | 2 +-
.../localconfignode/LocalSchemaPartitionTable.java | 2 +-
.../iotdb/db/metadata/LocalSchemaProcessor.java | 110 +-
.../apache/iotdb/db/metadata/MetadataConstant.java | 3 +-
.../db/metadata/cache/DataNodeSchemaCache.java | 2 +-
.../metadata/cache/DataNodeSchemaCacheMetrics.java | 4 +-
.../idtable/AppendOnlyDiskSchemaManager.java | 3 +-
.../apache/iotdb/db/metadata/idtable/IDTable.java | 3 +-
.../db/metadata/idtable/IDTableHashmapImpl.java | 136 +-
.../iotdb/db/metadata/idtable/IDTableManager.java | 14 +-
.../db/metadata/idtable/entry/DeviceEntry.java | 37 +-
.../db/metadata/idtable/entry/DiskSchemaEntry.java | 9 +
.../idtable/entry/InsertMeasurementMNode.java | 20 +
.../iotdb/db/metadata/mnode/EntityMNode.java | 38 +
.../iotdb/db/metadata/mnode/IEntityMNode.java | 8 +
.../org/apache/iotdb/db/metadata/mnode/IMNode.java | 8 +
.../iotdb/db/metadata/mnode/InternalMNode.java | 41 +-
.../apache/iotdb/db/metadata/mnode/MNodeType.java | 2 +-
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 14 +
.../db/metadata/mnode/StorageGroupEntityMNode.java | 4 +-
.../iotdb/db/metadata/mtree/ConfigMTree.java | 147 +-
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 88 +-
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 646 +++++-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 284 ++-
.../mtree/snapshot/MemMTreeSnapshotUtil.java | 4 +-
.../db/metadata/mtree/store/CachedMTreeStore.java | 29 +-
.../iotdb/db/metadata/mtree/store/IMTreeStore.java | 14 +
.../db/metadata/mtree/store/MemMTreeStore.java | 2 +-
.../mtree/store/disk/schemafile/ISchemaFile.java | 9 +-
.../mtree/store/disk/schemafile/ISchemaPage.java | 3 +
.../mtree/store/disk/schemafile/InternalPage.java | 2 +-
.../store/disk/schemafile/MockSchemaFile.java | 8 +-
.../mtree/store/disk/schemafile/RecordUtils.java | 27 +-
.../mtree/store/disk/schemafile/SchemaFile.java | 115 +-
.../store/disk/schemafile/SchemaFileConfig.java | 28 +-
.../mtree/store/disk/schemafile/SchemaPage.java | 14 +-
.../mtree/store/disk/schemafile/SegmentedPage.java | 7 +
.../disk/schemafile/log/SchemaFileLogReader.java | 112 ++
.../schemafile/log/SchemaFileLogSerializer.java | 34 +
.../disk/schemafile/log/SchemaFileLogWriter.java | 68 +
.../disk/schemafile/pagemgr/BTreePageManager.java | 7 +-
.../disk/schemafile/pagemgr/IPageManager.java | 2 +
.../store/disk/schemafile/pagemgr/PageManager.java | 146 +-
.../db/metadata/mtree/traverser/Traverser.java | 21 +-
.../mtree/traverser/collector/MNodeCollector.java | 2 +-
.../traverser/collector/MeasurementCollector.java | 3 +-
.../traverser/collector/StorageGroupCollector.java | 2 +-
.../traverser/counter/StorageGroupCounter.java | 2 +-
.../plan/schemaregion/SchemaRegionPlanType.java | 6 +-
.../plan/schemaregion/SchemaRegionPlanVisitor.java | 17 +
.../impl/ActivateTemplateInClusterPlanImpl.java | 8 +-
.../impl/DeactivateTemplatePlanImpl.java | 47 +
.../impl/PreDeactivateTemplatePlanImpl.java | 47 +
.../RollbackPreDeactivateTemplatePlanImpl.java | 47 +
.../impl/SchemaRegionPlanDeserializer.java | 43 +
.../schemaregion/impl/SchemaRegionPlanFactory.java | 24 +
.../impl/SchemaRegionPlanSerializer.java | 51 +
.../impl/SchemaRegionPlanTxtSerializer.java | 35 +
.../write/IActivateTemplateInClusterPlan.java | 4 +-
.../write/IDeactivateTemplatePlan.java | 45 +
.../write/IPreDeactivateTemplatePlan.java | 45 +
.../write/IRollbackPreDeactivateTemplatePlan.java | 45 +
.../db/metadata/rescon/SchemaResourceManager.java | 2 +-
.../rescon/SchemaStatisticsManagerMetrics.java | 4 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 22 +-
.../db/metadata/schemaregion/SchemaEngine.java | 52 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 413 ++--
.../schemaregion/SchemaRegionSchemaFileImpl.java | 705 +++----
.../metadata/schemaregion/SchemaRegionUtils.java | 48 -
.../storagegroup/IStorageGroupSchemaManager.java | 82 +-
.../storagegroup/StorageGroupSchemaManager.java | 8 +-
.../apache/iotdb/db/metadata/tag/TagLogFile.java | 2 +-
.../apache/iotdb/db/metadata/tag/TagManager.java | 58 +-
.../metadata/template/ClusterTemplateManager.java | 59 +-
.../iotdb/db/metadata/template/Template.java | 5 +-
.../metadata/template/TemplateInternalRPCUtil.java | 99 +
.../db/metadata/upgrade/MetadataUpgrader.java | 6 +-
.../iotdb/db/metadata/utils/MetaFormatUtils.java | 2 +-
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 2 +-
.../metadata/visitor/SchemaExecutionVisitor.java | 38 +
.../iotdb/db/mpp/common/MPPQueryContext.java | 19 +-
.../org/apache/iotdb/db/mpp/common/QueryId.java | 2 +
.../apache/iotdb/db/mpp/common/SessionInfo.java | 19 +
.../db/mpp/common/header/ColumnHeaderConstant.java | 359 ++--
.../db/mpp/common/header/DatasetHeaderFactory.java | 18 +-
.../mpp/common/schematree/ClusterSchemaTree.java | 11 +-
.../db/mpp/common/schematree/ISchemaTree.java | 6 +-
.../common/schematree/node/SchemaEntityNode.java | 1 +
.../iotdb/db/mpp/execution/StateMachine.java | 3 -
.../db/mpp/execution/exchange/ISourceHandle.java | 10 +
.../db/mpp/execution/exchange/LocalSinkHandle.java | 14 +-
.../mpp/execution/exchange/LocalSourceHandle.java | 33 +-
.../execution/exchange/MPPDataExchangeManager.java | 28 +-
.../execution/exchange/MPPDataExchangeService.java | 10 +-
.../exchange/MPPDataExchangeServiceMetrics.java | 4 +-
.../MPPDataExchangeServiceThriftHandler.java | 2 +-
...MppDataExchangeServiceThriftHandlerMetrics.java | 6 +-
.../mpp/execution/exchange/SharedTsBlockQueue.java | 2 +-
.../db/mpp/execution/exchange/SinkHandle.java | 98 +-
.../db/mpp/execution/exchange/SourceHandle.java | 38 +-
.../execution/executor/RegionWriteExecutor.java | 82 +-
.../fragment/FragmentInstanceContext.java | 40 +-
.../fragment/FragmentInstanceExecution.java | 11 +-
.../fragment/FragmentInstanceFailureInfo.java | 212 ++
.../execution/fragment/FragmentInstanceInfo.java | 21 +-
.../fragment/FragmentInstanceManager.java | 41 +-
.../fragment/FragmentInstanceStateMachine.java | 14 +-
.../db/mpp/execution/operator/OperatorContext.java | 5 +
.../operator/process/AbstractIntoOperator.java | 384 ++++
.../operator/process/DeviceViewIntoOperator.java | 140 ++
.../operator/process/FilterAndProjectOperator.java | 10 +-
.../execution/operator/process/IntoOperator.java | 104 +
.../process/RawDataAggregationOperator.java | 2 +-
.../process/SingleInputAggregationOperator.java | 2 -
.../process/SlidingWindowAggregationOperator.java | 2 +-
.../operator/process/TransformOperator.java | 6 +-
.../operator/schema/CountMergeOperator.java | 65 +-
.../operator/schema/NodePathsCountOperator.java | 35 +-
.../schema/PathsUsingTemplateScanOperator.java | 21 +-
.../operator/schema/SchemaFetchMergeOperator.java | 2 +-
.../operator/schema/SchemaFetchScanOperator.java | 2 +-
.../schema/SchemaQueryOrderByHeatOperator.java | 133 +-
.../schema/TimeSeriesSchemaScanOperator.java | 9 +-
.../execution/schedule/AbstractDriverThread.java | 60 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 40 +-
.../mpp/execution/schedule/DriverTaskThread.java | 5 +-
.../schedule/DriverTaskTimeoutSentinelThread.java | 5 +-
.../db/mpp/execution/schedule/ThreadProducer.java | 32 +
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 38 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 46 +
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 300 ++-
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 22 +-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 20 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 53 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 59 +-
.../mpp/plan/analyze/ExpressionTypeAnalyzer.java | 12 +-
.../db/mpp/plan/analyze/IPartitionFetcher.java | 8 +-
.../iotdb/db/mpp/plan/analyze/SelectIntoUtils.java | 105 +
.../plan/analyze/StandalonePartitionFetcher.java | 4 +-
.../db/mpp/plan/analyze/cache/PartitionCache.java | 121 +-
.../iotdb/db/mpp/plan/constant/StatementType.java | 4 +-
.../db/mpp/plan/execution/IQueryExecution.java | 7 +
.../db/mpp/plan/execution/QueryExecution.java | 81 +-
.../mpp/plan/execution/config/ConfigExecution.java | 33 +-
.../plan/execution/config/ConfigTaskVisitor.java | 79 +-
.../config/executor/ClusterConfigTaskExecutor.java | 597 ++++--
.../config/executor/IConfigTaskExecutor.java | 35 +-
.../executor/StandaloneConfigTaskExecutor.java | 119 +-
.../config/metadata/CreateContinuousQueryTask.java | 49 +
.../config/metadata/CreateFunctionTask.java | 15 +-
.../config/metadata/DropContinuousQueryTask.java | 42 +
.../execution/config/metadata/GetRegionIdTask.java | 76 +
.../execution/config/metadata/GetRegionTask.java | 76 -
.../config/metadata/SetStorageGroupTask.java | 2 +-
.../config/metadata/ShowClusterDetailsTask.java | 150 ++
.../execution/config/metadata/ShowClusterTask.java | 8 +-
.../config/metadata/ShowContinuousQueriesTask.java | 75 +
.../config/metadata/ShowFunctionsTask.java | 160 +-
.../template/DeactivateSchemaTemplateTask.java | 45 +
.../metadata/template/DropSchemaTemplateTask.java | 42 +
.../metadata/template/UnsetSchemaTemplateTask.java | 45 +
.../execution/config/sys/sync/ShowPipeTask.java | 3 +-
.../plan/execution/memory/MemorySourceHandle.java | 22 +
.../memory/StatementMemorySourceVisitor.java | 9 +-
.../iotdb/db/mpp/plan/expression/Expression.java | 5 +
.../db/mpp/plan/expression/ExpressionType.java | 2 +
.../mpp/plan/expression/leaf/ConstantOperand.java | 4 +-
.../db/mpp/plan/expression/leaf/NullOperand.java | 101 +
.../plan/expression/leaf/TimeSeriesOperand.java | 9 +
.../plan/expression/unary/NegationExpression.java | 2 +
.../visitor/ColumnTransformerVisitor.java | 17 +
.../plan/expression/visitor/ExpressionVisitor.java | 5 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 445 ++++-
.../db/mpp/plan/parser/StatementGenerator.java | 25 +-
.../plan/planner/LocalExecutionPlanContext.java | 13 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 7 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 53 +-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 11 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 132 +-
.../planner/distribution/ExchangeNodeAdder.java | 6 +-
.../SimpleFragmentParallelPlanner.java | 1 +
.../plan/planner/distribution/SourceRewriter.java | 99 +-
.../distribution/WriteFragmentParallelPlanner.java | 3 +-
.../db/mpp/plan/planner/plan/FragmentInstance.java | 22 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 53 +
.../mpp/plan/planner/plan/node/PlanNodeType.java | 22 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 25 +
.../plan/node/load/LoadSingleTsFileNode.java | 368 +---
.../planner/plan/node/load/LoadTsFileNode.java | 16 +-
.../plan/node/load/LoadTsFilePieceNode.java | 44 +-
.../metedata/read/AbstractSchemaMergeNode.java | 5 +
.../node/metedata/read/CountSchemaMergeNode.java | 5 +
.../plan/node/metedata/read/DevicesCountNode.java | 6 +
.../metedata/read/LevelTimeSeriesCountNode.java | 7 +
.../read/NodeManagementMemoryMergeNode.java | 5 +
.../node/metedata/read/NodePathsConvertNode.java | 5 +
.../node/metedata/read/NodePathsCountNode.java | 5 +
.../metedata/read/NodePathsSchemaScanNode.java | 7 +
.../metedata/read/PathsUsingTemplateScanNode.java | 43 +-
.../node/metedata/read/SchemaFetchScanNode.java | 2 +-
.../node/metedata/read/SchemaQueryMergeNode.java | 2 +-
.../metedata/read/SchemaQueryOrderByHeatNode.java | 4 +-
.../node/metedata/read/SchemaQueryScanNode.java | 12 +-
.../node/metedata/read/TimeSeriesCountNode.java | 7 +
.../metedata/write/CreateMultiTimeSeriesNode.java | 81 +-
.../metedata/write/DeactivateTemplateNode.java | 128 ++
.../plan/node/metedata/write/MeasurementGroup.java | 89 +
.../metedata/write/PreDeactivateTemplateNode.java | 128 ++
.../write/RollbackPreDeactivateTemplateNode.java | 130 ++
.../planner/plan/node/process/AggregationNode.java | 23 +-
.../planner/plan/node/process/DeviceMergeNode.java | 32 +-
.../plan/node/process/DeviceViewIntoNode.java | 117 ++
.../planner/plan/node/process/DeviceViewNode.java | 19 +-
.../planner/plan/node/process/ExchangeNode.java | 41 +-
.../plan/planner/plan/node/process/FillNode.java | 46 +-
.../plan/node/process/GroupByLevelNode.java | 29 +-
.../planner/plan/node/process/GroupByTagNode.java | 17 +-
.../plan/planner/plan/node/process/IntoNode.java | 114 ++
.../plan/planner/plan/node/process/LimitNode.java | 37 +-
.../planner/plan/node/process/MultiChildNode.java | 66 -
.../plan/node/process/MultiChildProcessNode.java | 81 +
.../plan/planner/plan/node/process/OffsetNode.java | 36 +-
.../planner/plan/node/process/ProjectNode.java | 40 +-
.../plan/node/process/SingleChildProcessNode.java | 92 +
.../node/process/SlidingWindowAggregationNode.java | 36 +-
.../plan/planner/plan/node/process/SortNode.java | 29 +-
.../planner/plan/node/process/TimeJoinNode.java | 17 +-
.../planner/plan/node/process/TransformNode.java | 29 +-
.../node/process/last/LastQueryCollectNode.java | 4 +-
.../plan/node/process/last/LastQueryMergeNode.java | 4 +-
.../plan/node/process/last/LastQueryNode.java | 4 +-
.../plan/node/source/LastQueryScanNode.java | 6 +-
.../planner/plan/node/write/InsertRowNode.java | 5 +-
.../planner/plan/node/write/InsertRowsNode.java | 4 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 39 +-
.../planner/plan/node/write/InsertTabletNode.java | 9 +-
.../parameter/DeviceViewIntoPathDescriptor.java | 209 ++
.../planner/plan/parameter/IntoPathDescriptor.java | 169 ++
.../scheduler/AbstractFragInsStateTracker.java | 33 +-
.../db/mpp/plan/scheduler/ClusterScheduler.java | 8 +-
.../scheduler/FixedRateFragInsStateTracker.java | 61 +-
.../plan/scheduler/IFragInstanceStateTracker.java | 6 +
.../mpp/plan/scheduler/SimpleQueryTerminator.java | 30 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 2 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 233 ++-
.../db/mpp/plan/statement/StatementVisitor.java | 42 +-
.../plan/statement/component/FillComponent.java | 12 +
.../plan/statement/component/FromComponent.java | 12 +
.../statement/component/GroupByLevelComponent.java | 17 +
.../statement/component/GroupByTimeComponent.java | 35 +
.../plan/statement/component/HavingCondition.java | 4 +
.../plan/statement/component/IntoComponent.java | 251 +++
.../db/mpp/plan/statement/component/IntoItem.java | 88 +
.../plan/statement/component/OrderByComponent.java | 12 +
.../plan/statement/component/SelectComponent.java | 21 +-
.../db/mpp/plan/statement/component/SortItem.java | 4 +
.../plan/statement/component/WhereCondition.java | 4 +
.../crud/InsertRowsOfOneDeviceStatement.java | 25 +-
.../plan/statement/crud/LoadTsFileStatement.java | 8 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 152 +-
.../mpp/plan/statement/literal/BooleanLiteral.java | 5 +
.../mpp/plan/statement/literal/DoubleLiteral.java | 5 +
.../db/mpp/plan/statement/literal/LongLiteral.java | 5 +
.../db/mpp/plan/statement/literal/NullLiteral.java | 5 +
.../mpp/plan/statement/literal/StringLiteral.java | 5 +
.../plan/statement/metadata/CountStatement.java | 2 +-
.../metadata/CreateContinuousQueryStatement.java | 215 ++
.../metadata/CreateFunctionStatement.java | 28 +-
.../statement/metadata/CreateTriggerStatement.java | 21 +-
.../metadata/DropContinuousQueryStatement.java | 60 +
.../statement/metadata/DropTriggerStatement.java | 22 +-
.../statement/metadata/GetRegionIdStatement.java | 100 +
.../statement/metadata/GetRegionStatement.java | 100 -
.../statement/metadata/ShowClusterStatement.java | 10 +
.../metadata/ShowContinuousQueriesStatement.java | 52 +
.../statement/metadata/ShowDevicesStatement.java | 2 +-
.../metadata/ShowStorageGroupStatement.java | 4 +-
.../template/DeactivateTemplateStatement.java | 80 +
.../template/DropSchemaTemplateStatement.java | 55 +
.../template/ShowPathsUsingTemplateStatement.java | 22 +-
.../template/UnsetSchemaTemplateStatement.java | 74 +
.../db/mpp/plan/statement/sys/FlushStatement.java | 2 +-
.../sys/sync/CreatePipeSinkStatement.java | 7 +-
.../dag/column/ColumnTransformer.java | 31 +
.../binary/CompareBinaryColumnTransformer.java | 7 +-
.../binary/CompareEqualToColumnTransformer.java | 2 +-
.../column/binary/LogicAndColumnTransformer.java | 30 +
.../binary/LogicBinaryColumnTransformer.java | 24 -
.../column/binary/LogicOrColumnTransformer.java | 30 +
.../dag/column/leaf/NullColumnTransformer.java | 38 +
.../ternary/CompareTernaryColumnTransformer.java | 17 +-
.../dag/column/unary/InColumnTransformer.java | 48 +-
.../column/unary/LogicNotColumnTransformer.java | 2 +-
.../dag/column/unary/RegularColumnTransformer.java | 2 +-
.../dag/input/ConstantInputReader.java | 3 +-
.../mpp/transformation/dag/udf/UDTFExecutor.java | 4 +-
.../dag/udf/UDTFInformationInferrer.java | 4 +-
.../transformation/dag/util/TransformUtils.java | 3 +-
.../iotdb/db/protocol/influxdb/dto/IoTDBPoint.java | 32 +-
.../influxdb/handler/AbstractQueryHandler.java | 90 +-
.../protocol/influxdb/handler/NewQueryHandler.java | 114 +-
.../db/protocol/influxdb/handler/QueryHandler.java | 521 -----
.../influxdb/handler/QueryHandlerFactory.java | 45 +
.../protocol/influxdb/handler/TagQueryHandler.java | 140 ++
.../influxdb/meta/AbstractInfluxDBMetaManager.java | 46 +-
.../influxdb/meta/IInfluxDBMetaManager.java | 66 +
.../influxdb/meta/InfluxDBMetaManager.java | 150 --
.../influxdb/meta/InfluxDBMetaManagerFactory.java | 45 +
.../influxdb/meta/NewInfluxDBMetaManager.java | 61 +-
.../influxdb/meta/TagInfluxDBMetaManager.java | 191 ++
.../db/protocol/influxdb/meta/TagInfoRecords.java | 24 -
.../protocol/influxdb/util/QueryResultUtils.java | 109 +-
.../iotdb/db/protocol/mpprest/MPPRestService.java | 162 --
.../protocol/mpprest/filter/ApiOriginFilter.java | 45 -
.../mpprest/filter/AuthorizationFilter.java | 138 --
.../mpprest/filter/BasicSecurityContext.java | 56 -
.../iotdb/db/protocol/mpprest/filter/User.java | 38 -
.../db/protocol/mpprest/filter/UserCache.java | 56 -
.../mpprest/handler/AuthorizationHandler.java | 47 -
.../protocol/mpprest/handler/ExceptionHandler.java | 86 -
.../mpprest/handler/QueryDataSetHandler.java | 279 ---
.../mpprest/handler/RequestValidationHandler.java | 53 -
.../handler/StatementConstructionHandler.java | 165 --
.../mpprest/impl/GrafanaApiServiceImpl.java | 268 ---
.../protocol/mpprest/impl/PingApiServiceImpl.java | 51 -
.../protocol/mpprest/impl/RestApiServiceImpl.java | 203 --
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 41 +-
.../db/protocol/mqtt/PayloadFormatManager.java | 5 +-
.../iotdb/db/protocol/mqtt/PublishHandler.java | 149 --
.../apache/iotdb/db/protocol/rest/RestService.java | 1 +
.../protocol/rest/filter/AuthorizationFilter.java | 20 +-
.../rest/handler/AuthorizationHandler.java | 10 +-
.../db/protocol/rest/handler/ExceptionHandler.java | 15 +-
.../rest/handler/ExecuteStatementHandler.java | 52 +
.../handler/PhysicalPlanConstructionHandler.java | 163 --
.../handler/PhysicalPlanValidationHandler.java | 81 -
.../protocol/rest/handler/QueryDataSetHandler.java | 348 ++--
.../rest/handler/StatementConstructionHandler.java | 166 ++
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 183 +-
.../db/protocol/rest/impl/RestApiServiceImpl.java | 162 +-
.../main/java/org/apache/iotdb/db/qp/Planner.java | 19 -
.../apache/iotdb/db/qp/constant/SQLConstant.java | 170 +-
.../apache/iotdb/db/qp/executor/IPlanExecutor.java | 79 -
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 1520 +-------------
.../db/qp/logical/crud/DeleteDataOperator.java | 15 +-
.../iotdb/db/qp/logical/crud/InsertOperator.java | 31 +-
.../db/qp/logical/sys/CreatePipeOperator.java | 12 +-
.../db/qp/logical/sys/CreatePipeSinkOperator.java | 11 +-
.../db/qp/logical/sys/DeletePartitionOperator.java | 3 +-
.../iotdb/db/qp/logical/sys/DropPipeOperator.java | 4 +-
.../db/qp/logical/sys/DropPipeSinkOperator.java | 4 +-
.../iotdb/db/qp/logical/sys/ShowPipeOperator.java | 4 +-
.../db/qp/logical/sys/ShowPipeSinkOperator.java | 4 +-
.../qp/logical/sys/ShowPipeSinkTypeOperator.java | 4 +-
.../iotdb/db/qp/logical/sys/StartPipeOperator.java | 4 +-
.../iotdb/db/qp/logical/sys/StopPipeOperator.java | 4 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 24 -
.../db/qp/physical/crud/DeletePartitionPlan.java | 53 -
.../iotdb/db/qp/physical/crud/DeletePlan.java | 221 ---
.../iotdb/db/qp/physical/crud/GroupByTimePlan.java | 2 +-
.../qp/physical/crud/InsertMultiTabletsPlan.java | 453 -----
.../iotdb/db/qp/physical/crud/InsertPlan.java | 239 ---
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 812 --------
.../physical/crud/InsertRowsOfOneDevicePlan.java | 296 ---
.../iotdb/db/qp/physical/crud/InsertRowsPlan.java | 302 ---
.../db/qp/physical/crud/InsertTabletPlan.java | 895 ---------
.../sys/ActivateTemplateInClusterPlan.java | 8 +-
.../iotdb/db/qp/physical/sys/CreatePipePlan.java | 110 --
.../db/qp/physical/sys/CreatePipeSinkPlan.java | 98 -
.../iotdb/db/qp/physical/sys/DropPipeSinkPlan.java | 45 -
.../apache/iotdb/db/qp/physical/sys/FlushPlan.java | 4 +-
.../iotdb/db/qp/physical/sys/OperatePipePlan.java | 45 -
.../iotdb/db/qp/physical/sys/ShowPipePlan.java | 33 -
.../iotdb/db/qp/physical/sys/ShowPipeSinkPlan.java | 33 -
.../db/qp/physical/sys/ShowPipeSinkTypePlan.java | 26 -
.../apache/iotdb/db/qp/physical/sys/ShowPlan.java | 3 -
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 148 +-
.../apache/iotdb/db/qp/utils/DateTimeUtils.java | 4 +-
.../iotdb/db/query/context/QueryContext.java | 14 +-
.../db/query/control/QueryResourceManager.java | 17 +-
.../iotdb/db/query/control/QueryTimeManager.java | 46 +-
.../iotdb/db/query/control/SessionManager.java | 412 ++--
.../db/query/control/SessionManagerMBean.java | 30 +
.../db/query/control/SessionTimeoutManager.java | 119 --
.../query/control/clientsession/ClientSession.java | 115 ++
.../control/clientsession/IClientSession.java | 137 ++
.../clientsession/InternalClientSession.java | 97 +
.../control/clientsession/MqttClientSession.java | 82 +
.../iotdb/db/query/dataset/ShowDevicesDataSet.java | 4 +-
.../db/query/dataset/ShowTimeseriesDataSet.java | 4 +-
.../apache/iotdb/db/query/dataset/UDTFDataSet.java | 6 +-
.../db/query/executor/AggregationExecutor.java | 2 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 4 +-
.../apache/iotdb/db/query/executor/fill/IFill.java | 2 +-
.../iotdb/db/query/pool/QueryTaskManager.java | 4 +-
.../db/query/pool/RawQueryReadTaskPoolManager.java | 6 +-
.../pool/RawQueryReadTaskPoolManagerMetrics.java | 4 +-
.../metadata/DiskAlignedChunkMetadataLoader.java | 2 +-
.../chunk/metadata/DiskChunkMetadataLoader.java | 2 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 49 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 238 ++-
.../db/service/DataNodeInternalRPCService.java | 4 +-
.../service/DataNodeInternalRPCServiceMetrics.java | 4 +-
.../db/service/DataNodeServerCommandLine.java | 22 +-
.../org/apache/iotdb/db/service/GetVersion.java | 27 +
.../java/org/apache/iotdb/db/service/IoTDB.java | 54 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 13 +-
.../org/apache/iotdb/db/service/MQTTService.java | 7 +-
.../java/org/apache/iotdb/db/service/NewIoTDB.java | 42 +-
.../org/apache/iotdb/db/service/RPCService.java | 2 +-
.../apache/iotdb/db/service/RPCServiceMetrics.java | 4 +-
.../iotdb/db/service/RegionMigrateService.java | 31 +-
.../db/service/ResourcesInformationHolder.java | 12 +
.../org/apache/iotdb/db/service/SettleService.java | 36 +-
.../org/apache/iotdb/db/service/UpgradeSevice.java | 18 +-
.../iotdb/db/service/basic/ServiceProvider.java | 1 -
.../db/service/metrics/DataNodeMetricsHelper.java | 39 +
.../iotdb/db/service/metrics/FileMetrics.java | 200 ++
.../iotdb/db/service/metrics/MetricService.java | 156 --
.../db/service/metrics/MetricServiceMBean.java | 30 -
.../iotdb/db/service/metrics/ProcessMetrics.java | 189 ++
.../iotdb/db/service/metrics/SystemMetrics.java | 260 +++
.../iotdb/db/service/metrics/enums/Metric.java | 70 -
.../iotdb/db/service/metrics/enums/Operation.java | 39 -
.../apache/iotdb/db/service/metrics/enums/Tag.java | 31 -
.../db/service/metrics/predefined/FileMetrics.java | 200 --
.../service/metrics/predefined/ProcessMetrics.java | 189 --
.../service/metrics/predefined/SystemMetrics.java | 256 ---
.../metrics/recorder/CacheMetricsRecorder.java | 6 +-
.../recorder/CompactionMetricsRecorder.java | 6 +-
.../db/service/thrift/ProcessorWithMetrics.java | 6 +-
.../thrift/handler/BaseServerContextHandler.java | 79 +
.../handler/InfluxDBServiceThriftHandler.java | 11 +-
.../handler/InternalServiceThriftHandler.java | 2 +-
.../InternalServiceThriftHandlerMetrics.java | 4 +-
.../thrift/handler/RPCServiceThriftHandler.java | 21 +-
.../handler/RPCServiceThriftHandlerMetrics.java | 4 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 894 +++++----
.../impl/DataNodeInternalRPCServiceImpl.java | 485 ++++-
.../service/thrift/impl/InfluxDBServiceImpl.java | 184 --
.../thrift/impl/NewInfluxDBServiceImpl.java | 75 +-
.../db/service/thrift/impl/TSServiceImpl.java | 892 ++-------
.../java/org/apache/iotdb/db/sync/SyncService.java | 381 ++--
.../db/sync/common/ClusterSyncInfoFetcher.java | 35 +-
.../iotdb/db/sync/common/ISyncInfoFetcher.java | 7 +-
.../apache/iotdb/db/sync/common/LocalSyncInfo.java | 32 +-
.../iotdb/db/sync/common/LocalSyncInfoFetcher.java | 21 +-
.../iotdb/db/sync/datasource/PipeOpManager.java | 2 +-
.../iotdb/db/sync/datasource/TsFileOpBlock.java | 5 +-
.../db/sync/externalpipe/ExtPipePluginManager.java | 4 +-
.../iotdb/db/sync/pipedata/DeletionPipeData.java | 14 +-
.../apache/iotdb/db/sync/pipedata/PipeData.java | 35 +-
.../iotdb/db/sync/pipedata/SchemaPipeData.java | 100 -
.../iotdb/db/sync/pipedata/TsFilePipeData.java | 32 +-
.../sync/pipedata/queue/BufferedPipeDataQueue.java | 78 +-
.../db/sync/receiver/load/DeletionLoader.java | 47 +-
.../iotdb/db/sync/receiver/load/ILoader.java | 20 +
.../iotdb/db/sync/receiver/load/SchemaLoader.java | 71 -
.../iotdb/db/sync/receiver/load/TsFileLoader.java | 67 +-
.../org/apache/iotdb/db/sync/sender/pipe/Pipe.java | 7 +
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 49 +-
.../db/sync/transport/client/IoTDBSyncClient.java | 12 +-
.../db/sync/transport/client/SenderManager.java | 2 +
.../db/sync/transport/server/ReceiverManager.java | 6 +-
.../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 4 +-
.../apache/iotdb/db/tools/TsFileSelfCheckTool.java | 3 +-
.../apache/iotdb/db/tools/TsFileSketchTool.java | 196 +-
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 10 +-
.../java/org/apache/iotdb/db/tools/WalChecker.java | 2 +-
.../db/tools/dataregion/DeviceMappingViewer.java | 63 -
.../db/tools/schema/SchemaFileSketchTool.java | 7 +
.../db/tools/upgrade/TsFileOnlineUpgradeTool.java | 6 +-
.../db/tools/validate/TsFileValidationTool.java | 2 +-
.../iotdb/db/trigger/executor/TriggerExecutor.java | 56 +-
.../db/trigger/executor/TriggerFireResult.java | 57 +
.../db/trigger/executor/TriggerFireVisitor.java | 423 ++++
.../trigger/service/TriggerInformationUpdater.java | 104 +
.../trigger/service/TriggerManagementService.java | 122 +-
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 27 +-
.../java/org/apache/iotdb/db/utils/FilesUtils.java | 43 +
.../org/apache/iotdb/db/utils/JarLoaderUtil.java | 150 --
.../java/org/apache/iotdb/db/utils/MemUtils.java | 54 -
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 35 +-
.../java/org/apache/iotdb/db/utils/QueryUtils.java | 16 +-
.../apache/iotdb/db/utils/TimePartitionUtils.java | 4 +
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 6 +-
.../db/utils/datastructure/AlignedTVList.java | 4 +-
.../iotdb/db/utils/datastructure/BinaryTVList.java | 17 +-
.../db/utils/datastructure/BooleanTVList.java | 13 +-
.../iotdb/db/utils/datastructure/DoubleTVList.java | 13 +-
.../iotdb/db/utils/datastructure/FloatTVList.java | 13 +-
.../iotdb/db/utils/datastructure/IntTVList.java | 13 +-
.../iotdb/db/utils/datastructure/LongTVList.java | 13 +-
.../iotdb/db/utils/datastructure/TVList.java | 20 +-
.../apache/iotdb/db/utils/sync/SyncPipeUtil.java | 49 +-
.../runtime/WindowEvaluationTaskPoolManager.java | 5 +-
.../java/org/apache/iotdb/db/wal/WALManager.java | 30 +-
.../iotdb/db/wal/allocation/ElasticStrategy.java | 103 +
.../db/wal/allocation/RoundRobinStrategy.java | 4 +-
.../org/apache/iotdb/db/wal/buffer/WALEntry.java | 23 +-
.../apache/iotdb/db/wal/buffer/WALEntryType.java | 7 +-
.../apache/iotdb/db/wal/buffer/WALInfoEntry.java | 20 +-
.../org/apache/iotdb/db/wal/node/IWALNode.java | 11 -
.../org/apache/iotdb/db/wal/node/WALFakeNode.java | 19 -
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 125 +-
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 2 +-
.../iotdb/db/wal/recover/WALRecoverManager.java | 6 +-
.../db/wal/recover/file/TsFilePlanRedoer.java | 103 +-
.../file/UnsealedTsFileRecoverPerformer.java | 13 +-
.../apache/iotdb/db/conf/IoTDBDescriptorTest.java | 6 +-
.../engine/compaction/AbstractCompactionTest.java | 69 +-
.../engine/compaction/CompactionSchedulerTest.java | 383 ++--
.../ReadPointCompactionPerformerTest.java | 158 +-
.../cross/CrossSpaceCompactionExceptionTest.java | 3 +-
.../compaction/cross/CrossSpaceCompactionTest.java | 20 +-
.../cross/CrossSpaceCompactionValidationTest.java | 3 +-
.../cross/RewriteCompactionFileSelectorTest.java | 14 +-
.../RewriteCrossSpaceCompactionRecoverTest.java | 3 +-
.../cross/RewriteCrossSpaceCompactionTest.java | 16 +-
.../inner/InnerCompactionEmptyTsFileTest.java | 1 +
.../inner/InnerCompactionMoreDataTest.java | 60 +-
.../inner/InnerCompactionSchedulerTest.java | 13 +-
.../compaction/inner/InnerCompactionTest.java | 20 +-
.../compaction/inner/InnerSeqCompactionTest.java | 6 +-
.../ReadChunkCompactionPerformerAlignedTest.java | 79 +
.../ReadChunkCompactionPerformerNoAlignedTest.java | 18 +-
.../inner/ReadChunkCompactionPerformerOldTest.java | 2 +-
.../inner/sizetiered/SizeTieredCompactionTest.java | 8 +-
...eCrossSpaceCompactionRecoverCompatibleTest.java | 3 +-
.../SizeTieredCompactionRecoverCompatibleTest.java | 3 +-
.../compaction/utils/CompactionCheckerUtils.java | 9 +-
.../compaction/utils/CompactionConfigRestorer.java | 2 +-
.../utils/MultiTsFileDeviceIteratorTest.java | 120 ++
.../db/engine/memtable/MemTableFlushTaskTest.java | 6 +-
.../db/engine/memtable/MemTableTestUtils.java | 69 +-
.../db/engine/memtable/PrimitiveMemTableTest.java | 65 +-
.../engine/modification/DeletionFileNodeTest.java | 433 ----
.../db/engine/modification/DeletionQueryTest.java | 362 ----
.../db/engine/storagegroup/DataRegionTest.java | 148 +-
.../storagegroup/FileNodeManagerBenchmark.java | 132 --
.../storagegroup/IDTableLastFlushTimeMapTest.java | 129 ++
.../engine/storagegroup/LastFlushTimeMapTest.java | 223 +++
.../storagegroup/StorageGroupProcessorTest.java | 871 ---------
.../iotdb/db/engine/storagegroup/TTLTest.java | 158 +-
.../storagegroup/TimePartitionManagerTest.java | 129 ++
.../engine/storagegroup/TsFileProcessorTest.java | 476 -----
.../engine/storagegroup/TsFileProcessorV2Test.java | 12 +-
.../dataregion/HashVirtualPartitionerTest.java | 63 -
.../LocalConfigNodeMultiDataRegionTest.java | 4 -
.../apache/iotdb/db/metadata/SchemaBasicTest.java | 316 +--
.../org/apache/iotdb/db/metadata/TemplateTest.java | 151 +-
.../db/metadata/idtable/IDTableFlushTimeTest.java | 226 ---
.../db/metadata/idtable/IDTableLogFileTest.java | 239 ++-
.../db/metadata/idtable/IDTableRecoverTest.java | 354 ++--
.../idtable/IDTableResourceControlTest.java | 167 --
.../db/metadata/idtable/IDTableRestartTest.java | 205 --
.../iotdb/db/metadata/idtable/IDTableTest.java | 1479 +++++++-------
.../db/metadata/idtable/InsertWithIDTableTest.java | 759 -------
.../db/metadata/idtable/LastQueryWithIDTable.java | 285 ++-
.../QueryAlignedTimeseriesWithIDTableTest.java | 373 ----
.../db/metadata/idtable/QueryWithIDTableTest.java | 375 ----
.../iotdb/db/metadata/mtree/ConfigMTreeTest.java | 10 +-
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 2 +-
.../mtree/schemafile/SchemaFileLogTest.java | 156 ++
.../metadata/mtree/schemafile/SchemaFileTest.java | 25 +-
.../iotdb/db/metadata/path/PatternTreeMapTest.java | 88 +-
.../plan/SchemaRegionPlanCompatibilityTest.java | 22 +-
.../schemaRegion/SchemaRegionBasicTest.java | 589 ++++++
.../db/metadata/schemaRegion/SchemaRegionTest.java | 168 --
.../multimode/SchemaRegionFullMemoryTest.java | 43 +
.../multimode/SchemaRegionMemoryTest.java | 46 +
.../multimode/SchemaRegionNonMemoryTest.java | 43 +
.../multimode/SchemaRegionPartialMemoryTest.java | 43 +
.../multimode/SchemaRegionSchemaFileTest.java | 46 +
.../apache/iotdb/db/metric/MetricServiceTest.java | 19 +
.../common/schematree/ClusterSchemaTreeTest.java | 25 +
.../db/mpp/common/schematree/NodeRefTest.java | 47 +
.../db/mpp/execution/exchange/SinkHandleTest.java | 28 +-
.../FragmentInstanceFailureInfoSerdeTest.java | 85 +
.../mpp/execution/operator/OperatorMemoryTest.java | 6 +-
.../operator/schema/CountMergeOperatorTest.java | 4 +-
.../schema/SchemaQueryScanOperatorTest.java | 6 +-
.../DriverTaskTimeoutSentinelThreadTest.java | 23 +-
.../db/mpp/plan/StandaloneCoordinatorTest.java | 19 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeFailTest.java | 87 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeTest.java | 183 +-
.../mpp/plan/analyze/cache/PartitionCacheTest.java | 6 +-
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 10 +-
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 42 +-
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 17 +-
.../plan/plan/node/process/IntoNodeSerdeTest.java | 83 +
.../plan/scheduler/StandaloneSchedulerTest.java | 20 +-
.../iotdb/db/protocol/mqtt/PublishHandlerTest.java | 132 --
.../db/protocol/rest/GrafanaApiServiceTest.java | 3 +
.../db/protocol/rest/IoTDBRestServiceTest.java | 17 +-
.../java/org/apache/iotdb/db/qp/PlannerTest.java | 71 +-
.../iotdb/db/qp/logical/LogicalPlanSmallTest.java | 4 +-
.../iotdb/db/qp/other/TSPlanContextAuthorTest.java | 2 +-
.../iotdb/db/qp/physical/ConcatOptimizerTest.java | 138 --
.../iotdb/db/qp/physical/InsertRowPlanTest.java | 395 ----
.../qp/physical/InsertRowsOfOneDevicePlanTest.java | 75 -
.../db/qp/physical/InsertTabletMultiPlanTest.java | 300 ---
.../iotdb/db/qp/physical/InsertTabletPlanTest.java | 449 -----
.../db/qp/physical/PhysicalPlanSerializeTest.java | 326 ----
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 1475 --------------
.../iotdb/db/qp/physical/SerializationTest.java | 151 --
.../iotdb/db/qp/physical/SerializedSizeTest.java | 130 --
.../dataset/EngineDataSetWithValueFilterTest.java | 159 --
.../iotdb/db/query/dataset/ListDataSetTest.java | 12 +-
.../iotdb/db/query/dataset/SingleDataSetTest.java | 199 +-
.../query/dataset/UDTFAlignByTimeDataSetTest.java | 2 +
.../query/dataset/groupby/GroupByDataSetTest.java | 226 ---
.../dataset/groupby/GroupByFillDataSetTest.java | 194 --
.../dataset/groupby/GroupByLevelDataSetTest.java | 161 --
.../valuefilter/RawQueryWithValueFilterTest.java | 147 --
.../org/apache/iotdb/db/service/DaemonTest.java | 39 +
.../apache/iotdb/db/sink/LocalIoTDBSinkTest.java | 218 ---
.../org/apache/iotdb/db/sink/MQTTSinkTest.java | 210 --
.../db/sync/persistence/LocalSyncInfoTest.java | 104 +
.../iotdb/db/sync/persistence/SyncLogTest.java | 121 ++
.../sync/pipedata/BufferedPipeDataQueueTest.java | 108 +-
.../iotdb/db/sync/pipedata/PipeDataTest.java | 26 -
.../sync/receiver/manager/LocalSyncInfoTest.java | 95 -
.../db/sync/receiver/recovery/SyncLogTest.java | 123 --
.../iotdb/db/sync/transport/SyncTransportTest.java | 357 ----
.../apache/iotdb/db/tools/IoTDBWatermarkTest.java | 246 ---
.../iotdb/db/tools/SchemaFileSketchTest.java | 2 +-
.../iotdb/db/tools/TsFileAndModSettleToolTest.java | 397 ++--
.../org/apache/iotdb/db/tools/WalCheckerTest.java | 16 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 37 +-
.../org/apache/iotdb/db/utils/MemUtilsTest.java | 35 +-
.../iotdb/db/utils/TsFileRewriteToolTest.java | 62 +-
.../iotdb/db/utils/TypeInferenceUtilsTest.java | 2 +
.../db/utils/datastructure/PrecisionTest.java | 8 +-
.../db/utils/writelog/LogWriterReaderTest.java | 50 +-
.../db/utils/writelog/MultiFileLogReaderTest.java | 15 +-
.../org/apache/iotdb/db/wal/WALManagerTest.java | 62 +-
.../db/wal/allocation/ElasticStrategyTest.java | 134 ++
.../db/wal/allocation/FirstCreateStrategyTest.java | 21 +-
.../db/wal/allocation/RoundRobinStrategyTest.java | 19 +-
.../iotdb/db/wal/buffer/WALBufferCommonTest.java | 68 +-
.../org/apache/iotdb/db/wal/io/WALFileTest.java | 119 +-
.../apache/iotdb/db/wal/node/WALFakeNodeTest.java | 22 +-
.../org/apache/iotdb/db/wal/node/WALNodeTest.java | 90 +-
.../db/wal/recover/WALRecoverManagerTest.java | 116 +-
.../file/SealedTsFileRecoverPerformerTest.java | 32 +-
.../db/wal/recover/file/TsFilePlanRedoerTest.java | 244 ++-
.../file/UnsealedTsFileRecoverPerformerTest.java | 60 +-
.../datanode1conf/iotdb-common.properties | 22 +
.../datanode1conf/iotdb-datanode-metric.yml | 48 +
.../datanode1conf/iotdb-datanode.properties | 31 +-
.../test/resources/datanode1conf/iotdb-metric.yml | 53 -
.../resources/datanode1conf/iotdb-rest.properties | 45 +-
.../datanode2conf/iotdb-common.properties | 22 +
.../datanode2conf/iotdb-datanode-metric.yml | 48 +
.../datanode2conf/iotdb-datanode.properties | 31 +-
.../test/resources/datanode2conf/iotdb-metric.yml | 53 -
.../resources/datanode2conf/iotdb-rest.properties | 43 -
.../datanode3conf/iotdb-common.properties | 22 +
.../datanode3conf/iotdb-datanode-metric.yml | 48 +
.../datanode3conf/iotdb-datanode.properties | 31 +-
.../test/resources/datanode3conf/iotdb-metric.yml | 53 -
.../resources/datanode3conf/iotdb-rest.properties | 45 +-
.../src/test/resources/iotdb-datanode.properties | 10 +-
server/src/test/resources/iotdb-rest.properties | 3 +
server/src/test/resources/logback-test.xml | 2 +-
service-rpc/pom.xml | 8 +
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 355 ++--
.../apache/iotdb/rpc/TElasticFramedTransport.java | 4 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 23 +-
.../rpc/TimeoutChangeableTFastFramedTransport.java | 8 +-
.../TimeoutChangeableTSnappyFramedTransport.java | 8 +-
.../java/org/apache/iotdb/session/ISession.java | 22 +-
.../java/org/apache/iotdb/session/Session.java | 290 ++-
.../org/apache/iotdb/session/SessionConfig.java | 2 +-
.../apache/iotdb/session/SessionConnection.java | 52 +-
.../org/apache/iotdb/session/SessionDataSet.java | 35 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 424 +++-
.../apache/iotdb/session/SessionCacheLeaderUT.java | 4 +-
.../src/test/resources/iotdb-datanode.properties | 23 +
session/src/test/resources/iotdb-engine.properties | 20 -
session/src/test/resources/iotdb-rest.properties | 3 +
site/src/main/.vuepress/config.js | 65 +-
.../src/test/resources/iotdb-datanode.properties | 23 +
.../src/test/resources/iotdb-engine.properties | 21 -
.../apache/iotdb/spark/db/EnvironmentUtils.java | 26 +-
.../org/apache/iotdb/spark/db/IoTDBTest.scala | 2 +
.../org/apache/iotdb/spark/db/IoTDBWriteTest.scala | 1 +
.../iotdb/spark/tsfile/qp/common/SQLConstant.java | 123 +-
.../apache/iotdb/spark/tsfile/DefaultSource.scala | 10 +-
.../iotdb/spark/tsfile/NarrowConverter.scala | 181 +-
.../org/apache/iotdb/spark/tsfile/TSFileSuit.scala | 30 +-
test/e2e/cases/cli/res/init.sql | 4 +-
.../java/org/apache/iotdb/db/sql/ClusterIT.java | 2 +-
.../test/java/org/apache/iotdb/db/sync/SyncIT.java | 6 +-
.../src/test/resources/iotdb-datanode.properties | 2 +-
thrift-commons/src/main/thrift/common.thrift | 2 +-
.../src/main/thrift/confignode.thrift | 296 ++-
.../src/main/thrift/mutlileader.thrift | 21 +
thrift/src/main/thrift/client.thrift | 43 +-
thrift/src/main/thrift/datanode.thrift | 138 +-
.../iotdb/tsfile/common/conf/TSFileConfig.java | 24 +-
.../iotdb/tsfile/common/conf/TSFileDescriptor.java | 4 +-
.../tsfile/common/constant/TsFileConstant.java | 4 +
.../iotdb/tsfile/file/header/ChunkHeader.java | 21 +
.../iotdb/tsfile/file/header/PageHeader.java | 10 +-
.../file/metadata/AlignedTimeSeriesMetadata.java | 15 +
.../iotdb/tsfile/file/metadata/ChunkMetadata.java | 18 +
.../tsfile/file/metadata/TimeseriesMetadata.java | 7 +
.../iotdb/tsfile/read/TsFileDeviceIterator.java | 34 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 130 +-
.../org/apache/iotdb/tsfile/read/common/Path.java | 81 +-
.../iotdb/tsfile/read/common/block/TsBlock.java | 5 +-
.../read/common/block/column/NullColumn.java | 87 +-
.../read/controller/MetadataQuerierByFileImpl.java | 3 +-
.../iotdb/tsfile/read/filter/operator/Regexp.java | 48 +-
.../java/org/apache/iotdb/tsfile/utils/BitMap.java | 6 +
.../org/apache/iotdb/tsfile/utils/BytesUtils.java | 4 +-
.../apache/iotdb/tsfile/utils/FilePathUtils.java | 4 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 28 +
.../iotdb/tsfile/utils/TsFileGeneratorUtils.java | 2 +-
.../apache/iotdb/tsfile/write/TsFileWriter.java | 4 +-
.../write/chunk/AlignedChunkGroupWriterImpl.java | 6 +-
.../tsfile/write/chunk/AlignedChunkWriterImpl.java | 16 +
.../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 1 +
.../tsfile/write/chunk/IChunkGroupWriter.java | 4 +-
.../iotdb/tsfile/write/chunk/TimeChunkWriter.java | 1 +
.../iotdb/tsfile/write/chunk/ValueChunkWriter.java | 12 +-
.../apache/iotdb/tsfile/write/record/Tablet.java | 341 +++-
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 34 +-
.../write/writer/TsFileIOWriterEndFileTest.java | 49 +
.../write/writer/tsmiterator/DiskTSMIterator.java | 7 +-
.../write/writer/tsmiterator/TSMIterator.java | 9 +-
.../tsfile/common/block/TsBlockSerdeTest.java | 4 +-
...easurementChunkMetadataListMapIteratorTest.java | 2 +-
.../iotdb/tsfile/read/ReadInPartitionTest.java | 22 +-
.../org/apache/iotdb/tsfile/read/ReadTest.java | 54 +-
.../iotdb/tsfile/read/TimePlainEncodeReadTest.java | 55 +-
.../tsfile/read/TimeSeriesMetadataReadTest.java | 4 +-
.../apache/iotdb/tsfile/read/TsFileReaderTest.java | 126 +-
.../tsfile/read/controller/ChunkLoaderTest.java | 2 +-
.../controller/IMetadataQuerierByFileImplTest.java | 16 +-
.../read/filter/IExpressionOptimizerTest.java | 30 +-
.../read/query/executor/QueryExecutorTest.java | 32 +-
.../read/query/timegenerator/ReadWriteTest.java | 8 +-
.../query/timegenerator/ReaderByTimestampTest.java | 2 +-
.../timegenerator/TimeGeneratorReadEmptyTest.java | 8 +-
.../timegenerator/TimeGeneratorReadWriteTest.java | 8 +-
.../query/timegenerator/TimeGeneratorTest.java | 6 +-
.../iotdb/tsfile/read/reader/ChunkReaderTest.java | 2 +-
.../tsfile/read/reader/FakedTimeGenerator.java | 9 +-
.../iotdb/tsfile/read/reader/ReaderTest.java | 8 +-
.../apache/iotdb/tsfile/utils/BytesUtilsTest.java | 47 +
.../tsfile/write/DefaultSchemaTemplateTest.java | 2 +-
.../tsfile/write/MetadataIndexConstructorTest.java | 6 +-
...SameMeasurementsWithDifferentDataTypesTest.java | 4 +-
.../iotdb/tsfile/write/TsFileReadWriteTest.java | 4 +-
.../iotdb/tsfile/write/TsFileWriteApiTest.java | 264 +++
.../iotdb/tsfile/write/TsFileWriterTest.java | 10 +-
.../org/apache/iotdb/tsfile/write/WriteTest.java | 2 +-
.../iotdb/tsfile/write/record/TabletTest.java | 65 +
.../write/writer/ForceAppendTsFileWriterTest.java | 4 +-
.../write/writer/RestorableTsFileIOWriterTest.java | 36 +-
.../writer/TsFileIOWriterMemoryControlTest.java | 11 +-
.../udf/api/exception/UDFManagementException.java | 32 +
.../api/exception/UDFRegistrationException.java | 32 -
zeppelin-interpreter/IoTDB-Zeppelin-Demo.zpln | 2 +-
.../zeppelin/iotdb/IoTDBInterpreterTest.java | 26 +-
1976 files changed, 98556 insertions(+), 76568 deletions(-)
create mode 100644 .github/workflows/cluster-it-1c1d.yml
create mode 100644 .github/workflows/cluster-it-1c3d.yml
delete mode 100644 .github/workflows/cluster-it.yml
delete mode 100644 .github/workflows/standalone-it-for-mpp.yml
create mode 100644 cli/src/assembly/resources/conf/logback-cli.xml
mode change 100644 => 100755 cli/src/assembly/resources/sbin/start-cli.sh
create mode 100644 confignode/src/assembly/resources/conf/logback-confignode.xml
delete mode 100644 confignode/src/assembly/resources/conf/logback.xml
mode change 100644 => 100755 confignode/src/assembly/resources/sbin/remove-confignode.sh
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/CountPathsUsingTemplateRPCHandler.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/DeleteSchemaRPCHandler.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/DeleteTimeSeriesRPCHandler.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/OperatePipeRPCHandler.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/CountStorageGroupPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetDataNodeConfigurationPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetDataPartitionPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetNodePathsPartitionPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetOrCreateDataPartitionPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetOrCreateSchemaPartitionPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetRegionInfoListPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetRoutingPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetSchemaPartitionPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetSeriesSlotListPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetStorageGroupPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetTimeSlotListPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetTriggerJarPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetTriggerTablePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/datanode/GetDataNodeConfigurationPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/function/GetFunctionTablePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/partition/GetDataPartitionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/partition/GetNodePathsPartitionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/partition/GetOrCreateDataPartitionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/partition/GetOrCreateSchemaPartitionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/partition/GetSchemaPartitionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/partition/GetSeriesSlotListPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/partition/GetTimeSlotListPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/region/GetRegionIdPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/region/GetRegionInfoListPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/storagegroup/CountStorageGroupPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/storagegroup/GetStorageGroupPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/template/GetTemplateSetInfoPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/trigger/GetTransferringTriggersPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/trigger/GetTriggerJarPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/trigger/GetTriggerLocationPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/trigger/GetTriggerTablePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/udf/GetUDFJarPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/CreateFunctionPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/DeleteProcedurePlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/DropFunctionPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/RegisterDataNodePlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/RemoveDataNodePlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/UpdateProcedurePlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/UpdateRegionLocationPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/cq/ActiveCQPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/cq/AddCQPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/cq/DropCQPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/cq/ShowCQPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/cq/UpdateCQLastExecTimePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/datanode/RegisterDataNodePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/datanode/RemoveDataNodePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/datanode/UpdateDataNodePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/function/CreateFunctionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/function/DropFunctionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/partition/UpdateRegionLocationPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/procedure/DeleteProcedurePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/procedure/UpdateProcedurePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/DropPipePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/template/DropSchemaTemplatePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/template/PreUnsetSchemaTemplatePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/template/RollbackPreUnsetSchemaTemplatePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/template/UnsetSchemaTemplatePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/trigger/UpdateTriggerLocationPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/trigger/UpdateTriggersOnTransferNodesPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/FunctionTableResp.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/GetRegionIdResp.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/GetRoutingResp.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/JarResp.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/ShowCQResp.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/TemplateSetInfoResp.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/TransferringTriggersResp.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/TriggerJarResp.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/TriggerLocationResp.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/statemachine/ConfigNodeRegionStateMachine.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/statemachine/PartitionRegionStateMachine.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/cq/CQManager.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/cq/CQScheduleTask.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/LazyGreedyRouter.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/RegionRouteMap.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/mcf/MCFEdge.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/mcf/MCFLeaderBalancer.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/node/BaseNodeCache.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/node/ConfigNodeHeartbeatCache.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/node/DataNodeHeartbeatCache.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/node/NodeHeartbeatSample.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/node/heartbeat/BaseNodeCache.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/node/heartbeat/ConfigNodeHeartbeatCache.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/node/heartbeat/DataNodeHeartbeatCache.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/node/heartbeat/NodeHeartbeatSample.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/node/heartbeat/NodeStatistics.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/RegionCache.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/RegionGroupCache.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/RegionHeartbeatSample.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/heartbeat/RegionCache.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/heartbeat/RegionGroupCache.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/heartbeat/RegionGroupStatistics.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/heartbeat/RegionHeartbeatSample.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/heartbeat/RegionStatistics.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/NodeInfo.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/cq/CQInfo.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/node/NodeInfo.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/RegionCreateTask.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/RegionDeleteTask.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/RegionMaintainTask.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/RegionMaintainType.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/maintainer/RegionCreateTask.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/maintainer/RegionDeleteTask.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/maintainer/RegionMaintainTask.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/maintainer/RegionMaintainType.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/CreateTriggerProcedure.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/DropTriggerProcedure.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/cq/CreateCQProcedure.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DataNodeRegionGroupUtil.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DataNodeRegionTask.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeactivateTemplateProcedure.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeleteStorageGroupProcedure.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeleteTimeSeriesProcedure.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/UnsetTemplateProcedure.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/statemachine/DeleteStorageGroupProcedure.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/statemachine/DeleteTimeSeriesProcedure.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/sync/OperatePipeProcedureRollbackProcessor.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/trigger/CreateTriggerProcedure.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/trigger/DropTriggerProcedure.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/DeleteStorageGroupState.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/DeleteTimeSeriesState.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/cq/CreateCQState.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/DeactivateTemplateState.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/DeleteStorageGroupState.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/DeleteTimeSeriesState.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/UnsetTemplateState.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/store/ProcedureType.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/writelog/io/BatchLogReader.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/writelog/io/ILogReader.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/writelog/io/SingleFileLogReader.java
delete mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/write/RemoveDataNodePlanTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/cq/CQScheduleTaskTest.java
delete mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/LazyGreedyRouterTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/RegionRouteMapTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/mcf/MCFLeaderBalancerTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/manager/node/NodeCacheTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/persistence/CQInfoTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/persistence/UDFInfoTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/persistence/node/NodeStatisticsTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/persistence/partition/statistics/RegionGroupStatisticsTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/persistence/partition/statistics/RegionStatisticsTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/CreateCQProcedureTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/DeactivateTemplateProcedureTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/UnsetTemplateProcedureTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/node/AddConfigNodeProcedureTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/node/RemoveConfigNodeProcedureTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/node/RemoveDataNodeProcedureTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/statemachine/RegionMigrateProcedureTest.java
delete mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceProcessorTest.java
create mode 100644 confignode/src/test/resources/confignode1conf/iotdb-common.properties
create mode 100644 confignode/src/test/resources/confignode1conf/iotdb-confignode-metric.yml
delete mode 100644 confignode/src/test/resources/confignode1conf/iotdb-metric.yml
create mode 100644 confignode/src/test/resources/confignode2conf/iotdb-common.properties
create mode 100644 confignode/src/test/resources/confignode2conf/iotdb-confignode-metric.yml
delete mode 100644 confignode/src/test/resources/confignode2conf/iotdb-metric.yml
create mode 100644 confignode/src/test/resources/confignode3conf/iotdb-common.properties
create mode 100644 confignode/src/test/resources/confignode3conf/iotdb-confignode-metric.yml
delete mode 100644 confignode/src/test/resources/confignode3conf/iotdb-metric.yml
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/exception/ConsensusGroupAddPeerException.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/exception/ConsensusGroupModifyPeerException.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerMetrics.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcherThreadMetrics.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/MultiLeaderMemoryManagerMetrics.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/ratis/FileInfoWithDelayedMd5Computing.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/simple/SimpleConsensus.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/simple/SimpleServerImpl.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/standalone/StandAloneConsensus.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/standalone/StandAloneServerImpl.java
create mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/simple/RecoveryTest.java
create mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/simple/SimpleConsensusTest.java
delete mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/standalone/RecoveryTest.java
delete mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/standalone/StandAloneConsensusTest.java
create mode 100644 cross-tests/src/test/resources/iotdb-datanode.properties
delete mode 100644 cross-tests/src/test/resources/iotdb-engine.properties
create mode 100755 docker/src/main/DockerCompose/start-1c1d.sh
delete mode 100644 docker/src/main/Dockerfile-0.10.0
delete mode 100644 docker/src/main/Dockerfile-0.11.0
delete mode 100644 docker/src/main/Dockerfile-0.11.1
delete mode 100644 docker/src/main/Dockerfile-0.11.2
delete mode 100644 docker/src/main/Dockerfile-0.11.3
delete mode 100644 docker/src/main/Dockerfile-0.12.0-cluster
delete mode 100644 docker/src/main/Dockerfile-0.12.0-node
delete mode 100644 docker/src/main/Dockerfile-0.12.1-cluster
delete mode 100644 docker/src/main/Dockerfile-0.12.1-node
delete mode 100644 docker/src/main/Dockerfile-0.12.2-cluster
delete mode 100644 docker/src/main/Dockerfile-0.12.2-grafana
delete mode 100644 docker/src/main/Dockerfile-0.12.2-node
create mode 100644 docker/src/main/Dockerfile-0.12.6-cluster
create mode 100644 docker/src/main/Dockerfile-0.12.6-grafana
create mode 100644 docker/src/main/Dockerfile-0.12.6-node
create mode 100644 docker/src/main/Dockerfile-0.13.0-cluster
create mode 100644 docker/src/main/Dockerfile-0.13.3-grafana-connector
create mode 100644 docker/src/main/Dockerfile-0.13.3-node
create mode 100644 docker/src/main/Dockerfile-0.13.3-node-multi-platform
delete mode 100644 docker/src/main/Dockerfile-0.9.0
create mode 100644 docker/src/main/Dockerfile-1c1d
create mode 100644 docker/src/main/Dockerfile-1c1d-influxdb
delete mode 100644 docs/UserGuide/Alert/Alerting.md
delete mode 100644 docs/UserGuide/Alert/Triggers.md
create mode 100644 docs/UserGuide/Edge-Cloud-Collaboration/Sync-Tool.md
rename docs/UserGuide/{Reference => FAQ}/Frequently-asked-questions.md (100%)
delete mode 100644 docs/UserGuide/Maintenance-Tools/Metric-Tool.md
delete mode 100644 docs/UserGuide/Maintenance-Tools/Sync-Tool.md
create mode 100644 docs/UserGuide/Monitor-Alert/Alerting.md
create mode 100644 docs/UserGuide/Monitor-Alert/Metric-Tool.md
create mode 100644 docs/UserGuide/Process-Data/Triggers.md
create mode 100644 docs/UserGuide/Write-Data/MQTT.md
create mode 100644 docs/UserGuide/Write-Data/REST-API.md
create mode 100644 docs/UserGuide/Write-Data/Session.md
delete mode 100644 docs/zh/UserGuide/Alert/Alerting.md
delete mode 100644 docs/zh/UserGuide/Alert/Triggers.md
create mode 100644 docs/zh/UserGuide/Edge-Cloud-Collaboration/Sync-Tool.md
rename docs/zh/UserGuide/{Reference => FAQ}/Frequently-asked-questions.md (100%)
delete mode 100644 docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md
delete mode 100644 docs/zh/UserGuide/Maintenance-Tools/Sync-Tool.md
create mode 100644 docs/zh/UserGuide/Monitor-Alert/Alerting.md
create mode 100644 docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md
create mode 100644 docs/zh/UserGuide/Process-Data/Triggers.md
create mode 100644 docs/zh/UserGuide/Write-Data/MQTT.md
create mode 100644 docs/zh/UserGuide/Write-Data/REST-API.md
create mode 100644 docs/zh/UserGuide/Write-Data/Session.md
create mode 100644 example/trigger/src/main/java/org/apache/iotdb/trigger/LoggerTrigger.java
delete mode 100644 external-api/src/main/java/org/apache/iotdb/external/api/ISeriesNumerLimiter.java
create mode 100644 external-api/src/main/java/org/apache/iotdb/external/api/ISeriesNumerMonitor.java
create mode 100644 external-api/src/main/java/org/apache/iotdb/external/api/thrift/JudgableServerContext.java
create mode 100644 external-api/src/main/java/org/apache/iotdb/external/api/thrift/ServerContextFactory.java
create mode 100644 grafana-plugin/pkg/plugin/iotdb_resource_handler.go
create mode 100644 grafana-plugin/src/img/addIoTDBDataSource.png
create mode 100644 grafana-plugin/src/img/showData.png
create mode 100644 integration-test/src/main/java/org/apache/iotdb/db/trigger/example/TriggerFireTimesCounter.java
create mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java
create mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/SimpleEnv.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/StandaloneDataNodeWrapper.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/StandaloneOnMppEnv.java
create mode 100644 integration-test/src/main/java/org/apache/iotdb/it/utils/TsFileGenerator.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/IoTDBClusterPartitionIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/IoTDBConfigNodeIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/IoTDBConfigNodeSnapshotIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBClusterAuthorityIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBClusterNodeIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBClusterPartitionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBClusterRegionLeaderBalancingIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBClusterRestartIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBConfigNodeSnapshotIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBConfigNodeSwitchLeaderIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBStorageGroupIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/utils/ConfigNodeTestUtils.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBDatetimeFormatIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBEncodingIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBExecuteBatchIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBFloatPrecisionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBInsertMultiRowIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBInsertNaNIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBInsertNullIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBInsertWithQueryIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBPartialInsertionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBQueryWithRecreatedTimeseriesIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBRecoverIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBRecoverUnclosedIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBRestartIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBSettleIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aligned/AlignedWriteUtil.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/cq/IoTDBCQExecIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/cq/IoTDBCQIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/last/IoTDBLastWithTTLIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/mqtt/IoTDBMQTTSinkIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBArithmeticIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBFuzzyQueryIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBInIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBNullOperandIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBQueryDemoIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBSelectCompareExpressionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBSelectSchemaIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBDeactivateTemplateIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBDeleteTimeseriesSchemaFileIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBMetadataFetchSchemaFileIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/selectinto/IoTDBSelectInto2IT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/selectinto/IoTDBSelectInto3IT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/selectinto/IoTDBSelectIntoIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/sync/SyncTransportTest.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/trigger/IoTDBTriggerExecutionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/trigger/IoTDBTriggerManagementIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/udf/IoTDBUDFM4IT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/utils/AlignedWriteUtil.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/watermark/IoTDBWatermarkIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/session/IoTDBSessionAlignedInsertIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/session/IoTDBSessionComplexIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/session/IoTDBSessionDisableMemControlIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/session/IoTDBSessionInsertNulIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/session/IoTDBSessionSimpleIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/session/IoTDBSessionSyntaxConventionIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/session/SessionTest.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBConnectionInfoIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBSessionAlignedInsertIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBSessionComplexIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBSessionDisableMemControlIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBSessionInsertNullIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBSessionInsertWithTriggerExecutionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBSessionSchemaTemplateIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBSessionSimpleIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBSessionSyntaxConventionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/session/it/SessionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/session/it/pool/SessionPoolIT.java
create mode 100644 integration-test/src/test/resources/TriggerFireTimesCounter.jar
create mode 100644 integration-test/src/test/resources/iotdb-datanode.properties
delete mode 100644 integration-test/src/test/resources/iotdb-engine.properties
create mode 100644 integration-test/src/test/resources/udf-example.jar
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBArithmeticIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBDatetimeFormatIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBEncodingIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBExecuteBatchIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBFilePathUtilsIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBFloatPrecisionIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBFuzzyQueryIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBInIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBInsertMultiRowIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBInsertNaNIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBInsertNullIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBInsertWithQueryIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBLoadExternalTsFileWithTimePartitionIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBManageTsFileResourceIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBPartialInsertionIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBQueryDemoIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBQueryWithRecreatedTimeseriesIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBRecoverIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBRecoverUnclosedIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBRepeatPatternNameIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBRestartIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSelectCompareExpressionIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSelectSchemaIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSettleIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/session/pool/SessionPoolTest.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/session/template/TemplateUT.java
create mode 100644 integration/src/test/resources/iotdb-datanode.properties
delete mode 100644 integration/src/test/resources/iotdb-engine.properties
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDAFQuantile.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/HeapLongKLLSketch.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/KLLSketchForQuantile.java
create mode 100644 metrics/interface/src/main/assembly/resources/conf/iotdb-confignode-metric.yml
create mode 100644 metrics/interface/src/main/assembly/resources/conf/iotdb-datanode-metric.yml
delete mode 100644 metrics/interface/src/main/assembly/resources/conf/iotdb-metric.yml
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/jvm/JvmClassLoaderMetrics.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/jvm/JvmCompileMetrics.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/jvm/JvmGcMetrics.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/jvm/JvmMemoryMetrics.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/jvm/JvmMetrics.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/jvm/JvmThreadMetrics.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/jvm/JvmUtils.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/logback/LogbackMetrics.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/logback/MetricsTurboFilter.java
delete mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/predefined/PredefinedMetric.java
delete mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/predefined/jvm/JvmClassLoaderMetrics.java
delete mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/predefined/jvm/JvmCompileMetrics.java
delete mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/predefined/jvm/JvmGcMetrics.java
delete mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/predefined/jvm/JvmMemoryMetrics.java
delete mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/predefined/jvm/JvmMetrics.java
delete mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/predefined/jvm/JvmThreadMetrics.java
delete mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/predefined/jvm/JvmUtils.java
delete mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/predefined/logback/LogbackMetrics.java
delete mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/predefined/logback/MetricsTurboFilter.java
create mode 100644 node-commons/src/assembly/resources/conf/iotdb-common.properties
create mode 100755 node-commons/src/assembly/resources/sbin/iotdb-common.sh
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/consensus/ConfigNodeRegionId.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/consensus/PartitionRegionId.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/cq/CQState.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/cq/TimeoutPolicy.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/PipeAlreadyExistException.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/PipeSinkAlreadyExistException.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/PipeSinkBeingUsedException.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/PipeSinkNotExistException.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/service/metric/MetricService.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/service/metric/MetricServiceMBean.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/service/metric/enums/Metric.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/service/metric/enums/Operation.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/service/metric/enums/Tag.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/UDFInformation.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/UDFTable.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFM4.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/service/SnapshotUtils.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/service/UDFLogWriter.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/service/UDFManagementService.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/service/UDFRegistrationInformation.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/service/UDFRegistrationService.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/utils/ProcessIdUtils.java
create mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/sync/metedata/SyncMetadataTest.java
create mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/utils/JVMCommonUtilsTest.java
create mode 100644 schema-engine-tag/README.md
create mode 100644 schema-engine-tag/pom.xml
create mode 100644 schema-engine-tag/src/assembly/resources/conf/schema-tag.properties
create mode 100644 schema-engine-tag/src/assembly/schema-engine-tag.xml
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/TagSchemaRegion.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/config/TagSchemaConfig.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/config/TagSchemaDescriptor.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/idtable/IDTableWithDeviceIDListImpl.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/ITagInvertedIndex.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/Request/DeletionRequest.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/Request/InsertionRequest.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/Request/QueryRequest.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/TagInvertedIndex.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/deletion/MemChunkDeletion.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/deletion/MemChunkGroupDeletion.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/deletion/MemTableDeletion.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/deletion/MemTableGroupDeletion.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/insertion/MemChunkGroupInsertion.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/insertion/MemChunkInsertion.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/insertion/MemTableGroupInsertion.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/insertion/MemTableInsertion.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/memtable/MemChunk.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/memtable/MemChunkGroup.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/memtable/MemTable.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/memtable/MemTableGroup.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/query/MemChunkGroupQuery.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/query/MemChunkQuery.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/query/MemTableGroupQuery.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/query/MemTableQuery.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/response/QueryResponse.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/wal/WALEntry.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/wal/WALManager.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/utils/MeasurementPathUtils.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/utils/PathTagConverterUtils.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/db/metadata/tagSchemaRegion/utils/ShowTimeSeriesResultUtils.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/annotation/DeletionProcessor.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/annotation/InsertionProcessor.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/annotation/QueryProcessor.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/applicationcontext/ApplicationContext.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/applicationcontext/ApplicationContextGenerator.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/requestcontext/DeleteRequestContext.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/requestcontext/FlushRequestContext.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/requestcontext/InsertRequestContext.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/requestcontext/QueryRequestContext.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/context/requestcontext/RequestContext.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/engine/ILSMEngine.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/engine/IRecoverable.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/engine/LSMEngine.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/engine/LSMEngineBuilder.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/BasicLevelProcessor.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/DeleteLevelProcessor.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/FlushLevelProcessor.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/ILevelProcessor.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/InsertLevelProcessor.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/LevelProcessorChain.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/levelProcess/QueryLevelProcessor.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/manager/BasicLSMManager.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/manager/DeletionManager.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/manager/ILSMManager.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/manager/InsertionManager.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/manager/QueryManager.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/manager/RecoverManager.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/manager/WALManager.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/request/IDeletionRequest.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/request/IInsertionRequest.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/request/IQueryRequest.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/request/IRequest.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/request/RequestType.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/response/IResponse.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/strategy/BFSAccessStrategy.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/strategy/IAccessStrategy.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/strategy/PostOrderAccessStrategy.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/strategy/PreOrderAccessStrategy.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/strategy/RBFSAccessStrategy.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/wal/IWALReader.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/wal/IWALRecord.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/wal/IWALWriter.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/wal/WALReader.java
create mode 100644 schema-engine-tag/src/main/java/org/apache/iotdb/lsm/wal/WALWriter.java
create mode 100644 schema-engine-tag/src/test/java/org/apache/iotdb/db/metadata/tagSchemaRegion/TagSchemaRegionTest.java
create mode 100644 schema-engine-tag/src/test/java/org/apache/iotdb/db/metadata/tagSchemaRegion/idtable/IDTableWithDeviceIDListImplTest.java
create mode 100644 schema-engine-tag/src/test/java/org/apache/iotdb/db/metadata/tagSchemaRegion/tagIndex/TagTagInvertedIndexTest.java
create mode 100644 server/src/assembly/resources/conf/logback-datanode.xml
delete mode 100644 server/src/assembly/resources/conf/logback.xml
delete mode 100755 server/src/assembly/resources/sbin/start-server.bat
delete mode 100755 server/src/assembly/resources/sbin/start-server.sh
delete mode 100755 server/src/assembly/resources/sbin/stop-server.bat
delete mode 100755 server/src/assembly/resources/sbin/stop-server.sh
create mode 100644 server/src/main/java/org/apache/iotdb/db/client/DataNodeInternalClient.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/conf/directories/DirectoryChecker.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/cq/CQLogReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/cq/CQLogWriter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/cq/ContinuousQuerySchemaCheckTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/cq/ContinuousQueryService.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/cq/ContinuousQueryTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/cq/ContinuousQueryTaskPoolManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/load/DeletionData.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/load/TsFileData.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/load/TsFileSplitter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/selectinto/InsertTabletPlanGenerator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/selectinto/InsertTabletPlansIterator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/HashLastFlushTimeMap.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/IDTableFlushTimeManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/IDTableLastFlushTimeMap.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/ILastFlushTimeManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/ILastFlushTimeMap.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/LastFlushTimeManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TimePartitionInfo.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TimePartitionManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/dataregion/HashVirtualPartitioner.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/dataregion/StorageGroupManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/dataregion/VirtualPartitioner.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/IntoProcessException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/schemafile/SchemaFileLogCorruptedException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/log/SchemaFileLogReader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/log/SchemaFileLogSerializer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/log/SchemaFileLogWriter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/DeactivateTemplatePlanImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/PreDeactivateTemplatePlanImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/RollbackPreDeactivateTemplatePlanImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/IDeactivateTemplatePlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/IPreDeactivateTemplatePlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/IRollbackPreDeactivateTemplatePlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/template/TemplateInternalRPCUtil.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceFailureInfo.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/AbstractIntoOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/DeviceViewIntoOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/IntoOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/ThreadProducer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/SelectIntoUtils.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/CreateContinuousQueryTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/DropContinuousQueryTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/GetRegionIdTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/GetRegionTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/ShowClusterDetailsTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/ShowContinuousQueriesTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/template/DeactivateSchemaTemplateTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/template/DropSchemaTemplateTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/template/UnsetSchemaTemplateTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/leaf/NullOperand.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/DeactivateTemplateNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/PreDeactivateTemplateNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/RollbackPreDeactivateTemplateNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/DeviceViewIntoNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/IntoNode.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/MultiChildNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/MultiChildProcessNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/SingleChildProcessNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/parameter/DeviceViewIntoPathDescriptor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/parameter/IntoPathDescriptor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/IntoComponent.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/IntoItem.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/CreateContinuousQueryStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/DropContinuousQueryStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/GetRegionIdStatement.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/GetRegionStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/ShowContinuousQueriesStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/template/DeactivateTemplateStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/template/DropSchemaTemplateStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/template/UnsetSchemaTemplateStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/leaf/NullColumnTransformer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/handler/QueryHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/handler/QueryHandlerFactory.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/handler/TagQueryHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/meta/IInfluxDBMetaManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/meta/InfluxDBMetaManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/meta/InfluxDBMetaManagerFactory.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/meta/TagInfluxDBMetaManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/MPPRestService.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/filter/ApiOriginFilter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/filter/AuthorizationFilter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/filter/BasicSecurityContext.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/filter/User.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/filter/UserCache.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/handler/AuthorizationHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/handler/ExceptionHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/handler/QueryDataSetHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/handler/RequestValidationHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/handler/StatementConstructionHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/impl/GrafanaApiServiceImpl.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/impl/PingApiServiceImpl.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mpprest/impl/RestApiServiceImpl.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/mqtt/PublishHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/rest/handler/ExecuteStatementHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/rest/handler/PhysicalPlanConstructionHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/rest/handler/PhysicalPlanValidationHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/rest/handler/StatementConstructionHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/DeletePartitionPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/DeletePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertMultiTabletsPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertRowPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertRowsOfOneDevicePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertRowsPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertTabletPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreatePipePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreatePipeSinkPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/DropPipeSinkPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/OperatePipePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowPipePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowPipeSinkPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowPipeSinkTypePlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/control/SessionManagerMBean.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/control/SessionTimeoutManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/control/clientsession/ClientSession.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/control/clientsession/IClientSession.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/control/clientsession/InternalClientSession.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/control/clientsession/MqttClientSession.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/GetVersion.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/DataNodeMetricsHelper.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/FileMetrics.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/MetricService.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/MetricServiceMBean.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/ProcessMetrics.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/SystemMetrics.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/enums/Metric.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/enums/Operation.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/enums/Tag.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/predefined/FileMetrics.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/predefined/ProcessMetrics.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/predefined/SystemMetrics.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/handler/BaseServerContextHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/impl/InfluxDBServiceImpl.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/pipedata/SchemaPipeData.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/SchemaLoader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/tools/dataregion/DeviceMappingViewer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/trigger/executor/TriggerFireResult.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/trigger/executor/TriggerFireVisitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/trigger/service/TriggerInformationUpdater.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/utils/FilesUtils.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/utils/JarLoaderUtil.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/allocation/ElasticStrategy.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/utils/MultiTsFileDeviceIteratorTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/modification/DeletionFileNodeTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/modification/DeletionQueryTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/storagegroup/FileNodeManagerBenchmark.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/storagegroup/IDTableLastFlushTimeMapTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/storagegroup/LastFlushTimeMapTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessorTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TimePartitionManagerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessorTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/storagegroup/dataregion/HashVirtualPartitionerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/IDTableFlushTimeTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/IDTableResourceControlTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/IDTableRestartTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/InsertWithIDTableTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/QueryAlignedTimeseriesWithIDTableTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/QueryWithIDTableTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/schemafile/SchemaFileLogTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/SchemaRegionBasicTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/SchemaRegionTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/multimode/SchemaRegionFullMemoryTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/multimode/SchemaRegionMemoryTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/multimode/SchemaRegionNonMemoryTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/multimode/SchemaRegionPartialMemoryTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/multimode/SchemaRegionSchemaFileTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/common/schematree/NodeRefTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceFailureInfoSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/process/IntoNodeSerdeTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/protocol/mqtt/PublishHandlerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/qp/physical/ConcatOptimizerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/qp/physical/InsertRowPlanTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/qp/physical/InsertRowsOfOneDevicePlanTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/qp/physical/InsertTabletMultiPlanTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/qp/physical/InsertTabletPlanTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/qp/physical/PhysicalPlanSerializeTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/qp/physical/PhysicalPlanTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/qp/physical/SerializationTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/qp/physical/SerializedSizeTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/dataset/EngineDataSetWithValueFilterTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/dataset/groupby/GroupByDataSetTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/dataset/groupby/GroupByFillDataSetTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/dataset/groupby/GroupByLevelDataSetTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/valuefilter/RawQueryWithValueFilterTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/service/DaemonTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sink/LocalIoTDBSinkTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sink/MQTTSinkTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/sync/persistence/LocalSyncInfoTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/sync/persistence/SyncLogTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/receiver/manager/LocalSyncInfoTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/receiver/recovery/SyncLogTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/transport/SyncTransportTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/tools/IoTDBWatermarkTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/allocation/ElasticStrategyTest.java
create mode 100644 server/src/test/resources/datanode1conf/iotdb-common.properties
create mode 100644 server/src/test/resources/datanode1conf/iotdb-datanode-metric.yml
delete mode 100644 server/src/test/resources/datanode1conf/iotdb-metric.yml
create mode 100644 server/src/test/resources/datanode2conf/iotdb-common.properties
create mode 100644 server/src/test/resources/datanode2conf/iotdb-datanode-metric.yml
delete mode 100644 server/src/test/resources/datanode2conf/iotdb-metric.yml
create mode 100644 server/src/test/resources/datanode3conf/iotdb-common.properties
create mode 100644 server/src/test/resources/datanode3conf/iotdb-datanode-metric.yml
delete mode 100644 server/src/test/resources/datanode3conf/iotdb-metric.yml
create mode 100644 session/src/test/resources/iotdb-datanode.properties
delete mode 100644 session/src/test/resources/iotdb-engine.properties
create mode 100644 spark-iotdb-connector/src/test/resources/iotdb-datanode.properties
delete mode 100644 spark-iotdb-connector/src/test/resources/iotdb-engine.properties
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/write/writer/TsFileIOWriterEndFileTest.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/write/record/TabletTest.java
create mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/exception/UDFManagementException.java
delete mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/exception/UDFRegistrationException.java