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/27 08:07:56 UTC
[iotdb] 01/02: Merge branch 'master' of https://github.com/apache/iotdb into deploy_site_using_github
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch deploy_site_using_github
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 5bb3e6f050d23aa5e3665c08ca57b759062c41c0
Merge: 860ff82f96 4d7c15ddcd
Author: HTHou <hh...@outlook.com>
AuthorDate: Sun Nov 27 16:02:15 2022 +0800
Merge branch 'master' of https://github.com/apache/iotdb into deploy_site_using_github
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 | 109 +-
.../confignode/conf/ConfigNodeDescriptor.java | 70 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 5 +-
.../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 | 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 | 18 +-
.../node/heartbeat/DataNodeHeartbeatCache.java | 13 +
.../node/heartbeat/NodeHeartbeatSample.java | 21 +-
.../partition/DataRegionGroupExtensionPolicy.java | 47 +-
.../manager/partition/PartitionManager.java | 202 +-
.../persistence/executor/ConfigPlanExecutor.java | 3 +
.../persistence/metric/NodeInfoMetrics.java | 95 -
.../persistence/metric/PartitionInfoMetrics.java | 16 +-
.../persistence/sync/ClusterSyncInfo.java | 9 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 2 +-
.../procedure/env/DataNodeRemoveHandler.java | 27 +-
.../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 +-
...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 | 2 +-
.../wal/GetConsensusReqReaderPlan.java | 2 +-
.../ratis/ApplicationStateMachineProxy.java | 3 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 6 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 31 +-
.../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 | 1942 ++++++
.../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 | 740 ++-
docs/zh/UserGuide/Query-Data/Align-By.md | 2 +-
docs/zh/UserGuide/QuickStart/QuickStart.md | 38 +-
.../zh/UserGuide/Reference/Common-Config-Manual.md | 1986 ++++++
.../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 +-
.../Apache IoTDB DataNode Dashboard v0.14.0.json | 38 +-
.../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 | 30 +-
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 18 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 28 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 10 +
.../it/IoTDBClusterRegionLeaderBalancingIT.java | 56 +-
.../it/IoTDBConfigNodeSwitchLeaderIT.java | 3 +-
.../it/partition/IoTDBPartitionDurableIT.java | 626 ++
.../it/partition/IoTDBPartitionDurableTest.java | 323 -
.../it/partition/IoTDBPartitionGetterIT.java | 37 +-
...est.java => IoTDBPartitionInheritPolicyIT.java} | 28 +-
.../it/partition/IoTDBRegionGroupExtensionIT.java | 136 +
.../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 | 273 +-
.../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 | 168 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 86 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 57 +-
.../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 | 28 +-
.../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 +-
.../exchange/MPPDataExchangeServiceMetrics.java | 2 +-
...MppDataExchangeServiceThriftHandlerMetrics.java | 2 +-
.../execution/executor/RegionWriteExecutor.java | 17 +-
.../apache/iotdb/db/mpp/plan/TestRPCClient.java | 26 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 68 +-
.../memory/StatementMemorySourceVisitor.java | 15 +-
.../plan/planner/distribution/SourceRewriter.java | 2 +-
.../metedata/write/CreateMultiTimeSeriesNode.java | 5 +-
.../plan/planner/plan/node/write/InsertNode.java | 2 +-
.../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 +-
.../java/org/apache/iotdb/db/wal/WALManager.java | 16 +-
.../db/wal/allocation/FirstCreateStrategy.java | 2 +-
.../org/apache/iotdb/db/wal/node/IWALNode.java | 2 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 18 +-
.../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 +-
.../db/mpp/execution/exchange/SinkHandleTest.java | 88 +-
.../mpp/execution/exchange/SourceHandleTest.java | 70 +-
.../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 | 98 +-
.../src/main/thrift/confignode.thrift | 8 +
.../pom.xml | 2 +-
.../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 +-
.../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 +-
429 files changed, 35430 insertions(+), 14505 deletions(-)