This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/FixIntoOperator
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 037d74836b refactor IntoOperator
add a04c7023c7 Catch Throwable in DataNodeInternalService to avoid
ambiguous TException (#8126)
add ce92432c8c Remove start-new-server scripts (#8128)
add 4da2f1bf4f [IOTDB-4556] Optimize log of failing to flush sync index
(#8090)
add 3103c12a00 [IOTDB-5006]Add a load-tsfile script (#8120)
add ac3b408da8 [IOTDB-5010] DataRegion StateMachine support for Ratis
Snapshot (#8110)
add fbca630b0a Add dispatch node endpoint msg to error log (#8132)
add 94414ad041 remove duplicate code in the PlanNodeIterator (#8122)
add 76542ea665 [IOTDB-5031] Make snapshot taking in shutdown hook parallel
(#8134)
add f30463ff30 [IOTDB-5019] Fix releasing wal files after flushing
memtable (#8131)
add 3775e9277e fix the issue that client get 305 when explain non-existing
series (#8145)
add b762675f22 Make memory portion take effect after change the default
ratio (#8137)
add 443c30293f Fix abstract map bug when remove failing measurement (#8139)
add dd250fc49b Remove redundant PartialPath init in TsFileProcessor (#8153)
add df7eb81932 [IOTDB-4556] change the log level from warn to info in
IndexController (#8149)
add 24cd97d101 [IOTDB-5040] Common Config Manual for cluster V1.0 (#8142)
add 444bfade77 update trigger jar
add 9f12b58c0b [IOTDB-5028] Using `show timeseries` to query the schema in
import-csv (#8130)
add 91aa0341ae [IOTDB-4994] Unify reporter (#8144)
add 26bcaea5d7 Add readme docs for TsFile tools (#8154)
add e9b287c064 Update auth config (#8162)
add c1cd52be0a change log level of RatisConsensus(#8146)
add 818c3e6272 Update description of missing params to user-guide (#8157)
add 713f03ba74 Update doc of mem control (#8159)
add bcd0305f70 Fix the issue when doing distribution plan for aggregation
add b0c2d67f41 make simple consensuse as default for confignode (#8160)
add 1eb95896db add mqtt broker and rest service document (#8161)
add 53d69a7d33 Split trigger doc into muitlple files for better display
(#8169)
add 4cd5a5d5d6 Update user guide (query part/en) (#8168)
add 2236421f2f update compaction docs (#8156)
add a4396a7302 Update CQ docs (#8171)
add c6f933fdb5 add trigger conf in common-config-manual (#8166)
add 55d9a7d284 Update config manual (sync part) (#8172)
add 0456270015 Update config manual (hot-load part) (#8174)
add b59ce4faa7 [IOTDB-4970] Enhanced sync safety management (#8028)
add 25e0cb6713 Fix timeout problems in CI (#8173)
add 31643b5622 add ratis configuration doc (#8180)
add 0b66a04019 Skip checking duplicated measurements in one write request
(#8178)
add 816b99aba8 [IOTDB-5004] [Metrics] Fix the seq file size in grafana is
inconsistent with the actual query (#8177)
add 5432ee79e5 make org.apache.iotdb.consensus.ratis.RatisConsensus as
default for config_node_consensus_protocol_class (#8176)
add 40fe9e08db Update config manual (query part) (#8167)
add 2a1e33a176 print status code name when dispatch failed (#8150)
add aa9d16cec5 [IOTDB-4334] Verify durable cases of RegionGroup extension
(#8133)
add 8de5264016 Update the cluster concept UserGuide (#8182)
add e5208e8907 [IOTDB-5049] Add parameters enable leader balance for
specifed consensus protocol class (#8170)
add b18b7bfdd0 [IOTDB-5053] Update Metric Doc and fix. (#8179)
add 3fd50f7898 [IOTDB-4940] Optimize PartitonFetch Process in query (#8155)
add 992ae7f07e [IOTDB-4066] Allocate new RegionGroups through double
keyword sort (#8140)
add 5200e266ea Update user document of storage engine (#8185)
add 51e3a9c99a [IOTDB-4945] Retry with sleep to avoid failure in
connecting confignodes caused by Ratis election
add 8d153466b1 Rename MultiLeader to IoTConsensus (#8181)
add 2d6ba7c0ae Remove merge statement from docs (#8186)
add 48293ddfd1 Fix Compile error (#8187)
add d8397b4e79 Add wal parameters in the documentation (#8183)
add 583a87b11f [IOTDB-5044] Correct the show triggers error message if the
user doesn't have corresponding auth (#8158)
add 2567d2b083 [IOTDB-4708] add reserverd words (#8191)
add a2d86aabda update description of missing params to user-guide (#8189)
add 3d329af059 Change default value of timed flush memtable and primitive
array size (#8188)
add d11c73590b [IOTDB-5052] Query release others' file reader by mistake
(#8190)
add e0c5e30da5 [IOTDB-3928][IOTDB-4097]New Compaction Performer —— Fast
Compaction (#7621)
add f7faed2b9b [IOTDB-5013] Added simple standalone logic for starting and
stopping shells (#8152)
add 17036c94dc Fix insert tablets npe (#8193)
add 93b875c98e Change default consensus (#8194)
add c60783898a [IOTDB-4553] Make code of region migrate process tidy
(#8138)
add fa2766c48a add faq for index out of bounds exception (#8197)
add ffbdaf3994 update ratis 2.4.1 formal version (#8196)
add 1966a070f6 [IOTDB-5058] Add custom RegionGroup extension policy (#8199)
add 4d7c15ddcd update doc of partition (#8201)
add 1ee088aac3 Deploy site using GitHub (#8203)
add 26cbba0205 [IOTDB-5056] Modify value of some parameters (#8195)
add d3b96a6e9d [IOTDB-4513] Improve load balance UserGuide (#8204)
add e5b4dfe033 Fix slot query bug; add optimization for getSchemaPartition
(#8200)
add 01d10843ac add common config in config.js (#8205)
add d3d2cf9950 Try to fix query performance (#8208)
add 941b12ada3 [IOTDB-5050] Try to make TsBlock returned by ScanOperator
larger (#8198)
add d3534b7180 fix restart problem in confignode simple (#8207)
add 68c06372d7 speed up ratis first election (#8209)
add 7c22141247 add docs for pattern_matching_threshold (#8212)
add 17ae35d5e7 rename Multi Leader Conesensus to IoTConsensus for RPC
service name (#8211)
add f3938bfdad [IOTDB-5062][Metric] Update Doc And Update Grafana
Dashboard (#8210)
add 82cc6bac49 change sleep time (#8213)
add c43deda65b Fix IT bug (#8206)
add 40a2596ee8 Update pom version and doc to 1.0 (#8214)
add 40de3ad14e Revert "Update pom version and doc to 1.0 (#8214)" (#8217)
new 55e629bd99 Merge remote-tracking branch 'origin/master' into
lmh/FixIntoOperator
new 4214a2240b fix
new 3186ba814d finish
new 93caabc429 add config
The 4 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:
.github/workflows/client-go.yml | 4 +-
.github/workflows/client-python.yml | 4 +-
.github/workflows/site-build.yml | 33 +-
RELEASE_NOTES.md | 2 +-
cli/src/assembly/resources/tools/load-tsfile.bat | 107 +
cli/src/assembly/resources/tools/load-tsfile.sh | 132 +
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 65 +-
.../resources/conf/iotdb-confignode.properties | 4 -
.../client/async/AsyncDataNodeClientPool.java | 13 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 117 +-
.../confignode/conf/ConfigNodeDescriptor.java | 75 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 5 +-
.../confignode/conf/SystemPropertiesUtils.java | 6 +-
.../consensus/request/ConfigPhysicalPlan.java | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 1 +
.../request/write/sync/RecordPipeMessagePlan.java | 65 +
.../statemachine/ConfigNodeRegionStateMachine.java | 2 +-
.../confignode/manager/ClusterSchemaManager.java | 57 +-
.../iotdb/confignode/manager/ConfigManager.java | 61 +-
.../iotdb/confignode/manager/ConsensusManager.java | 21 +-
.../apache/iotdb/confignode/manager/IManager.java | 8 +
.../iotdb/confignode/manager/SyncManager.java | 12 +
.../iotdb/confignode/manager/load/LoadManager.java | 2 +-
.../manager/load/LoadManagerMetrics.java | 104 +-
.../manager/load/balancer/RegionBalancer.java | 85 +-
.../manager/load/balancer/RouteBalancer.java | 53 +-
...cator.java => CopySetRegionGroupAllocator.java} | 15 +-
.../balancer/region/GreedyRegionAllocator.java | 68 -
.../region/GreedyRegionGroupAllocator.java | 101 +
...onAllocator.java => IRegionGroupAllocator.java} | 24 +-
.../router/leader/MinCostFlowLeaderBalancer.java | 2 +-
.../iotdb/confignode/manager/node/NodeManager.java | 20 +-
.../node/heartbeat/DataNodeHeartbeatCache.java | 13 +
.../node/heartbeat/NodeHeartbeatSample.java | 21 +-
.../partition/DataRegionGroupExtensionPolicy.java | 47 +-
.../manager/partition/PartitionManager.java | 204 +-
.../persistence/executor/ConfigPlanExecutor.java | 3 +
.../persistence/metric/NodeInfoMetrics.java | 95 -
.../persistence/metric/PartitionInfoMetrics.java | 16 +-
.../persistence/sync/ClusterSyncInfo.java | 9 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 4 +-
.../procedure/env/DataNodeRemoveHandler.java | 27 +-
.../procedure/state/CreateRegionGroupsState.java | 2 +-
.../iotdb/confignode/service/ConfigNode.java | 2 +-
.../thrift/ConfigNodeRPCServiceHandlerMetrics.java | 2 +-
.../thrift/ConfigNodeRPCServiceMetrics.java | 2 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 +
.../balancer/region/GreedyRegionAllocatorTest.java | 92 -
.../region/GreedyRegionGroupAllocatorTest.java | 140 +
.../confignode1conf/iotdb-common.properties | 2 +-
.../confignode1conf/iotdb-confignode.properties | 4 +-
.../confignode2conf/iotdb-common.properties | 2 +-
.../confignode2conf/iotdb-confignode.properties | 4 +-
.../confignode3conf/iotdb-common.properties | 2 +-
.../confignode3conf/iotdb-confignode.properties | 4 +-
consensus/pom.xml | 4 +-
.../apache/iotdb/consensus/ConsensusFactory.java | 3 +-
.../org/apache/iotdb/consensus/IStateMachine.java | 13 +-
.../common/request/IndexedConsensusRequest.java | 2 +-
...sensusRequest.java => IoTConsensusRequest.java} | 12 +-
.../iotdb/consensus/config/ConsensusConfig.java | 20 +-
...tiLeaderConfig.java => IoTConsensusConfig.java} | 8 +-
.../IoTConsensus.java} | 96 +-
.../IoTConsensusServerImpl.java} | 117 +-
.../IoTConsensusServerMetrics.java} | 32 +-
.../client/AsyncIoTConsensusServiceClient.java} | 27 +-
.../client/DispatchLogHandler.java | 10 +-
.../client/IoTConsensusClientPool.java} | 45 +-
.../client/SyncIoTConsensusServiceClient.java} | 32 +-
.../logdispatcher/IndexController.java | 13 +-
.../logdispatcher/IoTConsensusMemoryManager.java} | 14 +-
.../IoTConsensusMemoryManagerMetrics.java} | 18 +-
.../logdispatcher/LogDispatcher.java | 52 +-
.../logdispatcher/LogDispatcherThreadMetrics.java | 14 +-
.../logdispatcher/PendingBatch.java | 10 +-
.../logdispatcher/SyncStatus.java | 18 +-
.../service/IoTConsensusRPCService.java} | 32 +-
.../service/IoTConsensusRPCServiceHandler.java} | 8 +-
.../service/IoTConsensusRPCServiceMBean.java} | 4 +-
.../service/IoTConsensusRPCServiceProcessor.java} | 76 +-
.../snapshot/SnapshotFragment.java | 4 +-
.../snapshot/SnapshotFragmentReader.java | 2 +-
.../wal/ConsensusReqReader.java | 6 +-
.../wal/GetConsensusReqReaderPlan.java | 2 +-
.../ratis/ApplicationStateMachineProxy.java | 3 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 6 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 31 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 4 +
.../IoTConsensusTest.java} | 20 +-
.../{multileader => iot}/RecoveryTest.java | 8 +-
.../logdispatcher/IndexControllerTest.java | 2 +-
.../logdispatcher/SyncStatusTest.java | 18 +-
.../util/FakeConsensusReqReader.java | 4 +-
.../{multileader => iot}/util/RequestSets.java | 2 +-
.../{multileader => iot}/util/TestEntry.java | 6 +-
.../util/TestStateMachine.java | 6 +-
docs/UserGuide/Cluster/Cluster-Concept.md | 42 +-
docs/UserGuide/Cluster/Cluster-Setup.md | 68 +-
.../Edge-Cloud-Collaboration/Sync-Tool.md | 21 +-
docs/UserGuide/FAQ/Frequently-asked-questions.md | 4 +
.../IoTDB-Data-Dir-Overview-Tool.md | 82 +
.../Load-Tsfile.md} | 41 +-
.../Maintenance-Tools/Maintenance-Command.md | 21 +-
.../Maintenance-Tools/Rewrite-TsFile-Tool.md | 62 -
.../TsFile-Resource-Sketch-Tool.md | 79 +
.../Maintenance-Tools/TsFile-Sketch-Tool.md | 108 +
docs/UserGuide/Monitor-Alert/Alerting.md | 2 +-
docs/UserGuide/Monitor-Alert/Metric-Tool.md | 575 +-
docs/UserGuide/Operators-Functions/Aggregation.md | 58 +
.../Anomaly-Detection.md | 0
docs/UserGuide/Operators-Functions/Comparison.md | 305 +
docs/UserGuide/Operators-Functions/Constant.md | 57 +
.../Operators-Functions/Continuous-Interval.md | 73 +
docs/UserGuide/Operators-Functions/Conversion.md | 127 +
.../Data-Matching.md | 0
.../Data-Profiling.md | 0
.../Data-Quality.md | 0
.../Data-Repairing.md | 0
.../Frequency-Domain.md | 0
docs/UserGuide/Operators-Functions/Lambda.md | 77 +
docs/UserGuide/Operators-Functions/Logical.md | 63 +
docs/UserGuide/Operators-Functions/Mathematical.md | 113 +
.../Overview.md} | 24 +
docs/UserGuide/Operators-Functions/Sample.md | 389 ++
docs/UserGuide/Operators-Functions/Selection.md | 51 +
.../Series-Discovery.md | 0
.../String.md} | 66 +
.../Time-Series.md} | 2 +-
.../User-Defined-Function.md} | 2 -
.../Operators-Functions/Variation-Trend.md | 54 +
.../Query-Data/{Result-Format.md => Align-By.md} | 2 +-
.../Continuous-Query.md | 0
.../Query-Data/{Fill-Null-Value.md => Fill.md} | 0
.../Query-Data/{Aggregate-Query.md => Group-By.md} | 142 +-
docs/UserGuide/Query-Data/Having-Condition.md | 115 +
.../{UDF-Library/M4.md => Query-Data/Order-By.md} | 7 +-
docs/UserGuide/Query-Data/Overview.md | 76 +-
docs/UserGuide/Query-Data/Pagination.md | 2 +-
.../Query-Data/Performance-Tracing-Tool.md | 53 -
docs/UserGuide/Query-Data/Select-Expression.md | 1068 +---
.../{Process-Data => Query-Data}/Select-Into.md | 0
.../{Query-Filter.md => Where-Condition.md} | 0
docs/UserGuide/QuickStart/QuickStart.md | 49 +-
docs/UserGuide/Reference/Common-Config-Manual.md | 1978 ++++++
.../Reference/ConfigNode-Config-Manual.md | 213 +-
docs/UserGuide/Reference/DataNode-Config-Manual.md | 1172 +---
docs/UserGuide/Reference/Keywords.md | 7 +-
.../M4.md => Trigger/Configuration-Parameters.md} | 8 +-
.../Triggers.md => Trigger/Implement-Trigger.md} | 201 +-
docs/UserGuide/Trigger/Instructions.md | 51 +
docs/UserGuide/Trigger/Notes.md | 30 +
docs/UserGuide/Trigger/Trigger-Management.md | 152 +
docs/UserGuide/Write-Data/Batch-Load-Tool.md | 2 +-
docs/zh/UserGuide/Cluster/Cluster-Concept.md | 49 +-
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 59 +-
.../Edge-Cloud-Collaboration/Sync-Tool.md | 13 +-
.../zh/UserGuide/FAQ/Frequently-asked-questions.md | 5 +
.../IoTDB-Data-Dir-Overview-Tool.md | 82 +
.../Load-Tsfile.md} | 41 +-
.../Maintenance-Tools/Maintenance-Command.md | 21 +-
.../Maintenance-Tools/Rewrite-TsFile-Tool.md | 62 -
.../TsFile-Resource-Sketch-Tool.md | 79 +
.../Maintenance-Tools/TsFile-Sketch-Tool.md | 108 +
docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md | 738 ++-
docs/zh/UserGuide/Query-Data/Align-By.md | 2 +-
docs/zh/UserGuide/QuickStart/QuickStart.md | 38 +-
.../zh/UserGuide/Reference/Common-Config-Manual.md | 2021 ++++++
.../Reference/ConfigNode-Config-Manual.md | 193 +-
.../UserGuide/Reference/DataNode-Config-Manual.md | 1694 +----
docs/zh/UserGuide/Reference/Keywords.md | 7 +-
.../UserGuide/Trigger/Configuration-Parameters.md} | 8 +-
.../Trigger/{Trigger.md => Implement-Trigger.md} | 198 +-
docs/zh/UserGuide/Trigger/Instructions.md | 46 +
docs/zh/UserGuide/Trigger/Notes.md | 33 +
docs/zh/UserGuide/Trigger/Trigger-Management.md | 152 +
docs/zh/UserGuide/Write-Data/Batch-Load-Tool.md | 2 +-
...json => Apache IoTDB ConfigNode Dashboard.json} | 1440 ++++-
...0.json => Apache IoTDB DataNode Dashboard.json} | 2369 +++++--
.../standalone/Apache IoTDB Dashboard v0.14.0.json | 1519 -----
.../trigger/example/TriggerFireTimesCounter.java | 5 +
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 49 +-
.../org/apache/iotdb/it/env/DataNodeWrapper.java | 12 +-
.../java/org/apache/iotdb/it/env/MppConfig.java | 40 +-
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 18 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 38 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 10 +
.../it/IoTDBClusterRegionLeaderBalancingIT.java | 59 +-
.../it/IoTDBConfigNodeSwitchLeaderIT.java | 3 +-
.../it/partition/IoTDBPartitionDurableIT.java | 626 ++
.../it/partition/IoTDBPartitionDurableTest.java | 323 -
.../it/partition/IoTDBPartitionGetterIT.java | 113 +-
...est.java => IoTDBPartitionInheritPolicyIT.java} | 28 +-
.../it/partition/IoTDBRegionGroupExtensionIT.java | 156 +
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 18 +-
.../db/it/groupby/IoTDBGroupByNaturalMonthIT.java | 6 +-
.../src/test/resources/TriggerFireTimesCounter.jar | Bin 1324 -> 1397 bytes
.../db/integration/sync/IoTDBSyncReceiverIT.java | 2 +-
.../sync/IoTDBSyncReceiverLoaderIT.java | 6 +-
.../iotdb/db/integration/sync/MockSyncClient.java | 4 +-
metrics/dropwizard-metrics/pom.xml | 5 -
.../reporter/DropwizardIoTDBReporter.java | 79 -
.../dropwizard/reporter/DropwizardJmxReporter.java | 9 +-
.../dropwizard/reporter/DropwizardMetricType.java | 38 -
.../reporter/DropwizardMetricsExporter.java | 168 -
.../reporter/DropwizardPrometheusReporter.java | 118 -
.../metrics/dropwizard/reporter/IoTDBReporter.java | 278 -
.../type/DropwizardHistogramSnapshot.java | 7 -
... org.apache.iotdb.metrics.reporter.JmxReporter} | 4 +-
metrics/interface/pom.xml | 11 +-
.../iotdb/metrics/AbstractMetricManager.java | 99 +-
.../iotdb/metrics/AbstractMetricService.java | 153 +-
.../metrics/{reporter => }/CompositeReporter.java | 3 +-
.../iotdb/metrics/DoNothingMetricService.java | 4 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 16 +-
.../metrics/config/MetricConfigDescriptor.java | 12 +-
.../metrics/impl/DoNothingHistogramSnapshot.java | 7 -
.../metricsets/jvm/JvmClassLoaderMetrics.java | 8 +-
.../metrics/metricsets/jvm/JvmCompileMetrics.java | 4 +-
.../iotdb/metrics/metricsets/jvm/JvmGcMetrics.java | 24 +-
.../metrics/metricsets/jvm/JvmMemoryMetrics.java | 36 +-
.../metrics/metricsets/jvm/JvmThreadMetrics.java | 16 +-
.../metrics/metricsets/logback/LogbackMetrics.java | 10 +-
.../metricsets/logback/MetricsTurboFilter.java | 10 +-
.../iotdb/metrics/reporter/InternalReporter.java | 104 -
.../reporter/{Reporter.java => JmxReporter.java} | 14 +-
.../apache/iotdb/metrics/reporter/Reporter.java | 4 -
.../reporter/iotdb/InternalIoTDBReporter.java | 67 +
.../metrics/reporter/iotdb/IoTDBReporter.java | 103 +
.../MemoryInternalIoTDBReporter.java} | 30 +-
.../reporter/iotdb/SessionIoTDBReporter.java | 175 +
.../reporter/prometheus/PrometheusReporter.java | 222 +
.../reporter/prometheus}/PrometheusTextWriter.java | 44 +-
.../org/apache/iotdb/metrics/type/AutoGauge.java | 7 +
.../org/apache/iotdb/metrics/type/Counter.java | 7 +
.../java/org/apache/iotdb/metrics/type/Gauge.java | 7 +
.../org/apache/iotdb/metrics/type/Histogram.java | 8 +
.../iotdb/metrics/type/HistogramSnapshot.java | 18 +-
.../org/apache/iotdb/metrics/type/IMetric.java | 6 +-
.../java/org/apache/iotdb/metrics/type/Rate.java | 11 +
.../java/org/apache/iotdb/metrics/type/Timer.java | 7 +
.../iotdb/metrics/utils/IoTDBMetricsUtils.java | 75 +-
.../org/apache/iotdb/metrics/utils/MetricInfo.java | 9 +-
.../org/apache/iotdb/metrics/utils/MetricType.java | 1 +
.../iotdb/metrics/config/MetricConfigTest.java | 3 -
.../micrometer/MicrometerMetricManager.java | 1 +
.../micrometer/reporter/IoTDBMeterRegistry.java | 149 -
.../micrometer/reporter/IoTDBRegistryConfig.java | 50 -
.../reporter/MicrometerIoTDBReporter.java | 92 -
.../micrometer/reporter/MicrometerJmxReporter.java | 7 +-
.../reporter/MicrometerPrometheusReporter.java | 118 -
.../type/MicrometerHistogramSnapshot.java | 7 -
... org.apache.iotdb.metrics.reporter.JmxReporter} | 4 +-
.../resources/conf/iotdb-common.properties | 287 +-
.../src/assembly/resources/sbin/iotdb-common.sh | 2 +-
.../assembly/resources/sbin/start-standalone.bat | 42 +
.../assembly/resources/sbin/start-standalone.sh | 37 +-
.../assembly/resources/sbin/stop-standalone.bat | 40 +
.../src/assembly/resources/sbin/stop-standalone.sh | 34 +-
.../apache/iotdb/commons/client/ClientManager.java | 2 +-
.../sync/SyncThriftClientWithErrorHandler.java | 3 +-
.../iotdb/commons/concurrent/ThreadName.java | 4 +-
.../exception/sync}/SyncConnectionException.java | 2 +-
.../exception/sync/SyncHandshakeException.java | 9 +-
.../commons/partition/DataPartitionQueryParam.java | 6 +
.../apache/iotdb/commons/service/ServiceType.java | 2 +-
.../commons/service/metric/MetricService.java | 10 +-
.../iotdb/commons/service/metric/enums/Metric.java | 3 +-
.../iotdb/commons/sync/metadata/SyncMetadata.java | 3 +
.../iotdb/commons/sync/pipe/PipeMessage.java | 54 +-
.../commons/sync/transport/SyncIdentityInfo.java | 57 +
.../iotdb/commons/sync/utils/SyncPathUtil.java | 11 +-
.../org/apache/iotdb/commons/utils/PathUtils.java | 39 +-
pom.xml | 4 +-
.../resources/conf/iotdb-datanode.properties | 57 +-
.../assembly/resources/sbin/start-new-server.bat | 167 -
.../assembly/resources/sbin/start-new-server.sh | 249 -
.../apache/iotdb/db/client/ConfigNodeClient.java | 174 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 95 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 65 +-
.../db/consensus/DataRegionConsensusImpl.java | 10 +-
.../consensus/statemachine/BaseStateMachine.java | 4 +-
.../statemachine/DataRegionStateMachine.java | 23 +-
.../apache/iotdb/db/engine/StorageEngineV2.java | 2 +-
.../iotdb/db/engine/TsFileMetricManager.java | 6 +-
.../iotdb/db/engine/cache/ChunkCacheMetrics.java | 2 +-
.../cache/TimeSeriesMetadataCacheMetrics.java | 4 +-
.../compaction/CompactionExceptionHandler.java | 6 +-
.../db/engine/compaction/CompactionUtils.java | 91 +-
.../constant/CrossCompactionPerformer.java | 11 +-
.../constant/InnerSeqCompactionPerformer.java | 11 +-
.../constant/InnerUnseqCompactionPerformer.java | 12 +-
.../compaction/cross/CrossSpaceCompactionTask.java | 46 +-
.../RewriteCrossSpaceCompactionSelector.java | 13 +-
.../task/FastCompactionPerformerSubTask.java | 146 +
.../utils/AlignedSeriesCompactionExecutor.java | 339 +
.../cross/utils/ChunkMetadataElement.java | 48 +-
.../engine/compaction/cross/utils/FileElement.java | 14 +-
.../utils/NonAlignedSeriesCompactionExecutor.java | 208 +
.../engine/compaction/cross/utils/PageElement.java | 101 +
.../compaction/cross/utils/PointElement.java | 50 +
.../cross/utils/SeriesCompactionExecutor.java | 591 ++
.../compaction/inner/InnerSpaceCompactionTask.java | 32 +-
.../inner/utils/MultiTsFileDeviceIterator.java | 110 +-
.../compaction/performer/ICompactionPerformer.java | 8 +-
.../performer/impl/FastCompactionPerformer.java | 294 +
.../impl/ReadPointCompactionPerformer.java | 93 +-
.../compaction/reader/PointPriorityReader.java | 152 +
.../compaction/task/SubCompactionTaskSummary.java | 40 +
.../writer/AbstractCompactionWriter.java | 289 +-
.../writer/AbstractCrossCompactionWriter.java | 233 +
.../writer/AbstractInnerCompactionWriter.java | 108 +
.../writer/CrossSpaceCompactionWriter.java | 256 -
.../writer/FastCrossCompactionWriter.java | 203 +
.../writer/FastInnerCompactionWriter.java | 212 +
.../writer/InnerSpaceCompactionWriter.java | 140 -
.../writer/ReadPointCrossCompactionWriter.java | 94 +
.../writer/ReadPointInnerCompactionWriter.java | 79 +
.../iotdb/db/engine/flush/FlushManagerMetrics.java | 4 +-
.../iotdb/db/engine/snapshot/SnapshotTaker.java | 17 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 30 +-
.../db/engine/storagegroup/DataRegionMetrics.java | 6 +-
.../db/engine/storagegroup/TsFileManager.java | 12 +-
.../db/engine/storagegroup/TsFileProcessor.java | 196 +-
.../storagegroup/TsFileProcessorInfoMetrics.java | 2 +-
.../metadata/cache/DataNodeSchemaCacheMetrics.java | 2 +-
.../rescon/SchemaStatisticsManagerMetrics.java | 2 +-
.../iotdb/db/mpp/execution/driver/DataDriver.java | 2 +-
.../execution/exchange/MPPDataExchangeManager.java | 8 +-
.../exchange/MPPDataExchangeServiceMetrics.java | 2 +-
...MppDataExchangeServiceThriftHandlerMetrics.java | 2 +-
.../execution/executor/RegionWriteExecutor.java | 17 +-
.../fragment/FragmentInstanceContext.java | 22 +-
.../fragment/FragmentInstanceManager.java | 16 +-
.../operator/process/AbstractIntoOperator.java | 102 +-
.../operator/process/DeviceViewIntoOperator.java | 13 +-
.../execution/operator/process/IntoOperator.java | 14 +-
.../process/join/merge/MultiColumnMerger.java | 18 +-
.../operator/source/AlignedSeriesScanOperator.java | 121 +-
.../operator/source/SeriesScanOperator.java | 118 +-
.../apache/iotdb/db/mpp/plan/TestRPCClient.java | 26 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 68 +-
.../memory/StatementMemorySourceVisitor.java | 15 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 2 +-
.../plan/planner/LocalExecutionPlanContext.java | 5 +
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 6 +-
.../plan/planner/distribution/SourceRewriter.java | 2 +-
.../metedata/write/CreateMultiTimeSeriesNode.java | 5 +-
.../plan/planner/plan/node/write/InsertNode.java | 4 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 6 +-
.../statement/metadata/ShowTriggersStatement.java | 6 -
.../control/clientsession/IClientSession.java | 2 +-
.../pool/RawQueryReadTaskPoolManagerMetrics.java | 4 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 18 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 4 +-
.../service/DataNodeInternalRPCServiceMetrics.java | 2 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 1 +
.../apache/iotdb/db/service/RPCServiceMetrics.java | 2 +-
.../iotdb/db/service/RegionMigrateService.java | 367 +-
.../iotdb/db/service/metrics/FileMetrics.java | 14 +-
.../db/service/metrics/IoTDBInternalReporter.java | 126 +-
.../iotdb/db/service/metrics/ProcessMetrics.java | 21 +-
.../iotdb/db/service/metrics/SystemMetrics.java | 25 +-
.../InternalServiceThriftHandlerMetrics.java | 5 +-
.../handler/RPCServiceThriftHandlerMetrics.java | 2 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 27 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 23 +-
.../db/service/thrift/impl/TSServiceImpl.java | 23 +-
.../java/org/apache/iotdb/db/sync/SyncService.java | 24 +-
.../db/sync/common/ClusterSyncInfoFetcher.java | 12 +-
.../iotdb/db/sync/pipedata/DeletionPipeData.java | 4 +-
.../apache/iotdb/db/sync/pipedata/PipeData.java | 2 +-
.../iotdb/db/sync/pipedata/TsFilePipeData.java | 4 +-
.../load/DeletionLoader.java | 2 +-
.../sync/{receiver => pipedata}/load/ILoader.java | 2 +-
.../{receiver => pipedata}/load/TsFileLoader.java | 2 +-
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 2 +
.../db/sync/transport/client/ISyncClient.java | 7 +-
.../db/sync/transport/client/IoTDBSyncClient.java | 34 +-
.../db/sync/transport/client/SenderManager.java | 49 +-
.../sync/transport/client/SyncClientFactory.java | 34 +-
.../db/sync/transport/server/ReceiverManager.java | 54 +-
.../db/tools/validate/TsFileValidationTool.java | 7 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 4 +-
.../java/org/apache/iotdb/db/wal/WALManager.java | 20 +-
.../db/wal/allocation/FirstCreateStrategy.java | 2 +-
.../org/apache/iotdb/db/wal/buffer/WALEntry.java | 4 +-
.../org/apache/iotdb/db/wal/node/IWALNode.java | 2 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 22 +-
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 6 +-
.../engine/compaction/AbstractCompactionTest.java | 208 +-
.../compaction/CompactionTaskComparatorTest.java | 4 +-
.../compaction/CompactionTaskManagerTest.java | 74 +-
.../compaction/FastAlignedCrossCompactionTest.java | 6689 ++++++++++++++++++++
....java => FastCrossCompactionPerformerTest.java} | 4215 ++++--------
.../FastInnerCompactionPerformerTest.java | 1824 ++++++
.../FastNonAlignedCrossCompactionTest.java | 6655 +++++++++++++++++++
.../ReadPointCompactionPerformerTest.java | 929 ++-
.../cross/CrossSpaceCompactionValidationTest.java | 98 +-
.../cross/RewriteCrossSpaceCompactionTest.java | 10 +-
...ava => FastCompactionPerformerAlignedTest.java} | 43 +-
...a => FastCompactionPerformerNoAlignedTest.java} | 64 +-
...> InnerSeqCompactionWithFastPerformerTest.java} | 99 +-
...erSeqCompactionWithReadChunkPerformerTest.java} | 14 +-
.../inner/InnerSpaceCompactionExceptionTest.java | 26 +-
...InnerUnseqCompactionWithFastPerformerTest.java} | 17 +-
...UnseqCompactionWithReadPointPerformerTest.java} | 11 +-
.../ReadChunkCompactionPerformerAlignedTest.java | 36 +-
.../ReadChunkCompactionPerformerNoAlignedTest.java | 48 +-
.../inner/ReadChunkCompactionPerformerOldTest.java | 7 +-
.../SizeTieredCompactionRecoverTest.java | 48 +-
...eCrossSpaceCompactionRecoverCompatibleTest.java | 33 +-
.../SizeTieredCompactionRecoverCompatibleTest.java | 26 +-
.../recover/SizeTieredCompactionRecoverTest.java | 38 +-
.../compaction/utils/TsFileGeneratorUtils.java | 257 +
.../db/engine/storagegroup/DataRegionTest.java | 7 +-
.../engine/storagegroup/TsFileProcessorV2Test.java | 16 +-
.../apache/iotdb/db/metric/MetricServiceTest.java | 64 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 48 +-
.../db/mpp/execution/exchange/SinkHandleTest.java | 88 +-
.../mpp/execution/exchange/SourceHandleTest.java | 70 +-
.../operator/AlignedSeriesScanOperatorTest.java | 191 +-
.../operator/DeviceMergeOperatorTest.java | 73 +-
.../execution/operator/DeviceViewOperatorTest.java | 18 +-
.../mpp/execution/operator/LimitOperatorTest.java | 42 +-
.../mpp/execution/operator/OffsetOperatorTest.java | 90 +-
.../operator/RawDataAggregationOperatorTest.java | 41 +-
.../execution/operator/SeriesScanOperatorTest.java | 29 +-
.../execution/operator/TimeJoinOperatorTest.java | 115 +-
.../schedule/queue/L2PriorityQueueTest.java | 20 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeTest.java | 2 +-
.../mpp/plan/analyze/QueryTimePartitionTest.java | 532 ++
.../iotdb/db/tools/TsFileSelfCheckToolTest.java | 2 +-
.../datastructure/PrimitiveArrayManagerTest.java | 18 +-
.../iotdb/db/wal/node/ConsensusReqReaderTest.java | 2 +-
.../datanode1conf/iotdb-datanode.properties | 4 +-
.../datanode2conf/iotdb-datanode.properties | 4 +-
.../datanode3conf/iotdb-datanode.properties | 4 +-
site/src/main/.vuepress/config.js | 100 +-
.../src/main/thrift/confignode.thrift | 8 +
.../pom.xml | 6 +-
.../src/main/thrift/iotconsensus.thrift | 4 +-
thrift/src/main/thrift/client.thrift | 10 +-
thrift/src/main/thrift/datanode.thrift | 3 +
.../iotdb/tsfile/common/conf/TSFileConfig.java | 4 +-
.../tsfile/common/constant/TsFileConstant.java | 3 +
.../tsfile/file/metadata/TimeseriesMetadata.java | 15 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 69 +-
.../apache/iotdb/tsfile/read/common/TimeRange.java | 2 +-
.../read/common/block/column/BinaryColumn.java | 9 -
.../read/common/block/column/BooleanColumn.java | 9 -
.../read/common/block/column/ColumnBuilder.java | 2 +
.../read/common/block/column/DoubleColumn.java | 9 -
.../read/common/block/column/FloatColumn.java | 9 -
.../tsfile/read/common/block/column/IntColumn.java | 9 -
.../read/common/block/column/LongColumn.java | 9 -
.../block/column/RunLengthEncodedColumn.java | 15 -
.../read/common/block/column/TimeColumn.java | 7 -
.../iotdb/tsfile/read/filter/GroupByFilter.java | 10 +
.../iotdb/tsfile/read/filter/TimeFilter.java | 84 +
.../iotdb/tsfile/read/filter/basic/Filter.java | 7 +
.../tsfile/read/filter/operator/AndFilter.java | 40 +
.../tsfile/read/filter/operator/NotFilter.java | 27 +
.../tsfile/read/filter/operator/OrFilter.java | 66 +
.../read/reader/chunk/AlignedChunkReader.java | 69 +
.../tsfile/read/reader/chunk/ChunkReader.java | 67 +
.../iotdb/tsfile/utils/TsFileGeneratorUtils.java | 8 +-
.../tsfile/write/chunk/AlignedChunkWriterImpl.java | 36 +-
.../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 26 +
.../iotdb/tsfile/write/chunk/IChunkWriter.java | 12 +
.../iotdb/tsfile/write/chunk/TimeChunkWriter.java | 8 +
.../iotdb/tsfile/write/chunk/ValueChunkWriter.java | 24 +
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 36 +-
.../tsfile/common/block/NullColumnUnitTest.java | 30 -
.../iotdb/tsfile/read/common/ColumnTest.java | 152 +-
474 files changed, 39327 insertions(+), 17642 deletions(-)
create mode 100644 cli/src/assembly/resources/tools/load-tsfile.bat
create mode 100644 cli/src/assembly/resources/tools/load-tsfile.sh
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/RecordPipeMessagePlan.java
rename
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/region/{CopySetRegionAllocator.java
=> CopySetRegionGroupAllocator.java} (91%)
delete mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/region/GreedyRegionAllocator.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/region/GreedyRegionGroupAllocator.java
rename
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/region/{IRegionAllocator.java
=> IRegionGroupAllocator.java} (70%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/sync/pipe/PipeMessage.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/DataRegionGroupExtensionPolicy.java
(54%)
delete mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/persistence/metric/NodeInfoMetrics.java
delete mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/region/GreedyRegionAllocatorTest.java
create mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/region/GreedyRegionGroupAllocatorTest.java
rename
consensus/src/main/java/org/apache/iotdb/consensus/common/request/{MultiLeaderConsensusRequest.java
=> IoTConsensusRequest.java} (69%)
rename
consensus/src/main/java/org/apache/iotdb/consensus/config/{MultiLeaderConfig.java
=> IoTConsensusConfig.java} (98%)
rename
consensus/src/main/java/org/apache/iotdb/consensus/{multileader/MultiLeaderConsensus.java
=> iot/IoTConsensus.java} (78%)
rename
consensus/src/main/java/org/apache/iotdb/consensus/{multileader/MultiLeaderServerImpl.java
=> iot/IoTConsensusServerImpl.java} (87%)
rename
consensus/src/main/java/org/apache/iotdb/consensus/{multileader/MultiLeaderServerMetrics.java
=> iot/IoTConsensusServerMetrics.java} (76%)
rename
consensus/src/main/java/org/apache/iotdb/consensus/{multileader/client/AsyncMultiLeaderServiceClient.java
=> iot/client/AsyncIoTConsensusServiceClient.java} (79%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader =>
iot}/client/DispatchLogHandler.java (92%)
rename
consensus/src/main/java/org/apache/iotdb/consensus/{multileader/client/MultiLeaderConsensusClientPool.java
=> iot/client/IoTConsensusClientPool.java} (61%)
rename
consensus/src/main/java/org/apache/iotdb/consensus/{multileader/client/SyncMultiLeaderServiceClient.java
=> iot/client/SyncIoTConsensusServiceClient.java} (78%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader =>
iot}/logdispatcher/IndexController.java (89%)
rename
consensus/src/main/java/org/apache/iotdb/consensus/{multileader/logdispatcher/MultiLeaderMemoryManager.java
=> iot/logdispatcher/IoTConsensusMemoryManager.java} (85%)
rename
consensus/src/main/java/org/apache/iotdb/consensus/{multileader/logdispatcher/MultiLeaderMemoryManagerMetrics.java
=> iot/logdispatcher/IoTConsensusMemoryManagerMetrics.java} (71%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader =>
iot}/logdispatcher/LogDispatcher.java (91%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader =>
iot}/logdispatcher/LogDispatcherThreadMetrics.java (91%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader =>
iot}/logdispatcher/PendingBatch.java (90%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader =>
iot}/logdispatcher/SyncStatus.java (84%)
rename
consensus/src/main/java/org/apache/iotdb/consensus/{multileader/service/MultiLeaderRPCService.java
=> iot/service/IoTConsensusRPCService.java} (71%)
rename
consensus/src/main/java/org/apache/iotdb/consensus/{multileader/service/MultiLeaderRPCServiceHandler.java
=> iot/service/IoTConsensusRPCServiceHandler.java} (84%)
rename
consensus/src/main/java/org/apache/iotdb/consensus/{multileader/service/MultiLeaderRPCServiceMBean.java
=> iot/service/IoTConsensusRPCServiceMBean.java} (88%)
rename
consensus/src/main/java/org/apache/iotdb/consensus/{multileader/service/MultiLeaderRPCServiceProcessor.java
=> iot/service/IoTConsensusRPCServiceProcessor.java} (81%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader =>
iot}/snapshot/SnapshotFragment.java (93%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader =>
iot}/snapshot/SnapshotFragmentReader.java (97%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader =>
iot}/wal/ConsensusReqReader.java (93%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader =>
iot}/wal/GetConsensusReqReaderPlan.java (95%)
rename
consensus/src/test/java/org/apache/iotdb/consensus/{multileader/MultiLeaderConsensusTest.java
=> iot/IoTConsensusTest.java} (94%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{multileader =>
iot}/RecoveryTest.java (92%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{multileader =>
iot}/logdispatcher/IndexControllerTest.java (98%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{multileader =>
iot}/logdispatcher/SyncStatusTest.java (92%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{multileader =>
iot}/util/FakeConsensusReqReader.java (95%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{multileader =>
iot}/util/RequestSets.java (96%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{multileader =>
iot}/util/TestEntry.java (91%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{multileader =>
iot}/util/TestStateMachine.java (95%)
create mode 100644
docs/UserGuide/Maintenance-Tools/IoTDB-Data-Dir-Overview-Tool.md
rename docs/UserGuide/{Write-Data/Load-External-Tsfile.md =>
Maintenance-Tools/Load-Tsfile.md} (66%)
delete mode 100644 docs/UserGuide/Maintenance-Tools/Rewrite-TsFile-Tool.md
create mode 100644
docs/UserGuide/Maintenance-Tools/TsFile-Resource-Sketch-Tool.md
create mode 100644 docs/UserGuide/Maintenance-Tools/TsFile-Sketch-Tool.md
create mode 100644 docs/UserGuide/Operators-Functions/Aggregation.md
rename docs/UserGuide/{UDF-Library =>
Operators-Functions}/Anomaly-Detection.md (100%)
create mode 100644 docs/UserGuide/Operators-Functions/Comparison.md
create mode 100644 docs/UserGuide/Operators-Functions/Constant.md
create mode 100644 docs/UserGuide/Operators-Functions/Continuous-Interval.md
create mode 100644 docs/UserGuide/Operators-Functions/Conversion.md
rename docs/UserGuide/{UDF-Library => Operators-Functions}/Data-Matching.md
(100%)
rename docs/UserGuide/{UDF-Library => Operators-Functions}/Data-Profiling.md
(100%)
rename docs/UserGuide/{UDF-Library => Operators-Functions}/Data-Quality.md
(100%)
rename docs/UserGuide/{UDF-Library => Operators-Functions}/Data-Repairing.md
(100%)
rename docs/UserGuide/{UDF-Library => Operators-Functions}/Frequency-Domain.md
(100%)
create mode 100644 docs/UserGuide/Operators-Functions/Lambda.md
create mode 100644 docs/UserGuide/Operators-Functions/Logical.md
create mode 100644 docs/UserGuide/Operators-Functions/Mathematical.md
rename docs/UserGuide/{UDF-Library/Quick-Start.md =>
Operators-Functions/Overview.md} (63%)
create mode 100644 docs/UserGuide/Operators-Functions/Sample.md
create mode 100644 docs/UserGuide/Operators-Functions/Selection.md
rename docs/UserGuide/{UDF-Library => Operators-Functions}/Series-Discovery.md
(100%)
rename docs/UserGuide/{UDF-Library/String-Processing.md =>
Operators-Functions/String.md} (92%)
rename docs/UserGuide/{UDF-Library/Series-Processing.md =>
Operators-Functions/Time-Series.md} (99%)
rename docs/UserGuide/{Process-Data/UDF-User-Defined-Function.md =>
Operators-Functions/User-Defined-Function.md} (99%)
create mode 100644 docs/UserGuide/Operators-Functions/Variation-Trend.md
rename docs/UserGuide/Query-Data/{Result-Format.md => Align-By.md} (98%)
rename docs/UserGuide/{Process-Data => Query-Data}/Continuous-Query.md (100%)
rename docs/UserGuide/Query-Data/{Fill-Null-Value.md => Fill.md} (100%)
rename docs/UserGuide/Query-Data/{Aggregate-Query.md => Group-By.md} (82%)
create mode 100644 docs/UserGuide/Query-Data/Having-Condition.md
copy docs/UserGuide/{UDF-Library/M4.md => Query-Data/Order-By.md} (84%)
delete mode 100644 docs/UserGuide/Query-Data/Performance-Tracing-Tool.md
rename docs/UserGuide/{Process-Data => Query-Data}/Select-Into.md (100%)
rename docs/UserGuide/Query-Data/{Query-Filter.md => Where-Condition.md} (100%)
create mode 100644 docs/UserGuide/Reference/Common-Config-Manual.md
copy docs/UserGuide/{UDF-Library/M4.md => Trigger/Configuration-Parameters.md}
(61%)
rename docs/UserGuide/{Process-Data/Triggers.md =>
Trigger/Implement-Trigger.md} (51%)
create mode 100644 docs/UserGuide/Trigger/Instructions.md
create mode 100644 docs/UserGuide/Trigger/Notes.md
create mode 100644 docs/UserGuide/Trigger/Trigger-Management.md
create mode 100644
docs/zh/UserGuide/Maintenance-Tools/IoTDB-Data-Dir-Overview-Tool.md
rename docs/zh/UserGuide/{Write-Data/Load-External-Tsfile.md =>
Maintenance-Tools/Load-Tsfile.md} (68%)
delete mode 100644 docs/zh/UserGuide/Maintenance-Tools/Rewrite-TsFile-Tool.md
create mode 100644
docs/zh/UserGuide/Maintenance-Tools/TsFile-Resource-Sketch-Tool.md
create mode 100644 docs/zh/UserGuide/Maintenance-Tools/TsFile-Sketch-Tool.md
create mode 100644 docs/zh/UserGuide/Reference/Common-Config-Manual.md
rename docs/{UserGuide/UDF-Library/M4.md =>
zh/UserGuide/Trigger/Configuration-Parameters.md} (64%)
rename docs/zh/UserGuide/Trigger/{Trigger.md => Implement-Trigger.md} (51%)
create mode 100644 docs/zh/UserGuide/Trigger/Instructions.md
create mode 100644 docs/zh/UserGuide/Trigger/Notes.md
create mode 100644 docs/zh/UserGuide/Trigger/Trigger-Management.md
rename grafana-metrics-example/cluster/{Apache IoTDB ConfigNode Dashboard
v0.14.0.json => Apache IoTDB ConfigNode Dashboard.json} (64%)
rename grafana-metrics-example/cluster/{Apache IoTDB DataNode Dashboard
v0.14.0.json => Apache IoTDB DataNode Dashboard.json} (66%)
delete mode 100644 grafana-metrics-example/standalone/Apache IoTDB Dashboard
v0.14.0.json
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBPartitionDurableIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBPartitionDurableTest.java
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/{IoTDBPartitionInheritPolicyTest.java
=> IoTDBPartitionInheritPolicyIT.java} (86%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBRegionGroupExtensionIT.java
delete mode 100644
metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter/DropwizardIoTDBReporter.java
delete mode 100644
metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter/DropwizardMetricType.java
delete mode 100644
metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter/DropwizardMetricsExporter.java
delete mode 100644
metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter/DropwizardPrometheusReporter.java
delete mode 100644
metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter/IoTDBReporter.java
rename
metrics/dropwizard-metrics/src/main/resources/META-INF/services/{org.apache.iotdb.metrics.reporter.Reporter
=> org.apache.iotdb.metrics.reporter.JmxReporter} (85%)
rename metrics/interface/src/main/java/org/apache/iotdb/metrics/{reporter =>
}/CompositeReporter.java (97%)
delete mode 100644
metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/InternalReporter.java
copy
metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/{Reporter.java
=> JmxReporter.java} (77%)
create mode 100644
metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/iotdb/InternalIoTDBReporter.java
create mode 100644
metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/iotdb/IoTDBReporter.java
rename
metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/{MemoryInternalReporter.java
=> iotdb/MemoryInternalIoTDBReporter.java} (64%)
create mode 100644
metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/iotdb/SessionIoTDBReporter.java
create mode 100644
metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/prometheus/PrometheusReporter.java
rename
metrics/{dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter
=>
interface/src/main/java/org/apache/iotdb/metrics/reporter/prometheus}/PrometheusTextWriter.java
(72%)
delete mode 100644
metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/reporter/IoTDBMeterRegistry.java
delete mode 100644
metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/reporter/IoTDBRegistryConfig.java
delete mode 100644
metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/reporter/MicrometerIoTDBReporter.java
delete mode 100644
metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/reporter/MicrometerPrometheusReporter.java
rename
metrics/micrometer-metrics/src/main/resources/META-INF/services/{org.apache.iotdb.metrics.reporter.Reporter
=> org.apache.iotdb.metrics.reporter.JmxReporter} (85%)
create mode 100644
node-commons/src/assembly/resources/sbin/start-standalone.bat
copy confignode/src/test/resources/confignode3conf/iotdb-confignode.properties
=> node-commons/src/assembly/resources/sbin/start-standalone.sh (54%)
create mode 100644 node-commons/src/assembly/resources/sbin/stop-standalone.bat
copy confignode/src/test/resources/confignode3conf/iotdb-confignode.properties
=> node-commons/src/assembly/resources/sbin/stop-standalone.sh (61%)
rename {server/src/main/java/org/apache/iotdb/db/exception =>
node-commons/src/main/java/org/apache/iotdb/commons/exception/sync}/SyncConnectionException.java
(96%)
copy
metrics/interface/src/main/java/org/apache/iotdb/metrics/type/AutoGauge.java =>
node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/SyncHandshakeException.java
(80%)
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/sync/transport/SyncIdentityInfo.java
delete mode 100644 server/src/assembly/resources/sbin/start-new-server.bat
delete mode 100644 server/src/assembly/resources/sbin/start-new-server.sh
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/task/FastCompactionPerformerSubTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/AlignedSeriesCompactionExecutor.java
copy
integration/src/test/java/org/apache/iotdb/db/integration/sync/MockSyncClient.java
=>
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/ChunkMetadataElement.java
(50%)
copy
metrics/interface/src/main/java/org/apache/iotdb/metrics/type/AutoGauge.java =>
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/FileElement.java
(72%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/NonAlignedSeriesCompactionExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/PageElement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/PointElement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/SeriesCompactionExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/performer/impl/FastCompactionPerformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/reader/PointPriorityReader.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/task/SubCompactionTaskSummary.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/AbstractCrossCompactionWriter.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/AbstractInnerCompactionWriter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/CrossSpaceCompactionWriter.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/FastCrossCompactionWriter.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/FastInnerCompactionWriter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/InnerSpaceCompactionWriter.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/ReadPointCrossCompactionWriter.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/ReadPointInnerCompactionWriter.java
rename server/src/main/java/org/apache/iotdb/db/sync/{receiver =>
pipedata}/load/DeletionLoader.java (98%)
rename server/src/main/java/org/apache/iotdb/db/sync/{receiver =>
pipedata}/load/ILoader.java (97%)
rename server/src/main/java/org/apache/iotdb/db/sync/{receiver =>
pipedata}/load/TsFileLoader.java (98%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/FastAlignedCrossCompactionTest.java
copy
server/src/test/java/org/apache/iotdb/db/engine/compaction/{ReadPointCompactionPerformerTest.java
=> FastCrossCompactionPerformerTest.java} (62%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/FastInnerCompactionPerformerTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/FastNonAlignedCrossCompactionTest.java
copy
server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/{ReadChunkCompactionPerformerAlignedTest.java
=> FastCompactionPerformerAlignedTest.java} (92%)
copy
server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/{ReadChunkCompactionPerformerNoAlignedTest.java
=> FastCompactionPerformerNoAlignedTest.java} (94%)
copy
server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/{InnerSeqCompactionTest.java
=> InnerSeqCompactionWithFastPerformerTest.java} (94%)
rename
server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/{InnerSeqCompactionTest.java
=> InnerSeqCompactionWithReadChunkPerformerTest.java} (98%)
copy
server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/{InnerUnseqCompactionTest.java
=> InnerUnseqCompactionWithFastPerformerTest.java} (98%)
rename
server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/{InnerUnseqCompactionTest.java
=> InnerUnseqCompactionWithReadPointPerformerTest.java} (99%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/utils/TsFileGeneratorUtils.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/analyze/QueryTimePartitionTest.java
rename {thrift-multi-leader-consensus => thrift-iot-consensus}/pom.xml (93%)
rename thrift-multi-leader-consensus/src/main/thrift/mutlileader.thrift =>
thrift-iot-consensus/src/main/thrift/iotconsensus.thrift (97%)
