This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a change to branch Move-ConfigNodeConfig-into-CommonConfig
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 342f3b8e65 stash
add 2b4732ccd9 [IOTDB-5379] Fix the unit of Prometheus timer metric values
(#8773)
add 4c52365559 [IOTDB-5378] Implement Iterating Query for MTree Node Query
(#8771)
add 228607c5f0 Revert "[IOTDB-5209] Limit the read rate of compaction
execution (#8461)" (#8777)
add a06624782a [IOTDB-5384] add
core_client_count_for_each_node_in_client_manager and
max_client_count_for_each_node_in_client_manager parameters for confignode and
datanode (#8779)
add 48002969a5 update javadoc (#8789)
add cea3c5ce21 [IOTDB-4982] Replace recursion algorithm in Traverser with
iteration algorithm (#8765)
add d55ca83df7 [IoTDB-5374] Implement MLNode basic service framework
(#8772)
add 5f914f014e [IOTDB-3662] upgrade audit log (#8791)
add 362f56cdf5 Change version to 1.1.0-SNAPSHOT (#8796)
add 5de6adf3de [IOTDB-5386] Implement SchemaSource Component to Simplify
Schema Operators (#8792)
add c1dde58682 Jenkins disable integration (#8787)
add c085fb1a8c [IOTDB-4005] Pipeline fragmentInstance to implement
parallel execution
add 27549169a3 [IOTDB-5384] add
core_client_count_for_each_node_in_client_manager and
max_client_count_for_each_node_in_client_manager parameters for confignode and
datanode （#8800）
add a1cc705fdd [IOTDB-5387] Refine IT: Make JVM parameters mutable easily
(#8795)
add 7b1977330a [IOTDB-5328] Rename "REMOVE_DATANODE_PROCESS" in
MIGRATE_REGION_PROCEDURE to "REGION_MIGRATE_PROCESS" (#8790)
add 76d3a13e29 Eliminate LocalSchemaProcessor and stale code (#8802)
add 4dcaf696d5 Eliminate LocalConfigNode and Fix NPE while forceMLog
(#8804)
add dfb013b710 Separate SYNC_CONNECTION_ERROR and DISPATCH_ERROR (#8726)
add 8e40479c42 [IOTDB-5288][IOTDB-5163] Fix the file metrics is wrong
(#8805)
add 5ad3384f0f Change config in SourceHandleTest according to
IoTDBDescriptor
add 44fb69a7ff Fix wal manager test (#8808)
add 5dac205243 [IOTDB-4437] Implement event window in
RawDataAggregationOperator
add 43cd37bdcf [IOTDB-5389] Cause DataNode startup to fail when wal_mode
is disabled in IoTConsensus (#8798)
add 3ddaa39983 [IOTDB-5391] Implement SchemaReader using iterative
Traverser (#8816)
add 4f1409df4d Fix testGetSlots bug (#8819)
new 1611727710 Merge branch 'master' into
Move-ConfigNodeConfig-into-CommonConfig
The 1 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:
Jenkinsfile | 42 +-
antlr/pom.xml | 2 +-
cli/pom.xml | 2 +-
client-cpp/pom.xml | 2 +-
client-py/pom.xml | 2 +-
code-coverage/pom.xml | 2 +-
compile-tools/pom.xml | 2 +-
compile-tools/thrift/pom.xml | 2 +-
confignode/pom.xml | 2 +-
.../resources/conf/iotdb-confignode.properties | 11 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 2 +-
.../iotdb/confignode/conf/ConfigNodeConstant.java | 1 +
.../iotdb/confignode/manager/ConsensusManager.java | 10 +-
.../iotdb/confignode/manager/ProcedureManager.java | 2 +-
.../persistence/schema/ClusterSchemaInfo.java | 14 -
.../procedure/env/DataNodeRemoveHandler.java | 15 +-
.../impl/statemachine/RegionMigrateProcedure.java | 15 +-
consensus/pom.xml | 2 +-
.../iotdb/consensus/config/ConsensusConfig.java | 9 +-
.../iotdb/consensus/config/IoTConsensusConfig.java | 40 +-
.../apache/iotdb/consensus/config/RatisConfig.java | 219 +++++---
.../iot/client/IoTConsensusClientPool.java | 14 +-
.../apache/iotdb/consensus/ratis/RatisClient.java | 10 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 12 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 2 +-
distribution/pom.xml | 2 +-
.../Apache-IoTDB-ConfigNode-Dashboard.json | 2 +-
.../Apache-IoTDB-DataNode-Dashboard.json | 6 +-
docs/UserGuide/Reference/Common-Config-Manual.md | 16 +-
.../Reference/ConfigNode-Config-Manual.md | 18 +
docs/UserGuide/Reference/DataNode-Config-Manual.md | 18 +
docs/UserGuide/Reference/Status-Codes.md | 15 +-
.../zh/UserGuide/Reference/Common-Config-Manual.md | 16 +-
.../Reference/ConfigNode-Config-Manual.md | 20 +-
.../UserGuide/Reference/DataNode-Config-Manual.md | 18 +
docs/zh/UserGuide/Reference/Status-Codes.md | 249 +++++-----
example/client-cpp-example/pom.xml | 2 +-
example/ext-pipe-plugin-example/pom.xml | 4 +-
example/flink/pom.xml | 2 +-
example/hadoop/pom.xml | 2 +-
example/influxdb-protocol-example/pom.xml | 2 +-
example/jdbc/pom.xml | 2 +-
example/kafka/pom.xml | 2 +-
example/mqtt-customize/pom.xml | 2 +-
example/mqtt/pom.xml | 2 +-
example/pom.xml | 2 +-
example/pulsar/pom.xml | 2 +-
example/rabbitmq/pom.xml | 2 +-
example/rest-java-example/pom.xml | 2 +-
example/rocketmq/pom.xml | 2 +-
example/session/pom.xml | 2 +-
example/trigger/pom.xml | 2 +-
example/tsfile/pom.xml | 2 +-
example/udf/pom.xml | 2 +-
external-api/pom.xml | 2 +-
external-pipe-api/pom.xml | 2 +-
flink-iotdb-connector/pom.xml | 2 +-
flink-tsfile-connector/pom.xml | 2 +-
grafana-connector/pom.xml | 2 +-
grafana-plugin/pom.xml | 2 +-
hadoop/pom.xml | 2 +-
hive-connector/pom.xml | 2 +-
influxdb-protocol/pom.xml | 2 +-
integration-test/pom.xml | 5 +-
.../apache/iotdb/it/env/cluster/AbstractEnv.java | 15 +-
.../iotdb/it/env/cluster/AbstractNodeWrapper.java | 36 +-
.../iotdb/it/env/cluster/ConfigNodeWrapper.java | 19 +-
.../iotdb/it/env/cluster/DataNodeWrapper.java | 9 +
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 25 +-
.../iotdb/it/env/cluster/MppClusterConfig.java | 15 +
.../apache/iotdb/it/env/cluster/MppJVMConfig.java | 116 +++++
.../iotdb/it/env/remote/RemoteClusterConfig.java | 12 +
.../iotdb/it/env/remote/RemoteJVMConfig.java | 19 +-
.../org/apache/iotdb/itbase/env/ClusterConfig.java | 30 +-
.../org/apache/iotdb/itbase/env/JVMConfig.java | 53 +-
.../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 6 +-
.../it/cluster/IoTDBClusterRestartIT.java | 3 +-
.../it/partition/IoTDBPartitionGetterIT.java | 94 ++--
integration/pom.xml | 2 +-
.../iotdb/db/integration/IoTDBCheckConfigIT.java | 3 -
isession/pom.xml | 2 +-
jdbc/pom.xml | 2 +-
library-udf/pom.xml | 2 +-
metrics/dropwizard-metrics/pom.xml | 2 +-
.../type/DropwizardHistogramSnapshot.java | 14 +-
metrics/interface/pom.xml | 2 +-
.../metrics/impl/DoNothingHistogramSnapshot.java | 12 +-
.../iotdb/metrics/type/HistogramSnapshot.java | 6 +-
metrics/micrometer-metrics/pom.xml | 4 +-
.../type/MicrometerHistogramSnapshot.java | 14 +-
.../metrics/micrometer/type/MicrometerTimer.java | 2 +-
....java => MicrometerTimerHistogramSnapshot.java} | 30 +-
metrics/pom.xml | 2 +-
mlnode/.flake8 | 33 ++
mlnode/.gitignore | 5 +
external-pipe-api/pom.xml => mlnode/README.md | 42 +-
{client-py => mlnode}/iotdb/__init__.py | 0
.../iotdb => mlnode/iotdb/mlnode}/__init__.py | 0
mlnode/iotdb/mlnode/client.py | 51 ++
mlnode/iotdb/mlnode/config.py | 107 ++++
mlnode/iotdb/mlnode/constant.py | 21 +
mlnode/iotdb/mlnode/exception.py | 26 +
mlnode/iotdb/mlnode/handler.py | 53 ++
mlnode/iotdb/mlnode/log.py | 34 ++
mlnode/iotdb/mlnode/script.py | 36 ++
mlnode/iotdb/mlnode/service.py | 60 +++
mlnode/iotdb/mlnode/util.py | 48 ++
mlnode/pom.xml | 2 +-
mlnode/pyproject.toml | 54 ++
mlnode/resources/conf/iotdb-mlnode.toml | 50 ++
mlnode/resources/conf/logging_config.ini | 40 ++
node-commons/pom.xml | 2 +-
.../resources/conf/iotdb-common.properties | 4 +-
.../apache/iotdb/commons/client/ClientManager.java | 7 +-
.../iotdb/commons/client/ClientPoolFactory.java | 30 +-
.../iotdb/commons/client/IClientManager.java | 8 +-
.../client/property/ClientPoolProperty.java | 34 +-
.../iotdb/commons/concurrent/ThreadName.java | 4 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 1 +
.../commons/schema/tree/AbstractTreeVisitor.java | 92 +++-
.../iotdb/commons/schema/tree/ITreeNode.java | 4 +-
.../apache/iotdb/commons/utils/StatusUtils.java | 4 +-
.../iotdb/commons/client/ClientManagerTest.java | 10 +-
openapi/pom.xml | 2 +-
pom.xml | 3 +-
rewrite-tsfile-tool/pom.xml | 2 +-
schema-engine-rocksdb/pom.xml | 2 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 126 +----
.../schemaregion/rocksdb/mnode/RMNode.java | 5 +
schema-engine-tag/pom.xml | 2 +-
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 70 +--
server/pom.xml | 2 +-
.../resources/conf/iotdb-datanode.properties | 16 +-
.../apache/iotdb/db/audit/AuditLogOperation.java | 14 +-
.../org/apache/iotdb/db/audit/AuditLogStorage.java | 12 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 236 +++++++++
.../iotdb/db/client/DataNodeClientPoolFactory.java | 10 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 98 +++-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 23 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 6 +
.../db/consensus/DataRegionConsensusImpl.java | 28 +-
.../db/consensus/SchemaRegionConsensusImpl.java | 28 +-
.../execute/task/CrossSpaceCompactionTask.java | 27 +-
.../execute/task/InnerSpaceCompactionTask.java | 29 +-
.../fast/AlignedSeriesCompactionExecutor.java | 8 -
.../fast/NonAlignedSeriesCompactionExecutor.java | 2 -
.../readchunk/AlignedSeriesCompactionExecutor.java | 9 +-
.../readchunk/SingleSeriesCompactionExecutor.java | 11 +-
.../utils/writer/AbstractCompactionWriter.java | 12 +-
.../compaction/schedule/CompactionTaskManager.java | 15 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 294 -----------
.../db/localconfignode/LocalDataPartitionInfo.java | 111 -----
.../localconfignode/LocalDataPartitionTable.java | 127 -----
.../localconfignode/LocalSchemaPartitionTable.java | 122 -----
.../iotdb/db/metadata/LocalSchemaProcessor.java | 250 ----------
.../idtable/entry/InsertMeasurementMNode.java | 5 +
.../db/metadata/mnode/AboveDatabaseMNode.java | 20 +-
.../org/apache/iotdb/db/metadata/mnode/IMNode.java | 7 +-
.../iotdb/db/metadata/mnode/InternalMNode.java | 5 +
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 5 +
.../mnode/iterator/AbstractTraverserIterator.java | 115 +++++
.../iterator/CachedTraverserIterator.java} | 27 +-
.../iterator/MemoryTraverserIterator.java} | 22 +-
.../iotdb/db/metadata/mtree/ConfigMTree.java | 250 ++++------
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 68 +--
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 483 +++++++++---------
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 492 ++++++++++--------
.../db/metadata/mtree/store/CachedMTreeStore.java | 18 +
.../iotdb/db/metadata/mtree/store/IMTreeStore.java | 6 +
.../db/metadata/mtree/store/MemMTreeStore.java | 19 +
.../db/metadata/mtree/traverser/Traverser.java | 452 ++---------------
.../traverser/TraverserWithLimitOffsetWrapper.java | 122 +++++
.../DatabaseTraverser.java} | 49 +-
.../EntityTraverser.java} | 60 ++-
.../mtree/traverser/basic/MNodeTraverser.java | 103 ++++
.../MeasurementTraverser.java} | 41 +-
.../traverser/collector/CollectorTraverser.java | 96 ----
...eGroupCollector.java => DatabaseCollector.java} | 38 +-
.../mtree/traverser/collector/EntityCollector.java | 48 +-
.../traverser/collector/MNodeAboveSGCollector.java | 25 +-
.../mtree/traverser/collector/MNodeCollector.java | 58 +--
.../traverser/collector/MeasurementCollector.java | 58 +--
.../metadata/mtree/traverser/counter/Counter.java | 8 +-
...orageGroupCounter.java => DatabaseCounter.java} | 31 +-
...StorageGroupCounter.java => EntityCounter.java} | 29 +-
.../mtree/traverser/updater/EntityUpdater.java | 65 +++
.../traverser/updater/MeasurementUpdater.java | 66 +++
.../metadata/mtree/traverser/updater/Updater.java | 11 +-
.../impl/read/SchemaRegionReadPlanFactory.java | 10 +
.../schemaregion/impl/read/ShowNodesPlanImpl.java | 20 +-
.../plan/schemaregion/read/IShowNodesPlan.java | 7 +-
.../plan/schemaregion/result/ShowNodesResult.java | 42 +-
.../schemaregion/result/ShowTimeSeriesResult.java | 10 +-
.../db/metadata/query/info/INodeSchemaInfo.java | 8 +-
.../metadata/query/info/ITimeSeriesSchemaInfo.java | 5 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 99 +---
.../db/metadata/schemaregion/SchemaEngine.java | 3 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 242 ++++-----
.../schemaregion/SchemaRegionSchemaFileImpl.java | 195 +++-----
.../storagegroup/IStorageGroupSchemaManager.java | 53 --
.../storagegroup/StorageGroupSchemaManager.java | 78 ---
.../apache/iotdb/db/metadata/tag/TagManager.java | 3 +-
.../iotdb/db/mpp/aggregation/AvgAccumulator.java | 8 +-
.../iotdb/db/mpp/aggregation/CountAccumulator.java | 4 +-
.../db/mpp/aggregation/ExtremeAccumulator.java | 8 +-
.../db/mpp/aggregation/FirstValueAccumulator.java | 12 +-
.../mpp/aggregation/FirstValueDescAccumulator.java | 12 +-
.../db/mpp/aggregation/LastValueAccumulator.java | 12 +-
.../mpp/aggregation/LastValueDescAccumulator.java | 12 +-
.../db/mpp/aggregation/MaxTimeAccumulator.java | 2 +-
.../db/mpp/aggregation/MaxTimeDescAccumulator.java | 2 +-
.../db/mpp/aggregation/MaxValueAccumulator.java | 8 +-
.../db/mpp/aggregation/MinTimeAccumulator.java | 2 +-
.../db/mpp/aggregation/MinTimeDescAccumulator.java | 2 +-
.../db/mpp/aggregation/MinValueAccumulator.java | 8 +-
.../iotdb/db/mpp/aggregation/SumAccumulator.java | 8 +-
.../visitor/SchemaTreeDeviceVisitor.java | 2 +-
.../visitor/SchemaTreeMeasurementVisitor.java | 3 +-
.../iotdb/db/mpp/execution/StateMachine.java | 4 +-
.../iotdb/db/mpp/execution/driver/DataDriver.java | 37 +-
.../db/mpp/execution/driver/DataDriverContext.java | 48 +-
.../iotdb/db/mpp/execution/driver/Driver.java | 34 +-
.../db/mpp/execution/driver/DriverContext.java | 76 ++-
.../iotdb/db/mpp/execution/driver/IDriver.java | 5 +-
.../db/mpp/execution/driver/SchemaDriver.java | 5 +-
.../mpp/execution/driver/SchemaDriverContext.java | 13 +-
.../exchange/IMPPDataExchangeManager.java | 4 +-
.../db/mpp/execution/exchange/LocalSinkHandle.java | 25 +-
.../mpp/execution/exchange/LocalSourceHandle.java | 27 +-
.../execution/exchange/MPPDataExchangeManager.java | 113 ++++-
.../mpp/execution/exchange/SharedTsBlockQueue.java | 5 +
.../db/mpp/execution/exchange/SinkHandle.java | 2 +-
.../db/mpp/execution/exchange/SourceHandle.java | 2 +-
.../fragment/FragmentInstanceContext.java | 127 +++--
.../fragment/FragmentInstanceExecution.java | 25 +-
.../fragment/FragmentInstanceManager.java | 37 +-
.../db/mpp/execution/operator/OperatorContext.java | 32 +-
.../operator/factory/OperatorFactory.java} | 26 +-
.../operator/factory/SourceOperatorFactory.java | 41 +-
.../process/RawDataAggregationOperator.java | 51 +-
.../process/SingleInputAggregationOperator.java | 12 +-
.../process/SlidingWindowAggregationOperator.java | 11 +
.../operator/process/join/TimeJoinOperator.java | 1 -
.../last/AbstractUpdateLastCacheOperator.java | 2 +-
.../schema/CountGroupByLevelMergeOperator.java | 7 +
...tor.java => CountGroupByLevelScanOperator.java} | 76 +--
.../operator/schema/CountMergeOperator.java | 7 +
.../operator/schema/DevicesCountOperator.java | 65 ---
.../schema/NodePathsSchemaScanOperator.java | 147 ------
.../operator/schema/SchemaCountOperator.java | 33 +-
.../operator/schema/SchemaQueryScanOperator.java | 39 +-
.../operator/schema/TimeSeriesCountOperator.java | 85 ----
.../DeviceSchemaSource.java} | 66 +--
.../operator/schema/source/ISchemaSource.java | 50 ++
.../operator/schema/source/NodeSchemaSource.java | 81 +++
.../PathsUsingTemplateSource.java} | 55 +--
.../schema/source/SchemaSourceFactory.java | 78 +++
.../TimeSeriesSchemaSource.java} | 81 ++-
.../operator/source/AlignedSeriesScanUtil.java | 3 +-
.../operator/source/ExchangeOperator.java | 4 +
.../operator/source/SeriesScanOperator.java | 76 ++-
.../execution/operator/source/SeriesScanUtil.java | 6 +-
.../operator/window/EqualEventBooleanWindow.java} | 25 +-
.../window/EqualEventBooleanWindowManager.java | 64 +++
.../operator/window/EqualEventDoubleWindow.java} | 25 +-
.../window/EqualEventDoubleWindowManager.java | 64 +++
.../operator/window/EqualEventFloatWindow.java} | 25 +-
.../window/EqualEventFloatWindowManager.java | 64 +++
.../operator/window/EqualEventIntWindow.java} | 25 +-
.../window/EqualEventIntWindowManager.java | 63 +++
.../operator/window/EqualEventLongWindow.java} | 25 +-
.../window/EqualEventLongWindowManager.java | 63 +++
.../operator/window/EqualEventTextWindow.java} | 25 +-
.../window/EqualEventTextWindowManager.java | 64 +++
.../operator/window/EventBooleanWindow.java | 66 +++
.../operator/window/EventBooleanWindowManager.java | 46 ++
.../operator/window/EventDoubleWindow.java | 66 +++
.../operator/window/EventDoubleWindowManager.java | 46 ++
.../operator/window/EventFloatWindow.java | 66 +++
.../operator/window/EventFloatWindowManager.java | 46 ++
.../execution/operator/window/EventIntWindow.java | 66 +++
.../operator/window/EventIntWindowManager.java | 46 ++
.../execution/operator/window/EventLongWindow.java | 66 +++
.../operator/window/EventLongWindowManager.java | 46 ++
.../execution/operator/window/EventTextWindow.java | 67 +++
.../operator/window/EventTextWindowManager.java | 46 ++
.../window/{TimeWindow.java => EventWindow.java} | 61 +--
.../operator/window/EventWindowManager.java | 138 ++++++
.../operator/window/EventWindowParameter.java | 61 +++
.../db/mpp/execution/operator/window/IWindow.java | 2 +-
.../execution/operator/window/IWindowManager.java | 68 ++-
.../mpp/execution/operator/window/TimeWindow.java | 2 +-
.../operator/window/TimeWindowManager.java | 73 ++-
.../operator/window/TimeWindowParameter.java | 11 +-
.../window/VariationEventDoubleWindow.java} | 25 +-
.../window/VariationEventDoubleWindowManager.java | 66 +++
.../window/VariationEventFloatWindow.java} | 25 +-
.../window/VariationEventFloatWindowManager.java | 66 +++
.../operator/window/VariationEventIntWindow.java} | 25 +-
.../window/VariationEventIntWindowManager.java | 66 +++
.../operator/window/VariationEventLongWindow.java} | 25 +-
.../window/VariationEventLongWindowManager.java | 66 +++
.../operator/window/WindowManagerFactory.java | 84 ++++
.../operator/window/WindowParameter.java} | 23 +-
.../mpp/execution/operator/window/WindowType.java | 19 +-
.../execution/schedule/AbstractDriverThread.java | 9 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 143 +++---
...eption.java => DriverTaskAbortedException.java} | 8 +-
.../mpp/execution/schedule/DriverTaskThread.java | 12 +-
.../schedule/DriverTaskTimeoutSentinelThread.java | 2 +-
.../mpp/execution/schedule/IDriverScheduler.java | 7 +-
.../schedule/queue/IDIndexedAccessible.java | 2 +-
.../schedule/queue/IndexedBlockingQueue.java | 3 +-
.../execution/schedule/queue/L1PriorityQueue.java | 10 +-
.../execution/schedule/queue/L2PriorityQueue.java | 16 +-
.../db/mpp/execution/schedule/task/DriverTask.java | 44 +-
.../task/{DriverTaskID.java => DriverTaskId.java} | 49 +-
.../db/mpp/plan/execution/QueryExecution.java | 2 +-
.../config/executor/ClusterConfigTaskExecutor.java | 81 ++-
.../plan/planner/LocalExecutionPlanContext.java | 175 ++++---
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 100 ++--
.../plan/planner/MemoryDistributionCalculator.java | 472 ------------------
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 383 ++++++++------
.../db/mpp/plan/planner/PipelineDriverFactory.java | 59 +++
.../db/mpp/plan/scheduler/ClusterScheduler.java | 2 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 2 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 4 +-
.../iotdb/db/query/control/SessionManager.java | 45 +-
.../query/control/clientsession/ClientSession.java | 2 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 4 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 117 ++++-
.../iotdb/db/engine/MetadataManagerHelper.java | 158 ------
.../compaction/TestUtilsForAlignedSeries.java | 42 +-
.../db/engine/compaction/cross/MergeTest.java | 19 -
.../inner/AbstractInnerSpaceCompactionTest.java | 19 -
.../inner/FastCompactionPerformerAlignedTest.java | 3 -
...nerSeqCompactionWithReadChunkPerformerTest.java | 17 -
...rUnseqCompactionWithReadPointPerformerTest.java | 19 -
.../ReadChunkCompactionPerformerAlignedTest.java | 3 -
.../inner/sizetiered/SizeTieredCompactionTest.java | 19 -
.../recover/SizeTieredCompactionRecoverTest.java | 16 -
.../compaction/utils/CompactionConfigRestorer.java | 2 +-
.../db/engine/memtable/MemTableFlushTaskTest.java | 2 -
.../iotdb/db/metadata/mtree/ConfigMTreeTest.java | 31 --
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 69 ---
.../schemaRegion/SchemaRegionAliasAndTagTest.java | 32 +-
.../schemaRegion/SchemaRegionBasicTest.java | 105 ++--
.../schemaRegion/SchemaRegionManagementTest.java | 43 +-
.../schemaRegion/SchemaRegionTemplateTest.java | 64 +++
.../schemaRegion/SchemaRegionTestUtil.java | 67 ++-
.../apache/iotdb/db/metric/MetricServiceTest.java | 4 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 52 +-
.../execution/exchange/LocalSinkHandleTest.java | 26 +-
.../execution/exchange/LocalSourceHandleTest.java | 12 +-
.../exchange/MPPDataExchangeManagerTest.java | 8 +-
.../mpp/execution/exchange/SourceHandleTest.java | 82 +--
.../operator/AggregationOperatorTest.java | 17 +-
.../AlignedSeriesAggregationScanOperatorTest.java | 9 +-
.../operator/AlignedSeriesScanOperatorTest.java | 92 ++--
.../execution/operator/AlignedSeriesTestUtil.java | 53 --
.../operator/DeviceMergeOperatorTest.java | 77 ++-
.../execution/operator/DeviceViewOperatorTest.java | 16 +-
.../mpp/execution/operator/FillOperatorTest.java | 17 +-
.../operator/LastQueryMergeOperatorTest.java | 25 +-
.../execution/operator/LastQueryOperatorTest.java | 49 +-
.../operator/LastQuerySortOperatorTest.java | 49 +-
.../mpp/execution/operator/LimitOperatorTest.java | 22 +-
.../execution/operator/LinearFillOperatorTest.java | 57 +--
.../execution/operator/MergeSortOperatorTest.java | 205 ++++----
.../mpp/execution/operator/OffsetOperatorTest.java | 73 ++-
.../mpp/execution/operator/OperatorMemoryTest.java | 232 ++-------
.../operator/RawDataAggregationOperatorTest.java | 549 ++++++++++++++++++++-
.../SeriesAggregationScanOperatorTest.java | 8 +-
.../execution/operator/SeriesScanOperatorTest.java | 8 +-
.../operator/SingleDeviceViewOperatorTest.java | 20 +-
.../SlidingWindowAggregationOperatorTest.java | 12 +-
.../execution/operator/TimeJoinOperatorTest.java | 56 +--
.../operator/UpdateLastCacheOperatorTest.java | 13 +-
.../operator/VerticallyConcatOperatorTest.java | 14 +-
.../schema/CountGroupByLevelMergeOperatorTest.java | 76 ++-
.../operator/schema/SchemaCountOperatorTest.java | 223 ++-------
.../schema/SchemaQueryScanOperatorTest.java | 79 ++-
.../schedule/DefaultDriverSchedulerTest.java | 166 ++++---
.../execution/schedule/DriverSchedulerTest.java | 45 +-
.../DriverTaskTimeoutSentinelThreadTest.java | 23 +-
.../schedule/queue/L1PriorityQueueTest.java | 6 +-
.../schedule/queue/L2PriorityQueueTest.java | 12 +-
.../mpp/execution/schedule/queue/QueueElement.java | 4 +-
.../query/reader/series/SeriesReaderTestUtil.java | 18 +
.../iotdb/db/rescon/ResourceManagerTest.java | 19 -
.../DataNodeInternalRPCServiceImplTest.java | 11 +-
.../db/sync/datasource/PipeOpManagerTest.java | 3 -
.../apache/iotdb/db/utils/EnvironmentUtils.java | 14 +-
.../org/apache/iotdb/db/utils/SchemaTestUtils.java | 22 +-
.../db/wal/recover/WALRecoverManagerTest.java | 32 --
.../db/wal/recover/file/TsFilePlanRedoerTest.java | 53 --
.../file/UnsealedTsFileRecoverPerformerTest.java | 31 --
service-rpc/pom.xml | 2 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
session/pom.xml | 2 +-
site/pom.xml | 2 +-
spark-iotdb-connector/pom.xml | 2 +-
.../apache/iotdb/spark/db/EnvironmentUtils.java | 3 -
spark-tsfile/pom.xml | 2 +-
testcontainer/pom.xml | 2 +-
thrift-commons/pom.xml | 2 +-
thrift-confignode/pom.xml | 2 +-
thrift-influxdb/pom.xml | 2 +-
thrift-iot-consensus/pom.xml | 2 +-
thrift-mlnode/pom.xml | 2 +-
thrift-mlnode/src/main/thrift/mlnode.thrift | 10 +-
thrift/pom.xml | 2 +-
trigger-api/pom.xml | 2 +-
tsfile/pom.xml | 2 +-
udf-api/pom.xml | 2 +-
zeppelin-interpreter/pom.xml | 2 +-
416 files changed, 9336 insertions(+), 7496 deletions(-)
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/MppJVMConfig.java
copy
node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java
=>
integration-test/src/main/java/org/apache/iotdb/it/env/remote/RemoteJVMConfig.java
(67%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/client/IClientManager.java
=> integration-test/src/main/java/org/apache/iotdb/itbase/env/JVMConfig.java
(50%)
copy
metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/type/{MicrometerHistogramSnapshot.java
=> MicrometerTimerHistogramSnapshot.java} (73%)
create mode 100644 mlnode/.flake8
copy external-pipe-api/pom.xml => mlnode/README.md (54%)
copy {client-py => mlnode}/iotdb/__init__.py (100%)
copy {client-py/iotdb => mlnode/iotdb/mlnode}/__init__.py (100%)
create mode 100644 mlnode/iotdb/mlnode/client.py
create mode 100644 mlnode/iotdb/mlnode/config.py
create mode 100644 mlnode/iotdb/mlnode/constant.py
create mode 100644 mlnode/iotdb/mlnode/exception.py
create mode 100644 mlnode/iotdb/mlnode/handler.py
create mode 100644 mlnode/iotdb/mlnode/log.py
create mode 100644 mlnode/iotdb/mlnode/script.py
create mode 100644 mlnode/iotdb/mlnode/service.py
create mode 100644 mlnode/iotdb/mlnode/util.py
create mode 100644 mlnode/pyproject.toml
create mode 100644 mlnode/resources/conf/iotdb-mlnode.toml
create mode 100644 mlnode/resources/conf/logging_config.ini
copy
node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java
=> server/src/main/java/org/apache/iotdb/db/audit/AuditLogOperation.java (83%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java
=> server/src/main/java/org/apache/iotdb/db/audit/AuditLogStorage.java (84%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/audit/AuditLogger.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/localconfignode/LocalConfigNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/localconfignode/LocalDataPartitionInfo.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/localconfignode/LocalDataPartitionTable.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/localconfignode/LocalSchemaPartitionTable.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/LocalSchemaProcessor.java
copy
node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/mnode/AboveDatabaseMNode.java
(66%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/iterator/AbstractTraverserIterator.java
copy
server/src/main/java/org/apache/iotdb/db/metadata/{mtree/traverser/counter/CounterTraverser.java
=> mnode/iterator/CachedTraverserIterator.java} (60%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/{mtree/traverser/counter/CounterTraverser.java
=> mnode/iterator/MemoryTraverserIterator.java} (64%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/TraverserWithLimitOffsetWrapper.java
copy
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/{collector/StorageGroupCollector.java
=> basic/DatabaseTraverser.java} (53%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/{collector/EntityCollector.java
=> basic/EntityTraverser.java} (53%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/basic/MNodeTraverser.java
rename
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/{counter/CounterTraverser.java
=> basic/MeasurementTraverser.java} (52%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/collector/CollectorTraverser.java
rename
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/collector/{StorageGroupCollector.java
=> DatabaseCollector.java} (58%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/counter/Counter.java
(80%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/counter/{StorageGroupCounter.java
=> DatabaseCounter.java} (62%)
rename
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/counter/{StorageGroupCounter.java
=> EntityCounter.java} (63%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/updater/EntityUpdater.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/updater/MeasurementUpdater.java
copy
node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/updater/Updater.java
(61%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/read/ShowNodesPlanImpl.java
(60%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/read/IShowNodesPlan.java
(85%)
copy
metrics/interface/src/main/java/org/apache/iotdb/metrics/impl/DoNothingHistogramSnapshot.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/result/ShowNodesResult.java
(53%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/query/info/INodeSchemaInfo.java
(81%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/storagegroup/IStorageGroupSchemaManager.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/storagegroup/StorageGroupSchemaManager.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/factory/OperatorFactory.java} (58%)
copy
metrics/interface/src/main/java/org/apache/iotdb/metrics/impl/DoNothingHistogramSnapshot.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/factory/SourceOperatorFactory.java
(59%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{LevelTimeSeriesCountOperator.java
=> CountGroupByLevelScanOperator.java} (63%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/DevicesCountOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/NodePathsSchemaScanOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/TimeSeriesCountOperator.java
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{DevicesSchemaScanOperator.java
=> source/DeviceSchemaSource.java} (57%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/source/ISchemaSource.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/source/NodeSchemaSource.java
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{PathsUsingTemplateScanOperator.java
=> source/PathsUsingTemplateSource.java} (65%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/source/SchemaSourceFactory.java
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{TimeSeriesSchemaScanOperator.java
=> source/TimeSeriesSchemaSource.java} (64%)
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/window/EqualEventBooleanWindow.java} (62%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EqualEventBooleanWindowManager.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/window/EqualEventDoubleWindow.java} (63%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EqualEventDoubleWindowManager.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/window/EqualEventFloatWindow.java} (63%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EqualEventFloatWindowManager.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/window/EqualEventIntWindow.java} (63%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EqualEventIntWindowManager.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/window/EqualEventLongWindow.java} (63%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EqualEventLongWindowManager.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/window/EqualEventTextWindow.java} (63%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EqualEventTextWindowManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventBooleanWindow.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventBooleanWindowManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventDoubleWindow.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventDoubleWindowManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventFloatWindow.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventFloatWindowManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventIntWindow.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventIntWindowManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventLongWindow.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventLongWindowManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventTextWindow.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventTextWindowManager.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/{TimeWindow.java
=> EventWindow.java} (54%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventWindowManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventWindowParameter.java
copy
node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/TimeWindowParameter.java
(71%)
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/window/VariationEventDoubleWindow.java} (60%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/VariationEventDoubleWindowManager.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/window/VariationEventFloatWindow.java} (60%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/VariationEventFloatWindowManager.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/window/VariationEventIntWindow.java} (61%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/VariationEventIntWindowManager.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/window/VariationEventLongWindow.java} (60%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/VariationEventLongWindowManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/WindowManagerFactory.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/window/WindowParameter.java} (65%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/WindowType.java
(70%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/{FragmentInstanceAbortedException.java
=> DriverTaskAbortedException.java} (82%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/task/{DriverTaskID.java
=> DriverTaskId.java} (56%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/MemoryDistributionCalculator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/PipelineDriverFactory.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/engine/MetadataManagerHelper.java
