You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hu...@apache.org on 2022/10/31 08:49:27 UTC
[iotdb] branch ml/windowSet updated (ac24e3599d -> 01128d2215)
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
[iotdb] 01/02: Merge remote-tracking branch 'origin/master' into ml/windowSet
Posted by hu...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
hui pushed a commit to branch ml/windowSet
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 756d8b83b092addb0ab0f43cdadada0af601c204
Merge: ac24e3599d 2ee98de984
Author: Minghui Liu <li...@foxmail.com>
AuthorDate: Mon Oct 31 16:35:41 2022 +0800
Merge remote-tracking branch 'origin/master' into ml/windowSet
# Conflicts:
# thrift/src/main/thrift/client.thrift
.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 | 830 ++++----
.../impl/DataNodeInternalRPCServiceImpl.java | 393 +++-
.../service/thrift/impl/InfluxDBServiceImpl.java | 184 --
.../thrift/impl/NewInfluxDBServiceImpl.java | 75 +-
.../db/service/thrift/impl/TSServiceImpl.java | 416 ++--
.../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, 58316 insertions(+), 33964 deletions(-)
diff --cc thrift/src/main/thrift/client.thrift
index 49dc875de5,61744021c8..51b0d24c29
--- a/thrift/src/main/thrift/client.thrift
+++ b/thrift/src/main/thrift/client.thrift
@@@ -547,5 -559,5 +580,7 @@@ service IClientRPCService
common.TSStatus sendFile(1:TSyncTransportMetaInfo metaInfo, 2:binary buff);
+ TSConnectionInfoResp fetchAllConnectionsInfo();
++
+ TFetchWindowSetResp fetchWindowSet(1:TFetchWindowSetReq req)
}
[iotdb] 02/02: add interface fetchWindowSet in TSServiceImpl & ClientRPCServiceImpl
Posted by hu...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
hui pushed a commit to branch ml/windowSet
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 01128d2215545b982d12c980d89db6d606864731
Author: Minghui Liu <li...@foxmail.com>
AuthorDate: Mon Oct 31 16:47:52 2022 +0800
add interface fetchWindowSet in TSServiceImpl & ClientRPCServiceImpl
---
.../apache/iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java | 7 +++++++
.../org/apache/iotdb/db/service/thrift/impl/TSServiceImpl.java | 7 +++++++
2 files changed, 14 insertions(+)
diff --git a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java
index e26c4e603f..b3d6f41230 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/ClientRPCServiceImpl.java
@@ -70,6 +70,8 @@ import org.apache.iotdb.metrics.utils.MetricLevel;
import org.apache.iotdb.rpc.RpcUtils;
import org.apache.iotdb.rpc.TSStatusCode;
import org.apache.iotdb.service.rpc.thrift.ServerProperties;
+import org.apache.iotdb.service.rpc.thrift.TFetchWindowSetReq;
+import org.apache.iotdb.service.rpc.thrift.TFetchWindowSetResp;
import org.apache.iotdb.service.rpc.thrift.TSAppendSchemaTemplateReq;
import org.apache.iotdb.service.rpc.thrift.TSCancelOperationReq;
import org.apache.iotdb.service.rpc.thrift.TSCloseOperationReq;
@@ -418,6 +420,11 @@ public class ClientRPCServiceImpl implements IClientRPCServiceWithHandler {
}
}
+ @Override
+ public TFetchWindowSetResp fetchWindowSet(TFetchWindowSetReq req) throws TException {
+ return null;
+ }
+
@Override
public TSOpenSessionResp openSession(TSOpenSessionReq req) throws TException {
IoTDBConstant.ClientVersion clientVersion = parseClientVersion(req);
diff --git a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/TSServiceImpl.java b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/TSServiceImpl.java
index 72f1112c71..06ef9eec23 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/TSServiceImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/TSServiceImpl.java
@@ -85,6 +85,8 @@ import org.apache.iotdb.rpc.RedirectException;
import org.apache.iotdb.rpc.RpcUtils;
import org.apache.iotdb.rpc.TSStatusCode;
import org.apache.iotdb.service.rpc.thrift.ServerProperties;
+import org.apache.iotdb.service.rpc.thrift.TFetchWindowSetReq;
+import org.apache.iotdb.service.rpc.thrift.TFetchWindowSetResp;
import org.apache.iotdb.service.rpc.thrift.TSAppendSchemaTemplateReq;
import org.apache.iotdb.service.rpc.thrift.TSCancelOperationReq;
import org.apache.iotdb.service.rpc.thrift.TSCloseOperationReq;
@@ -276,6 +278,11 @@ public class TSServiceImpl implements IClientRPCServiceWithHandler {
return null;
}
+ @Override
+ public TFetchWindowSetResp fetchWindowSet(TFetchWindowSetReq req) throws TException {
+ return null;
+ }
+
@Override
public TSOpenSessionResp openSession(TSOpenSessionReq req) throws TException {
IoTDBConstant.ClientVersion clientVersion = parseClientVersion(req);