This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch ml/windowSet
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from ac24e3599d add interface
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)
new 756d8b83b0 Merge remote-tracking branch 'origin/master' into
ml/windowSet
new 01128d2215 add interface fetchWindowSet in TSServiceImpl &
ClientRPCServiceImpl
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.dockerignore | 1 +
.github/workflows/client-go.yml | 2 +-
.github/workflows/client-python.yml | 2 +-
.github/workflows/influxdb-protocol.yml | 2 +-
.github/workflows/main-unix.yml | 2 +-
.github/workflows/main-win.yml | 2 +-
.github/workflows/standalone-it-for-mpp.yml | 160 +-
.gitignore | 1 +
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 21 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 57 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 29 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 11 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 4 +-
.../org/apache/iotdb/cli/StartClientScriptIT.java | 3 +
client-cpp/README.md | 41 +-
client-go | 2 +-
client-py/requirements.txt | 4 +-
client-py/setup.py | 2 +-
client-py/tests/test_template.py | 127 +-
confignode/pom.xml | 5 +
confignode/src/assembly/confignode.xml | 14 +-
.../resources/conf/iotdb-confignode.properties | 357 +---
.../assembly/resources/conf/logback-confignode.xml | 140 ++
confignode/src/assembly/resources/conf/logback.xml | 140 --
.../assembly/resources/sbin/remove-confignode.bat | 2 +-
.../assembly/resources/sbin/remove-confignode.sh | 2 +-
.../assembly/resources/sbin/start-confignode.bat | 2 +-
.../assembly/resources/sbin/start-confignode.sh | 2 +-
.../assembly/resources/sbin/stop-confignode.bat | 10 +-
.../src/assembly/resources/sbin/stop-confignode.sh | 6 +-
.../confignode/client/DataNodeRequestType.java | 12 +-
.../client/async/AsyncDataNodeClientPool.java | 72 +-
.../client/async/handlers/AsyncClientHandler.java | 33 +-
.../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 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 59 +-
.../iotdb/confignode/conf/ConfigNodeConstant.java | 4 +-
.../confignode/conf/ConfigNodeDescriptor.java | 359 ++--
.../confignode/conf/ConfigNodeRemoveCheck.java | 2 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 2 +-
.../confignode/conf/SystemPropertiesUtils.java | 24 +-
.../consensus/request/ConfigPhysicalPlan.java | 233 ++-
.../consensus/request/ConfigPhysicalPlanType.java | 214 +-
.../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 -
.../consensus/request/read/GetRegionIdPlan.java | 112 -
.../request/read/GetRegionInfoListPlan.java | 84 -
.../request/read/GetSchemaPartitionPlan.java | 106 -
.../request/read/GetSeriesSlotListPlan.java | 84 -
.../request/read/GetStorageGroupPlan.java | 34 -
.../request/read/GetTimeSlotListPlan.java | 109 -
.../request/read/GetTransferringTriggersPlan.java | 42 -
.../consensus/request/read/GetTriggerJarPlan.java | 68 -
.../request/read/GetTriggerTablePlan.java | 62 -
.../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 | 87 +
.../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 | 2 +-
.../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 | 2 +-
.../trigger/UpdateTriggerStateInTablePlan.java | 2 +-
.../trigger/UpdateTriggersOnTransferNodesPlan.java | 2 +-
.../consensus/response/DataNodeRegisterResp.java | 17 +-
.../consensus/response/FunctionTableResp.java | 70 +
.../confignode/consensus/response/JarResp.java | 52 +
.../confignode/consensus/response/ShowCQResp.java | 55 +
.../consensus/response/TemplateSetInfoResp.java | 52 +
.../consensus/response/TriggerJarResp.java | 52 -
.../consensus/response/TriggerLocationResp.java | 49 +
.../statemachine/PartitionRegionStateMachine.java | 99 +-
.../confignode/manager/ClusterSchemaManager.java | 129 +-
.../iotdb/confignode/manager/ConfigManager.java | 252 ++-
.../iotdb/confignode/manager/ConsensusManager.java | 179 +-
.../apache/iotdb/confignode/manager/IManager.java | 91 +-
.../iotdb/confignode/manager/ProcedureManager.java | 165 +-
.../iotdb/confignode/manager/SyncManager.java | 115 +-
.../iotdb/confignode/manager/TriggerManager.java | 65 +-
.../iotdb/confignode/manager/UDFManager.java | 151 +-
.../iotdb/confignode/manager/cq/CQManager.java | 186 ++
.../confignode/manager/cq/CQScheduleTask.java | 276 +++
.../iotdb/confignode/manager/load/LoadManager.java | 188 +-
.../manager/load/LoadManagerMetrics.java | 12 +-
.../manager/load/balancer/RouteBalancer.java | 277 ++-
.../manager/load/balancer/router/IRouter.java | 4 +-
.../load/balancer/router/LazyGreedyRouter.java | 159 --
.../manager/load/balancer/router/LeaderRouter.java | 34 +-
.../balancer/router/LoadScoreGreedyRouter.java | 30 +-
.../load/balancer/router/RegionRouteMap.java | 166 ++
.../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 | 226 ++-
.../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 | 115 +-
.../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/NodeInfo.java | 532 -----
.../confignode/persistence/ProcedureInfo.java | 4 +-
.../iotdb/confignode/persistence/TriggerInfo.java | 52 +-
.../iotdb/confignode/persistence/UDFInfo.java | 227 ++-
.../iotdb/confignode/persistence/cq/CQInfo.java | 501 +++++
.../persistence/executor/ConfigPlanExecutor.java | 134 +-
.../persistence/metric/NodeInfoMetrics.java | 6 +-
.../persistence/metric/PartitionInfoMetrics.java | 4 +-
.../confignode/persistence/node/NodeInfo.java | 512 +++++
.../persistence/partition/PartitionInfo.java | 48 +-
.../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 | 21 +-
.../partition/maintainer/RegionCreateTask.java | 135 ++
.../partition/maintainer/RegionDeleteTask.java | 98 +
.../partition/maintainer/RegionMaintainTask.java | 131 ++
.../partition/maintainer/RegionMaintainType.java | 24 +
.../persistence/schema/ClusterSchemaInfo.java | 136 +-
.../persistence/schema/TemplateTable.java | 31 +
.../persistence/sync/ClusterSyncInfo.java | 25 +
.../iotdb/confignode/procedure/Procedure.java | 8 +-
.../confignode/procedure/ProcedureExecutor.java | 2 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 87 +-
.../procedure/env/DataNodeRemoveHandler.java | 34 +-
.../procedure/impl/CreateTriggerProcedure.java | 295 ---
.../procedure/impl/DropTriggerProcedure.java | 176 --
.../procedure/impl/cq/CreateCQProcedure.java | 263 +++
.../impl/node/AddConfigNodeProcedure.java | 4 +-
.../impl/node/RemoveConfigNodeProcedure.java | 4 +-
.../impl/node/RemoveDataNodeProcedure.java | 18 +-
.../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 | 4 +-
.../impl/sync/AbstractOperatePipeProcedure.java | 3 +
.../procedure/impl/sync/CreatePipeProcedure.java | 76 +-
.../procedure/impl/sync/DropPipeProcedure.java | 44 +-
.../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/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 | 6 +-
.../procedure/store/ProcedureFactory.java | 62 +-
.../confignode/procedure/store/ProcedureType.java | 82 +
.../iotdb/confignode/service/ConfigNode.java | 33 +-
.../service/thrift/ConfigNodeRPCService.java | 6 +-
.../thrift/ConfigNodeRPCServiceHandler.java | 2 +-
.../thrift/ConfigNodeRPCServiceHandlerMetrics.java | 4 +-
.../thrift/ConfigNodeRPCServiceMetrics.java | 4 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 122 +-
.../confignode/writelog/io/BatchLogReader.java | 76 +
.../iotdb/confignode/writelog/io/ILogReader.java | 46 +
.../writelog/io/SingleFileLogReader.java | 156 ++
.../request/ConfigPhysicalPlanSerDeTest.java | 244 ++-
.../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 +
.../confignode/manager/node/NodeCacheTest.java | 67 +
.../manager/partition/RegionGroupCacheTest.java | 109 +-
.../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 +
.../confignode1conf/iotdb-confignode.properties | 15 +-
.../resources/confignode1conf/iotdb-metric.yml | 5 -
.../confignode2conf/iotdb-confignode.properties | 15 +-
.../resources/confignode2conf/iotdb-metric.yml | 5 -
.../confignode3conf/iotdb-confignode.properties | 15 +-
.../resources/confignode3conf/iotdb-metric.yml | 5 -
.../org/apache/iotdb/consensus/IConsensus.java | 34 +
.../org/apache/iotdb/consensus/common/Peer.java | 16 +-
.../exception/ConsensusGroupAddPeerException.java | 34 -
.../ConsensusGroupModifyPeerException.java | 34 +
.../multileader/MultiLeaderConsensus.java | 37 +-
.../multileader/MultiLeaderServerImpl.java | 204 +-
.../multileader/MultiLeaderServerMetrics.java | 88 +
.../multileader/client/DispatchLogHandler.java | 15 +
.../multileader/logdispatcher/LogDispatcher.java | 26 +-
.../logdispatcher/LogDispatcherThreadMetrics.java | 95 +
.../logdispatcher/MultiLeaderMemoryManager.java | 10 +-
.../MultiLeaderMemoryManagerMetrics.java | 52 +
.../service/MultiLeaderRPCServiceProcessor.java | 63 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 65 +-
.../consensus/standalone/StandAloneConsensus.java | 5 +
.../iotdb/consensus/ratis/RatisConsensusTest.java | 14 +
distribution/src/assembly/all.xml | 48 +-
distribution/src/assembly/confignode.xml | 14 +-
distribution/src/assembly/datanode.xml | 6 +-
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 | 56 +
docker/src/main/Dockerfile-1c1d-influxdb | 57 +
docs/Download/README.md | 176 +-
docs/UserGuide/API/Interface-Comparison.md | 44 +-
docs/UserGuide/API/Programming-Java-Native-API.md | 2 +-
docs/UserGuide/Alert/Alerting.md | 122 +-
docs/UserGuide/Alert/Triggers.md | 1174 +++--------
docs/UserGuide/Ecosystem-Integration/NiFi-IoTDB.md | 56 +-
docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 6 -
docs/UserGuide/Maintenance-Tools/Sync-Tool.md | 296 +--
docs/UserGuide/Operate-Metadata/Template.md | 38 +-
docs/UserGuide/Process-Data/Continuous-Query.md | 678 +++++--
docs/UserGuide/Process-Data/Select-Into.md | 425 ++--
.../Process-Data/UDF-User-Defined-Function.md | 9 +-
docs/UserGuide/Query-Data/Select-Expression.md | 155 ++
docs/UserGuide/Reference/Keywords.md | 52 +-
docs/UserGuide/Reference/Syntax-Conventions.md | 169 +-
docs/UserGuide/UDF-Library/M4.md | 101 +-
docs/zh/Download/README.md | 171 +-
docs/zh/UserGuide/API/Interface-Comparison.md | 44 +-
.../UserGuide/API/Programming-Java-Native-API.md | 2 +-
docs/zh/UserGuide/Alert/Alerting.md | 110 +-
docs/zh/UserGuide/Alert/Triggers.md | 1132 +++--------
.../UserGuide/Ecosystem-Integration/NiFi-IoTDB.md | 53 +-
docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 7 -
docs/zh/UserGuide/Maintenance-Tools/Sync-Tool.md | 332 ++-
docs/zh/UserGuide/Operate-Metadata/Template.md | 40 +-
docs/zh/UserGuide/Process-Data/Continuous-Query.md | 681 +++++--
docs/zh/UserGuide/Process-Data/Select-Into.md | 425 ++--
.../Process-Data/UDF-User-Defined-Function.md | 8 +-
docs/zh/UserGuide/Query-Data/Select-Expression.md | 156 ++
docs/zh/UserGuide/Reference/Keywords.md | 50 +-
docs/zh/UserGuide/Reference/Syntax-Conventions.md | 172 +-
docs/zh/UserGuide/UDF-Library/M4.md | 101 +-
.../org/apache/iotdb/influxdb/InfluxDBExample.java | 2 +-
.../server/CustomizedJsonPayloadFormatter.java | 2 +-
.../iotdb/trigger/ClusterAlertingExample.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 | 12 +-
.../Apache IoTDB ConfigNode Dashboard v0.14.0.json | 277 ++-
.../Apache IoTDB DataNode Dashboard v0.14.0.json | 2141 +++++++++++++++++---
grafana-plugin/README.md | 363 +++-
grafana-plugin/src/plugin.json | 4 +-
.../influxdb/integration/IoTDBInfluxDBIT.java | 7 +-
integration-test/checkstyle.xml | 2 +-
integration-test/import-control.xml | 16 +-
integration-test/src/assembly/mpp-test.xml | 18 +-
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 69 +-
.../apache/iotdb/it/env/AbstractNodeWrapper.java | 34 +-
.../org/apache/iotdb/it/env/ConfigNodeWrapper.java | 44 +-
.../org/apache/iotdb/it/env/DataNodeWrapper.java | 71 +-
.../java/org/apache/iotdb/it/env/MppConfig.java | 44 +
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 23 +-
.../BuiltinTimeSeriesGeneratingFunctionEnum.java | 3 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 60 +
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 16 +-
.../confignode/it/IoTDBClusterAuthorityIT.java | 452 +++++
.../iotdb/confignode/it/IoTDBClusterNodeIT.java | 308 +++
.../confignode/it/IoTDBClusterPartitionIT.java | 41 +-
.../it/IoTDBClusterRegionLeaderBalancingIT.java | 152 ++
.../iotdb/confignode/it/IoTDBClusterRestartIT.java | 149 +-
.../iotdb/confignode/it/IoTDBConfigNodeIT.java | 848 --------
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 180 +-
.../it/IoTDBConfigNodeSwitchLeaderIT.java | 191 ++
.../iotdb/confignode/it/IoTDBStorageGroupIT.java | 8 +-
.../confignode/it/utils/ConfigNodeTestUtils.java | 115 ++
.../org/apache/iotdb/db/it/IoTDBNestedQueryIT.java | 5 +
.../db/it/aggregation/IoTDBTagAggregationIT.java | 16 +
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 1 -
.../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 | 15 +-
.../iotdb/db/it/env/StandaloneEnvConfig.java | 79 +
.../apache/iotdb/db/it/mqtt/IoTDBMQTTSinkIT.java | 212 ++
.../db/it/schema/IoTDBDeactivateTemplateIT.java | 231 +++
.../schema/IoTDBDeleteTimeseriesSchemaFileIT.java | 49 +
.../it/schema/IoTDBMetadataFetchSchemaFileIT.java | 53 +
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 63 +-
.../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 | 126 +-
.../apache/iotdb/db/it/sync/IoTDBPipeSinkIT.java | 2 +-
.../apache/iotdb/db/it/sync/SyncTransportTest.java | 323 +++
.../db/it/trigger/IoTDBTriggerExecutionIT.java | 23 +-
.../db/it/trigger/IoTDBTriggerManagementIT.java | 488 +++++
.../org/apache/iotdb/db/it/udf/IoTDBUDFM4IT.java | 283 +++
.../iotdb/db/it/udf/IoTDBUDFManagementIT.java | 21 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 10 +
.../iotdb/db/it/watermark/IoTDBWatermarkIT.java | 247 +++
.../iotdb/session/it/IoTDBConnectionInfoIT.java | 66 +
.../iotdb/session/it/IoTDBSessionInsertNulIT.java | 360 ----
.../iotdb/session/it/IoTDBSessionInsertNullIT.java | 360 ++++
.../IoTDBSessionInsertWithTriggerExecutionIT.java | 23 +-
.../session/it/IoTDBSessionSchemaTemplateIT.java | 223 ++
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 186 +-
.../iotdb/session/it/pool/SessionPoolIT.java | 550 +++++
.../src/test/resources/logback-test.xml | 2 +-
.../src/test/resources/udf-example.jar | Bin 0 -> 10018 bytes
.../apache/iotdb/integration/env/ClusterNode.java | 4 +-
.../db/integration/IoTDBRewriteTsFileToolIT.java | 523 ++++-
.../iotdb/db/integration/IoTDBTracingIT.java | 4 +-
.../apache/iotdb/db/integration/IoTDBTtlIT.java | 4 +-
.../apache/iotdb/session/pool/SessionPoolTest.java | 482 -----
.../apache/iotdb/session/template/TemplateUT.java | 400 ----
integration/src/test/resources/logback-test.xml | 2 +-
jdbc/src/main/feature/feature.xml | 2 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 843 +++++---
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 1163 ++++++++++-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 26 +-
.../iotdb/jdbc/IoTDBDatabaseMetadataTest.java | 4 +-
.../apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java | 77 +-
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 34 +-
metrics/ReadMe.md | 9 +-
metrics/dropwizard-metrics/pom.xml | 6 -
.../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 | 17 +-
.../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 | 2 +-
.../org/apache/iotdb/metrics/utils/MetricInfo.java | 2 +-
.../iotdb/metrics/config/MetricConfigTest.java | 1 -
.../interface/src/test/resources/iotdb-metric.yml | 8 -
.../micrometer/MicrometerMetricManager.java | 2 +-
node-commons/pom.xml | 21 +
.../resources/conf/iotdb-common.properties | 1241 ++++++++++++
.../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 +
.../apache/iotdb/commons/conf/CommonConfig.java | 30 +-
.../iotdb/commons/conf/CommonDescriptor.java | 23 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 30 +-
.../java/org/apache/iotdb/commons/cq/CQState.java | 45 +
.../org/apache/iotdb/commons/cq/TimeoutPolicy.java | 45 +
.../exception/sync/PipeSinkBeingUsedException.java | 2 +-
.../commons/executable/ExecutableManager.java | 63 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 4 +
.../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 +
.../apache/iotdb/commons/sync/pipe/PipeInfo.java | 6 +-
.../apache/iotdb/commons/sync/pipe/PipeStatus.java | 44 +-
.../iotdb/commons/sync/pipe/TsFilePipeInfo.java | 8 +-
.../iotdb/commons/trigger/TriggerInformation.java | 30 +-
.../apache/iotdb/commons/trigger/TriggerTable.java | 7 +
.../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 -----
.../commons/utils/ThriftCommonsSerDeUtils.java | 19 +
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 19 -
openapi/pom.xml | 26 -
pom.xml | 3 +-
.../java/org/apache/iotdb/RewriteTsFileTool.java | 620 ++++--
.../resources/conf/schema-rocksdb.properties | 8 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 29 +-
.../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 | 992 +++++++++
.../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 -
.../resources/conf/iotdb-datanode.properties | 1125 +---------
.../assembly/resources/conf/logback-datanode.xml | 302 +++
server/src/assembly/resources/conf/logback.xml | 302 ---
.../assembly/resources/sbin/remove-datanode.bat | 2 +-
.../src/assembly/resources/sbin/remove-datanode.sh | 2 +-
.../src/assembly/resources/sbin/start-datanode.bat | 2 +-
.../src/assembly/resources/sbin/start-datanode.sh | 2 +-
.../assembly/resources/sbin/start-new-server.bat | 2 +-
.../assembly/resources/sbin/start-new-server.sh | 2 +-
.../src/assembly/resources/sbin/start-server.bat | 2 +-
server/src/assembly/resources/sbin/start-server.sh | 2 +-
.../src/assembly/resources/sbin/stop-datanode.bat | 10 +-
.../src/assembly/resources/sbin/stop-datanode.sh | 6 +-
server/src/assembly/server.xml | 14 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 5 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 484 ++++-
.../iotdb/db/client/DataNodeInternalClient.java | 119 ++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 81 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 174 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 101 +
.../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 | 2 +-
.../cache/TimeSeriesMetadataCacheMetrics.java | 4 +-
.../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 | 6 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 6 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 6 +-
.../db/engine/storagegroup/DataRegionMetrics.java | 4 +-
.../db/engine/storagegroup/TsFileProcessor.java | 17 +-
.../engine/storagegroup/TsFileProcessorInfo.java | 2 +-
.../storagegroup/TsFileProcessorInfoMetrics.java | 6 +-
.../iotdb/db/exception/IntoProcessException.java | 27 +
.../SchemaFileLogCorruptedException.java | 34 +
.../exception/query/PathNumOverLimitException.java | 2 +-
.../exception/sql/PathNumOverLimitException.java | 2 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 2 +-
.../db/metadata/cache/DataNodeSchemaCache.java | 2 +-
.../metadata/cache/DataNodeSchemaCacheMetrics.java | 4 +-
.../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 +-
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 14 +
.../iotdb/db/metadata/mtree/ConfigMTree.java | 77 +-
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 66 +
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 392 +++-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 262 ++-
.../iotdb/db/metadata/mtree/store/IMTreeStore.java | 14 +
.../db/metadata/mtree/store/MemMTreeStore.java | 2 +-
.../mtree/store/disk/schemafile/ISchemaPage.java | 3 +
.../mtree/store/disk/schemafile/InternalPage.java | 2 +-
.../store/disk/schemafile/MockSchemaFile.java | 2 +-
.../mtree/store/disk/schemafile/SchemaFile.java | 51 +-
.../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 | 19 +-
.../traverser/collector/MeasurementCollector.java | 3 +-
.../plan/schemaregion/SchemaRegionPlanType.java | 6 +-
.../plan/schemaregion/SchemaRegionPlanVisitor.java | 17 +
.../impl/ActivateTemplateInClusterPlanImpl.java | 8 +-
.../impl/DeactivateTemplatePlanImpl.java | 41 +
.../impl/PreDeactivateTemplatePlanImpl.java | 41 +
.../RollbackPreDeactivateTemplatePlanImpl.java | 41 +
.../impl/SchemaRegionPlanDeserializer.java | 43 +
.../schemaregion/impl/SchemaRegionPlanFactory.java | 6 +
.../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 | 17 +-
.../db/metadata/schemaregion/SchemaEngine.java | 46 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 172 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 164 +-
.../apache/iotdb/db/metadata/tag/TagLogFile.java | 2 +-
.../metadata/template/ClusterTemplateManager.java | 28 +-
.../iotdb/db/metadata/template/Template.java | 5 +-
.../metadata/template/TemplateInternalRPCUtil.java | 99 +
.../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 | 13 +
.../db/mpp/common/header/DatasetHeaderFactory.java | 4 +
.../db/mpp/execution/exchange/ISourceHandle.java | 10 +
.../mpp/execution/exchange/LocalSourceHandle.java | 21 +
.../execution/exchange/MPPDataExchangeService.java | 2 +-
.../exchange/MPPDataExchangeServiceMetrics.java | 4 +-
.../MPPDataExchangeServiceThriftHandler.java | 2 +-
...MppDataExchangeServiceThriftHandlerMetrics.java | 6 +-
.../db/mpp/execution/exchange/SourceHandle.java | 22 +-
.../execution/executor/RegionWriteExecutor.java | 31 +
.../fragment/FragmentInstanceContext.java | 29 +-
.../fragment/FragmentInstanceManager.java | 6 +-
.../db/mpp/execution/operator/OperatorContext.java | 5 +
.../operator/process/AbstractIntoOperator.java | 384 ++++
.../operator/process/DeviceViewIntoOperator.java | 140 ++
.../execution/operator/process/IntoOperator.java | 104 +
.../process/RawDataAggregationOperator.java | 2 +-
.../process/SingleInputAggregationOperator.java | 2 -
.../process/SlidingWindowAggregationOperator.java | 2 +-
.../operator/process/TransformOperator.java | 6 +-
.../schema/PathsUsingTemplateScanOperator.java | 21 +-
.../schema/TimeSeriesSchemaScanOperator.java | 9 +-
.../execution/schedule/AbstractDriverThread.java | 60 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 38 +-
.../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 | 15 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 12 +
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 65 +-
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 22 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 6 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 26 +
.../iotdb/db/mpp/plan/constant/StatementType.java | 2 +
.../db/mpp/plan/execution/IQueryExecution.java | 3 +
.../db/mpp/plan/execution/QueryExecution.java | 33 +-
.../mpp/plan/execution/config/ConfigExecution.java | 23 +-
.../plan/execution/config/ConfigTaskVisitor.java | 65 +-
.../config/executor/ClusterConfigTaskExecutor.java | 474 ++++-
.../config/executor/IConfigTaskExecutor.java | 28 +-
.../executor/StandaloneConfigTaskExecutor.java | 110 +-
.../config/metadata/CreateContinuousQueryTask.java | 49 +
.../config/metadata/CreateFunctionTask.java | 15 +-
.../config/metadata/DropContinuousQueryTask.java | 42 +
.../execution/config/metadata/ShowClusterTask.java | 4 +-
.../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/parser/ASTVisitor.java | 262 ++-
.../db/mpp/plan/parser/StatementGenerator.java | 18 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 47 +-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 11 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 125 +-
.../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 +
.../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/DeactivateTemplateNode.java | 128 ++
.../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 +-
.../parameter/DeviceViewIntoPathDescriptor.java | 11 +-
.../planner/plan/parameter/IntoPathDescriptor.java | 10 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 6 +-
.../db/mpp/plan/statement/StatementVisitor.java | 36 +
.../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 | 20 +-
.../db/mpp/plan/statement/component/IntoItem.java | 15 +
.../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 +
.../plan/statement/crud/LoadTsFileStatement.java | 4 +
.../db/mpp/plan/statement/crud/QueryStatement.java | 116 +-
.../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 +
.../metadata/CreateContinuousQueryStatement.java | 215 ++
.../metadata/CreateFunctionStatement.java | 28 +-
.../statement/metadata/CreateTriggerStatement.java | 19 +-
.../metadata/DropContinuousQueryStatement.java | 60 +
.../metadata/ShowContinuousQueriesStatement.java | 52 +
.../template/DeactivateTemplateStatement.java | 80 +
.../template/DropSchemaTemplateStatement.java | 55 +
.../template/ShowPathsUsingTemplateStatement.java | 22 +-
.../template/UnsetSchemaTemplateStatement.java | 74 +
.../mpp/transformation/dag/udf/UDTFExecutor.java | 4 +-
.../dag/udf/UDTFInformationInferrer.java | 4 +-
.../iotdb/db/protocol/influxdb/dto/IoTDBPoint.java | 18 +-
.../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 ++
.../protocol/influxdb/util/QueryResultUtils.java | 102 +-
.../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 +
.../rest/handler/AuthorizationHandler.java | 10 +-
.../db/protocol/rest/handler/ExceptionHandler.java | 13 +-
.../handler/PhysicalPlanConstructionHandler.java | 163 --
.../handler/PhysicalPlanValidationHandler.java | 81 -
.../protocol/rest/handler/QueryDataSetHandler.java | 331 ++-
.../rest/handler/StatementConstructionHandler.java | 165 ++
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 183 +-
.../db/protocol/rest/impl/RestApiServiceImpl.java | 152 +-
.../main/java/org/apache/iotdb/db/qp/Planner.java | 19 -
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 90 +-
.../iotdb/db/qp/physical/crud/GroupByTimePlan.java | 2 +-
.../sys/ActivateTemplateInClusterPlan.java | 8 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 59 +-
.../apache/iotdb/db/qp/utils/DateTimeUtils.java | 4 +-
.../iotdb/db/query/context/QueryContext.java | 14 +-
.../db/query/control/QueryResourceManager.java | 11 +-
.../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 +
.../apache/iotdb/db/query/dataset/UDTFDataSet.java | 6 +-
.../apache/iotdb/db/query/executor/fill/IFill.java | 2 +-
.../db/query/pool/RawQueryReadTaskPoolManager.java | 2 +-
.../pool/RawQueryReadTaskPoolManagerMetrics.java | 4 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 198 +-
.../db/service/DataNodeInternalRPCService.java | 4 +-
.../service/DataNodeInternalRPCServiceMetrics.java | 4 +-
.../db/service/DataNodeServerCommandLine.java | 10 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 29 +-
.../org/apache/iotdb/db/service/MQTTService.java | 3 +-
.../java/org/apache/iotdb/db/service/NewIoTDB.java | 22 +-
.../org/apache/iotdb/db/service/RPCService.java | 2 +-
.../apache/iotdb/db/service/RPCServiceMetrics.java | 4 +-
.../db/service/ResourcesInformationHolder.java | 12 +
.../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 | 837 ++++----
.../impl/DataNodeInternalRPCServiceImpl.java | 393 +++-
.../service/thrift/impl/InfluxDBServiceImpl.java | 184 --
.../thrift/impl/NewInfluxDBServiceImpl.java | 75 +-
.../db/service/thrift/impl/TSServiceImpl.java | 423 ++--
.../java/org/apache/iotdb/db/sync/SyncService.java | 142 +-
.../db/sync/common/ClusterSyncInfoFetcher.java | 14 +-
.../sync/pipedata/queue/BufferedPipeDataQueue.java | 70 +-
.../db/sync/receiver/load/DeletionLoader.java | 52 +-
.../iotdb/db/sync/receiver/load/ILoader.java | 20 +
.../iotdb/db/sync/receiver/load/TsFileLoader.java | 58 +-
.../db/sync/transport/server/ReceiverManager.java | 2 +-
.../iotdb/db/trigger/executor/TriggerExecutor.java | 14 +-
.../db/trigger/executor/TriggerFireVisitor.java | 42 +-
.../trigger/service/TriggerInformationUpdater.java | 104 +
.../trigger/service/TriggerManagementService.java | 39 +-
.../java/org/apache/iotdb/db/utils/FilesUtils.java | 43 +
.../org/apache/iotdb/db/utils/JarLoaderUtil.java | 150 --
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 27 +
.../apache/iotdb/db/utils/sync/SyncPipeUtil.java | 12 +-
.../java/org/apache/iotdb/db/wal/WALManager.java | 24 +-
.../iotdb/db/wal/allocation/ElasticStrategy.java | 103 +
.../db/wal/allocation/RoundRobinStrategy.java | 4 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 79 +-
.../apache/iotdb/db/conf/IoTDBDescriptorTest.java | 6 +-
.../engine/compaction/CompactionSchedulerTest.java | 3 +
.../inner/InnerCompactionMoreDataTest.java | 3 +
.../engine/modification/DeletionFileNodeTest.java | 433 ----
.../db/engine/modification/DeletionQueryTest.java | 362 ----
.../idtable/IDTableResourceControlTest.java | 167 --
.../db/metadata/idtable/IDTableRestartTest.java | 205 --
.../db/metadata/idtable/InsertWithIDTableTest.java | 759 -------
.../QueryAlignedTimeseriesWithIDTableTest.java | 373 ----
.../db/metadata/idtable/QueryWithIDTableTest.java | 375 ----
.../iotdb/db/metadata/mtree/ConfigMTreeTest.java | 2 +-
.../mtree/schemafile/SchemaFileLogTest.java | 156 ++
.../metadata/mtree/schemafile/SchemaFileTest.java | 25 +-
.../plan/SchemaRegionPlanCompatibilityTest.java | 22 +-
.../schemaRegion/SchemaRegionBasicTest.java | 315 +++
.../schemaRegion/SchemaRegionSnapshotTest.java | 168 ++
.../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 +
.../mpp/execution/operator/OperatorMemoryTest.java | 6 +-
.../DriverTaskTimeoutSentinelThreadTest.java | 23 +-
.../db/mpp/plan/StandaloneCoordinatorTest.java | 17 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeFailTest.java | 87 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeTest.java | 8 +-
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 10 +-
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 40 +
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 11 +-
.../plan/plan/node/process/IntoNodeSerdeTest.java | 83 +
.../plan/scheduler/StandaloneSchedulerTest.java | 18 +-
.../iotdb/db/protocol/mqtt/PublishHandlerTest.java | 132 --
.../db/protocol/rest/GrafanaApiServiceTest.java | 3 +
.../db/protocol/rest/IoTDBRestServiceTest.java | 3 +
.../iotdb/db/qp/physical/InsertRowPlanTest.java | 395 ----
.../db/qp/physical/InsertTabletMultiPlanTest.java | 300 ---
.../iotdb/db/qp/physical/InsertTabletPlanTest.java | 449 ----
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 29 +-
.../dataset/EngineDataSetWithValueFilterTest.java | 159 --
.../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 --
.../apache/iotdb/db/sink/LocalIoTDBSinkTest.java | 218 --
.../org/apache/iotdb/db/sink/MQTTSinkTest.java | 210 --
.../sync/pipedata/BufferedPipeDataQueueTest.java | 98 +
.../iotdb/db/sync/pipedata/PipeDataTest.java | 21 +-
.../iotdb/db/sync/transport/SyncTransportTest.java | 357 ----
.../apache/iotdb/db/tools/IoTDBWatermarkTest.java | 246 ---
.../iotdb/db/tools/SchemaFileSketchTest.java | 2 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 17 +-
.../iotdb/db/utils/TsFileRewriteToolTest.java | 47 +-
.../org/apache/iotdb/db/wal/WALManagerTest.java | 14 +-
.../db/wal/allocation/ElasticStrategyTest.java | 130 ++
.../db/wal/allocation/FirstCreateStrategyTest.java | 3 -
.../db/wal/allocation/RoundRobinStrategyTest.java | 3 -
.../datanode1conf/iotdb-datanode.properties | 28 +-
.../test/resources/datanode1conf/iotdb-metric.yml | 7 +-
.../datanode2conf/iotdb-datanode.properties | 28 +-
.../test/resources/datanode2conf/iotdb-metric.yml | 7 +-
.../datanode3conf/iotdb-datanode.properties | 28 +-
.../test/resources/datanode3conf/iotdb-metric.yml | 7 +-
.../src/test/resources/iotdb-datanode.properties | 10 +-
server/src/test/resources/logback-test.xml | 2 +-
service-rpc/pom.xml | 8 +
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 345 ++--
.../apache/iotdb/rpc/TElasticFramedTransport.java | 4 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 19 +-
.../rpc/TimeoutChangeableTFastFramedTransport.java | 8 +-
.../TimeoutChangeableTSnappyFramedTransport.java | 8 +-
.../java/org/apache/iotdb/session/ISession.java | 9 +-
.../java/org/apache/iotdb/session/Session.java | 272 ++-
.../org/apache/iotdb/session/SessionConfig.java | 2 +-
.../apache/iotdb/session/SessionConnection.java | 43 +-
.../org/apache/iotdb/session/SessionDataSet.java | 29 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 361 +++-
.../apache/iotdb/session/SessionCacheLeaderUT.java | 4 +-
site/src/main/.vuepress/config.js | 4 +-
.../apache/iotdb/spark/db/EnvironmentUtils.java | 6 +-
.../org/apache/iotdb/spark/db/IoTDBTest.scala | 2 +
.../org/apache/iotdb/spark/db/IoTDBWriteTest.scala | 1 +
.../java/org/apache/iotdb/db/sql/ClusterIT.java | 2 +-
.../src/test/resources/iotdb-datanode.properties | 2 +-
.../src/main/thrift/confignode.thrift | 172 +-
.../src/main/thrift/mutlileader.thrift | 21 +
thrift/src/main/thrift/client.thrift | 39 +-
thrift/src/main/thrift/datanode.thrift | 96 +-
.../iotdb/tsfile/common/conf/TSFileConfig.java | 14 +-
.../iotdb/tsfile/common/conf/TSFileDescriptor.java | 4 +-
.../org/apache/iotdb/tsfile/read/common/Path.java | 72 +-
.../java/org/apache/iotdb/tsfile/utils/BitMap.java | 6 +
.../org/apache/iotdb/tsfile/utils/BytesUtils.java | 4 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 28 +
.../apache/iotdb/tsfile/utils/BytesUtilsTest.java | 47 +
.../udf/api/exception/UDFManagementException.java | 32 +
.../api/exception/UDFRegistrationException.java | 32 -
.../zeppelin/iotdb/IoTDBInterpreterTest.java | 3 +
1078 files changed, 58330 insertions(+), 33964 deletions(-)
create mode 100644
confignode/src/assembly/resources/conf/logback-confignode.xml
delete mode 100644 confignode/src/assembly/resources/conf/logback.xml
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/GetRegionIdPlan.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/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/GetTransferringTriggersPlan.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/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/response/FunctionTableResp.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
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/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
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/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
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
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
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
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/IoTDBClusterRegionLeaderBalancingIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBConfigNodeIT.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/utils/ConfigNodeTestUtils.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/mqtt/IoTDBMQTTSinkIT.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/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/watermark/IoTDBWatermarkIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBConnectionInfoIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBSessionInsertNulIT.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/IoTDBSessionSchemaTemplateIT.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/udf-example.jar
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
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 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/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 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
create mode 100644
server/src/main/java/org/apache/iotdb/db/client/DataNodeInternalClient.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/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/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/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/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/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/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/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
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
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
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/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
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
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/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
create mode 100644
server/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/SchemaRegionSnapshotTest.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/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/InsertRowPlanTest.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/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
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
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
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
