You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2022/11/01 01:44:50 UTC
[iotdb] branch feat-4230-0.14 updated (1c0ccf05f0 -> fc15edc52a)
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch feat-4230-0.14
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 1c0ccf05f0 fix shell shift issue in some systems
add 2e9fa3c91c [IOTDB-4796] Remove LoadStatistics consensus feature (#7799)
add bd907c0b79 [IOTDB-4741] [IOTDB-4767] Support fetching all connection info in Session & SessionPool (#7795)
add 8eaadfc497 Enable time partition by default (#7800)
add 76b947f56b Add built-in M4 UDF (#7755)
add a78cd55c89 Update download doc (#7801)
add 1e0f3300e0 Fix shell problem in start-confignode.sh/bat and start-datanode.sh/bat (#7811)
add caca66ada7 [IOTDB-2884]Redo Log for SchemaFile (#7726)
add 0e843a7614 Rename mpprest to rest (#7804)
add 21963788ad [IOTDB-4719] SchemaFile adaptation for cluster delete timeseries (#7709)
add a2ccdeb91d [IOTDB-4652] Add retry logic of borrow client in MultiLeaderImpl (#7741)
add 021056c1bd [IOTDB-4802] Optimize the logical plan of query with only time filter (#7805)
add 8f78e26799 Fix IoTDBConfigNodeSnapshotIT.testCreateUDF
add 2ee98de984 [IOTDB-4797] Supplement and improve the metedata plannode tostring function (#7786)
add a3df3a1b14 Rename time_partition to time_partition_interval_for_storage in system.properties file (#7810)
add c034d4cbce [IOTDB-4142] Add delete generated file logic in pom of antlr (#7820)
add 1b1d9bffad Unify thread number configurations to thread_count && Fix clusterIT NPE (#7817)
add 773c963a15 [IOTDB-4806] Add size limit of UDF jar when create UDF on ConfigNode
add b023bb390c [IOTDB-4744] Fix schema register validation bug (#7816)
add a12f66885e fix ConfigNodeSnapshotIT
add 0460a054a1 fix client bug during deactivate template (#7833)
add 07bdbddf16 [IOTDB-4810] Fix print-tsfile-sketch.bat bug when reading measurementID containing Chinese (#7831)
add 952ffcf87d [IOTDB-4527] [IOTDB-4748] Make IoTDB-SQL syntax more flexible (#7806)
add 6e089fb200 Add docs for udf accuracy (#7824)
add b8a20c4078 Change log level of some messages from INFO to DEBUG (#7834)
add 521f9b5f8e [IOTDB-4738]TsFile damaged after writing empty value pages (#7827)
add 60133208c7 Bump actions/first-interaction from 1.1.0 to 1.1.1 (#7836)
add bc0e88b878 [IOTDB-4695] GROUP LEVEL query de-duplicates result columns unexpected (#7736)
add 6c21c7f86c merge master
add b7712113e0 fix Tests
add fc15edc52a fix Tests
No new revisions were added by this update.
Summary of changes:
.github/workflows/greetings.yml | 2 +-
antlr/pom.xml | 17 +
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 2 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 43 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 8 +
.../java/org/apache/iotdb/cli/AbstractCli.java | 2 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 4 +-
client-py/setup.py | 2 +-
.../assembly/resources/sbin/stop-confignode.bat | 10 +-
.../src/assembly/resources/sbin/stop-confignode.sh | 8 +-
.../client/async/AsyncDataNodeClientPool.java | 3 +
.../heartbeat/ConfigNodeHeartbeatHandler.java | 4 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 39 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 10 +-
.../confignode/conf/ConfigNodeDescriptor.java | 84 +--
.../consensus/request/ConfigPhysicalPlan.java | 11 +-
.../consensus/request/ConfigPhysicalPlanType.java | 5 +-
.../write/procedure/UpdateProcedurePlan.java | 8 -
.../write/statistics/UpdateLoadStatisticsPlan.java | 161 -----
.../statemachine/PartitionRegionStateMachine.java | 4 +-
.../iotdb/confignode/manager/ProcedureManager.java | 6 +-
.../iotdb/confignode/manager/UDFManager.java | 34 +-
.../iotdb/confignode/manager/load/LoadManager.java | 131 ++--
.../manager/load/balancer/RouteBalancer.java | 53 +-
.../load/balancer/router/RegionRouteMap.java | 14 +-
.../iotdb/confignode/manager/node/NodeManager.java | 95 +--
.../node/{ => heartbeat}/BaseNodeCache.java | 68 +-
.../{ => heartbeat}/ConfigNodeHeartbeatCache.java | 36 +-
.../{ => heartbeat}/DataNodeHeartbeatCache.java | 11 +-
.../node/{ => heartbeat}/NodeHeartbeatSample.java | 2 +-
.../node/heartbeat}/NodeStatistics.java | 7 +-
.../manager/partition/PartitionManager.java | 55 +-
.../partition/{ => heartbeat}/RegionCache.java | 7 +-
.../{ => heartbeat}/RegionGroupCache.java | 84 ++-
.../heartbeat}/RegionGroupStatistics.java | 28 +-
.../{ => heartbeat}/RegionHeartbeatSample.java | 2 +-
.../partition/heartbeat}/RegionStatistics.java | 7 +-
.../persistence/executor/ConfigPlanExecutor.java | 8 -
.../confignode/persistence/node/NodeInfo.java | 62 +-
.../persistence/partition/PartitionInfo.java | 116 +---
.../persistence/partition/RegionGroup.java | 2 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 6 +-
.../procedure/env/DataNodeRemoveHandler.java | 2 +-
.../OperatePipeProcedureRollbackProcessor.java | 2 +-
.../iotdb/confignode/service/ConfigNode.java | 4 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 7 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 60 --
.../load/balancer/router/LeaderRouterTest.java | 8 +-
.../balancer/router/LoadScoreGreedyRouterTest.java | 8 +-
.../confignode/manager/node/NodeCacheTest.java | 17 +-
.../manager/partition/RegionGroupCacheTest.java | 33 +-
.../iotdb/confignode/persistence/NodeInfoTest.java | 13 -
.../confignode/persistence/PartitionInfoTest.java | 43 --
.../persistence/node/NodeStatisticsTest.java | 1 +
.../statistics/RegionGroupStatisticsTest.java | 2 +
.../partition/statistics/RegionStatisticsTest.java | 1 +
.../multileader/logdispatcher/LogDispatcher.java | 3 +-
docker/src/main/Dockerfile-1c1d | 11 +-
docker/src/main/Dockerfile-1c1d-influxdb | 11 +-
docs/Download/README.md | 148 +++-
docs/UserGuide/Query-Data/Select-Expression.md | 155 +++++
docs/UserGuide/Reference/Keywords.md | 2 +
docs/UserGuide/Reference/Syntax-Conventions.md | 169 +----
docs/UserGuide/UDF-Library/Data-Quality.md | 57 +-
docs/UserGuide/UDF-Library/M4.md | 101 +--
docs/zh/Download/README.md | 143 +++-
docs/zh/UserGuide/Query-Data/Select-Expression.md | 156 +++++
docs/zh/UserGuide/Reference/Keywords.md | 2 +
docs/zh/UserGuide/Reference/Syntax-Conventions.md | 172 +----
docs/zh/UserGuide/UDF-Library/Data-Quality.md | 57 +-
docs/zh/UserGuide/UDF-Library/M4.md | 101 +--
external-api/pom.xml | 8 +
.../external/api/thrift/JudgableServerContext.java | 28 +-
.../external/api/thrift/ServerContextFactory.java | 8 +-
integration-test/import-control.xml | 3 +
.../java/org/apache/iotdb/it/env/MppConfig.java | 7 +-
.../BuiltinTimeSeriesGeneratingFunctionEnum.java | 3 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 2 +-
...thorizeIT.java => IoTDBClusterAuthorityIT.java} | 2 +-
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 2 +
.../it/IoTDBConfigNodeSwitchLeaderIT.java | 69 +-
.../it/aggregation/IoTDBAggregationByLevelIT.java | 19 +
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 1 -
.../iotdb/db/it/env/StandaloneEnvConfig.java | 8 +-
...java => IoTDBDeleteTimeseriesSchemaFileIT.java} | 6 +-
.../org/apache/iotdb/db/it/udf/IoTDBUDFM4IT.java | 283 ++++++++
.../it/IoTDBConnectionInfoIT.java} | 45 +-
.../iotdb/integration/env/ClusterEnvConfig.java | 3 +-
.../db/integration/IoTDBLoadExternalTsfileIT.java | 5 +-
.../IoTDBLoadExternalTsfileWithVirtualSGIT.java | 3 +-
.../integration/IoTDBManageTsFileResourceIT.java | 8 +-
.../integration/IoTDBSizeTieredCompactionIT.java | 12 +-
.../aligned/IoTDBLoadExternalAlignedTsFileIT.java | 5 +-
.../session/IoTDBSessionAlignedABDeviceIT.java | 6 +-
.../session/IoTDBSessionAlignedAggregationIT.java | 6 +-
.../IoTDBSessionAlignedAggregationWithUnSeqIT.java | 6 +-
jdbc/src/main/feature/feature.xml | 2 +-
.../resources/conf/iotdb-common.properties | 65 +-
.../commons/executable/ExecutableManager.java | 12 +-
.../apache/iotdb/commons/service/ServiceType.java | 29 +-
.../BuiltinTimeSeriesGeneratingFunction.java | 3 +-
.../apache/iotdb/commons/udf/builtin/UDTFM4.java | 311 +++++++++
.../commons/udf/service/UDFManagementService.java | 19 +-
openapi/pom.xml | 26 -
.../resources/conf/iotdb-datanode.properties | 2 +-
.../src/assembly/resources/sbin/stop-datanode.bat | 12 +-
.../src/assembly/resources/sbin/stop-datanode.sh | 8 +-
.../tools/tsfileToolSet/print-tsfile-sketch.bat | 7 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 5 +-
.../iotdb/db/client/DataNodeInternalClient.java | 40 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 89 +--
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 137 ++--
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 16 +-
.../db/consensus/DataRegionConsensusImpl.java | 2 +-
.../engine/compaction/CompactionTaskManager.java | 9 +-
.../RewriteCrossSpaceCompactionSelector.java | 4 +-
.../impl/ReadChunkCompactionPerformer.java | 2 +-
.../writer/CrossSpaceCompactionWriter.java | 2 +-
.../writer/InnerSpaceCompactionWriter.java | 2 +-
.../org/apache/iotdb/db/engine/cq/CQLogReader.java | 47 --
.../org/apache/iotdb/db/engine/cq/CQLogWriter.java | 74 --
.../engine/cq/ContinuousQuerySchemaCheckTask.java | 99 ---
.../iotdb/db/engine/cq/ContinuousQueryService.java | 305 ---------
.../iotdb/db/engine/cq/ContinuousQueryTask.java | 200 ------
.../engine/cq/ContinuousQueryTaskPoolManager.java | 107 ---
.../db/engine/flush/pool/FlushTaskPoolManager.java | 4 +-
...s.java => SchemaFileLogCorruptedException.java} | 8 +-
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 30 +
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 53 ++
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 8 +-
.../mtree/store/disk/schemafile/ISchemaPage.java | 3 +
.../mtree/store/disk/schemafile/InternalPage.java | 2 +-
.../mtree/store/disk/schemafile/SchemaFile.java | 49 +-
.../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} | 19 +-
.../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 +++-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 93 ++-
.../db/mpp/execution/exchange/LocalSinkHandle.java | 14 +-
.../mpp/execution/exchange/LocalSourceHandle.java | 12 +-
.../execution/exchange/MPPDataExchangeManager.java | 18 +-
.../db/mpp/execution/exchange/SinkHandle.java | 16 +-
.../db/mpp/execution/exchange/SourceHandle.java | 16 +-
.../execution/executor/RegionWriteExecutor.java | 16 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 2 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 17 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 72 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 6 +-
.../db/mpp/plan/execution/QueryExecution.java | 8 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 27 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 2 +
.../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 | 7 +
.../node/metedata/read/SchemaFetchScanNode.java | 2 +-
.../node/metedata/read/SchemaQueryMergeNode.java | 2 +-
.../node/metedata/read/SchemaQueryScanNode.java | 2 +-
.../node/metedata/read/TimeSeriesCountNode.java | 7 +
.../db/mpp/plan/scheduler/ClusterScheduler.java | 2 +-
.../db/protocol/influxdb/handler/QueryHandler.java | 498 --------------
.../influxdb/handler/QueryHandlerFactory.java | 2 +-
.../influxdb/meta/InfluxDBMetaManager.java | 221 ------
.../influxdb/meta/InfluxDBMetaManagerFactory.java | 2 +-
.../influxdb/meta/NewInfluxDBMetaManager.java | 6 +
.../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 --
.../mpprest/impl/GrafanaApiServiceImpl.java | 268 --------
.../protocol/mpprest/impl/PingApiServiceImpl.java | 51 --
.../protocol/mpprest/impl/RestApiServiceImpl.java | 203 ------
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 41 +-
.../iotdb/db/protocol/mqtt/PublishHandler.java | 145 ----
.../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 ++++-----
.../handler/StatementConstructionHandler.java | 4 +-
.../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 | 56 +-
.../iotdb/db/qp/physical/crud/GroupByTimePlan.java | 2 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 24 +-
.../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 | 413 +++++------
.../db/query/control/SessionManagerMBean.java} | 13 +-
.../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/executor/fill/IFill.java | 2 +-
.../iotdb/db/query/pool/QueryTaskManager.java | 4 +-
.../db/query/pool/RawQueryReadTaskPoolManager.java | 4 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 6 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 12 +-
.../org/apache/iotdb/db/service/MQTTService.java | 3 +-
.../java/org/apache/iotdb/db/service/NewIoTDB.java | 6 +-
.../org/apache/iotdb/db/service/UpgradeSevice.java | 2 +-
.../iotdb/db/service/basic/ServiceProvider.java | 1 -
.../thrift/handler/BaseServerContextHandler.java | 79 +++
.../handler/InfluxDBServiceThriftHandler.java | 11 +-
.../thrift/handler/RPCServiceThriftHandler.java | 19 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 357 +++++-----
.../impl/DataNodeInternalRPCServiceImpl.java | 41 +-
.../service/thrift/impl/InfluxDBServiceImpl.java | 183 -----
.../db/service/thrift/impl/TSServiceImpl.java | 380 ++++-------
.../db/sync/receiver/load/DeletionLoader.java | 2 +-
.../iotdb/db/sync/receiver/load/TsFileLoader.java | 2 +-
.../runtime/WindowEvaluationTaskPoolManager.java | 5 +-
.../engine/compaction/CompactionSchedulerTest.java | 95 +--
.../cross/RewriteCompactionFileSelectorTest.java | 14 +-
.../inner/InnerCompactionMoreDataTest.java | 3 +
.../inner/InnerCompactionSchedulerTest.java | 10 +-
.../compaction/utils/CompactionConfigRestorer.java | 2 +-
.../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 ----------
.../mtree/schemafile/SchemaFileLogTest.java | 156 +++++
.../metadata/mtree/schemafile/SchemaFileTest.java | 25 +-
.../schemaRegion/SchemaRegionBasicTest.java | 84 +++
.../db/mpp/plan/StandaloneCoordinatorTest.java | 14 +-
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 11 +-
.../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 ------------
.../dataset/EngineDataSetWithValueFilterTest.java | 159 -----
.../query/dataset/groupby/GroupByDataSetTest.java | 226 ------
.../dataset/groupby/GroupByFillDataSetTest.java | 194 ------
.../dataset/groupby/GroupByLevelDataSetTest.java | 161 -----
.../valuefilter/RawQueryWithValueFilterTest.java | 147 ----
.../sync/pipedata/BufferedPipeDataQueueTest.java | 3 +
.../iotdb/db/sync/pipedata/PipeDataTest.java | 21 +-
.../iotdb/db/tools/SchemaFileSketchTest.java | 2 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 9 +-
.../iotdb/db/utils/TsFileRewriteToolTest.java | 47 +-
.../apache/iotdb/rpc/TElasticFramedTransport.java | 4 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../rpc/TimeoutChangeableTFastFramedTransport.java | 8 +-
.../TimeoutChangeableTSnappyFramedTransport.java | 8 +-
.../java/org/apache/iotdb/session/ISession.java | 3 +
.../java/org/apache/iotdb/session/Session.java | 6 +
.../apache/iotdb/session/SessionConnection.java | 17 +
.../org/apache/iotdb/session/pool/SessionPool.java | 21 +
.../apache/iotdb/spark/db/EnvironmentUtils.java | 4 +-
.../org/apache/iotdb/spark/db/IoTDBTest.scala | 2 +
.../org/apache/iotdb/spark/db/IoTDBWriteTest.scala | 1 +
thrift/src/main/thrift/client.thrift | 19 +
.../apache/iotdb/tsfile/write/TsFileWriter.java | 4 +-
.../write/chunk/AlignedChunkGroupWriterImpl.java | 6 +-
.../tsfile/write/chunk/AlignedChunkWriterImpl.java | 4 +
.../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 1 +
.../tsfile/write/chunk/IChunkGroupWriter.java | 4 +-
.../iotdb/tsfile/write/chunk/TimeChunkWriter.java | 1 +
.../iotdb/tsfile/write/chunk/ValueChunkWriter.java | 12 +-
.../iotdb/tsfile/write/TsFileWriteApiTest.java | 264 +++++++
285 files changed, 5266 insertions(+), 11817 deletions(-)
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/statistics/UpdateLoadStatisticsPlan.java
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/node/{ => heartbeat}/BaseNodeCache.java (54%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/node/{ => heartbeat}/ConfigNodeHeartbeatCache.java (67%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/node/{ => heartbeat}/DataNodeHeartbeatCache.java (88%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/node/{ => heartbeat}/NodeHeartbeatSample.java (97%)
rename confignode/src/main/java/org/apache/iotdb/confignode/{persistence/node => manager/node/heartbeat}/NodeStatistics.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/{ => heartbeat}/RegionCache.java (87%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/{ => heartbeat}/RegionGroupCache.java (66%)
rename confignode/src/main/java/org/apache/iotdb/confignode/{persistence/partition/statistics => manager/partition/heartbeat}/RegionGroupStatistics.java (85%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/{ => heartbeat}/RegionHeartbeatSample.java (95%)
rename confignode/src/main/java/org/apache/iotdb/confignode/{persistence/partition/statistics => manager/partition/heartbeat}/RegionStatistics.java (94%)
copy tsfile/src/main/java/org/apache/iotdb/tsfile/read/query/dataset/EmptyDataSet.java => external-api/src/main/java/org/apache/iotdb/external/api/thrift/JudgableServerContext.java (63%)
copy influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol/constant/InfluxDBConstant.java => external-api/src/main/java/org/apache/iotdb/external/api/thrift/ServerContextFactory.java (78%)
rename integration-test/src/test/java/org/apache/iotdb/confignode/it/{IoTDBClusterAuthorizeIT.java => IoTDBClusterAuthorityIT.java} (99%)
copy integration-test/src/test/java/org/apache/iotdb/db/it/schema/{IoTDBMetadataFetchSchemaFileIT.java => IoTDBDeleteTimeseriesSchemaFileIT.java} (87%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/udf/IoTDBUDFM4IT.java
copy integration-test/src/test/java/org/apache/iotdb/{db/it/schema/IoTDBMetadataFetchSchemaFileIT.java => session/it/IoTDBConnectionInfoIT.java} (51%)
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFM4.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
copy server/src/main/java/org/apache/iotdb/db/exception/metadata/schemafile/{SchemaFileNotExists.java => SchemaFileLogCorruptedException.java} (77%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/log/SchemaFileLogReader.java
copy server/src/main/java/org/apache/iotdb/db/{qp/utils/EmptyOutputStream.java => metadata/mtree/store/disk/schemafile/log/SchemaFileLogSerializer.java} (68%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/log/SchemaFileLogWriter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/handler/QueryHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/meta/InfluxDBMetaManager.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/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
rename server/src/main/java/org/apache/iotdb/db/protocol/{mpprest => rest}/handler/StatementConstructionHandler.java (98%)
copy server/src/{test/java/org/apache/iotdb/db/query/control/QueryResourceManagerTest.java => main/java/org/apache/iotdb/db/query/control/SessionManagerMBean.java} (81%)
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/thrift/handler/BaseServerContextHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/impl/InfluxDBServiceImpl.java
delete mode 100644 server/src/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
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