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/04/09 06:38:27 UTC
[iotdb] branch InsertTabletNode updated (d4c8d1072d -> 262997a1ea)
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch InsertTabletNode
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from d4c8d1072d remove plan
add e2e8a16a90 Modify site/src/main/.vuepress/config.js to add REST API navigation for v0.13 (#5442)
add 34ca54a94d [IOTDB-2859] Fix python tablet with None value is incorrect (#5441)
add 3174c501cd [IOTDB-2727] data block manager impl (#5367)
add 347bd4a580 [IOTDB-2727] add DataBlockService#getInstance (#5446)
add 0c847d4297 Add english community about docs (#5445)
add 519293b078 [IOTDB-2838] Check and auto correct endian type for NumpyTablet (#5448)
add b5e16dfbb9 [IOTDB-2307]UDF Library Series Discovery Functions (#4848)
add c32fc88aad [IOTDB-2308]Library string (#4836)
add b5a028e785 [IOTDB-2302] Library-UDF Data Profiling Functions (#4731)
add e23879045d [IOTDB-2238] Library-UDF Data Quality Functions (#4691)
add becc9c0f65 [IOTDB-2306]Library-UDF Frequency Domain Functions (#4824)
add f5ec5baea9 [IoTDB-2799] Complete the basic implementation of QueryExecution and ClusterScheduler (#5430)
add edad9ddf0d [IOTDB-2862] Fix SQL injection risks of grafana-connector (#5450)
add e2f93a42ee rollback config.js (#5453)
add d5a7cd5215 Merge branch 'master' of https://github.com/apache/iotdb into InsertTabletNode
add 40fd10e634 Remove redundant docs (#5454)
add ef97d29520 Merge branch 'master' of https://github.com/apache/iotdb into InsertTabletNode
add c079557789 dev
add 2e82976def [IOTDB-2303]Library dmatch (#4835)
add bd01ddea00 [IOTDB-2832] Initialize the consensus layer of the Datanode (#5417)
add 9d206f9568 [IOTDB-2857] Move methods in serviceProvider to sessionManager (#5440)
add 19d469775d Construct SinkHandle in LocalExecutionPlanner and remove the IOExecption in next and hasNext method of Operator (#5449)
add f3cc2821ba Update iotdb-doap.rdf (#5456)
add 87c8ab4ac8 [IOTDB-2304]Library-UDF Data Repairing Functions (#4833)
add 69b3920af7 Update iotdb-doap.rdf (#5457)
add dd67c0aacb Update iotdb-doap.rdf (#5458)
add a8f7439db9 [IOTDB-2841] add permission manager model (#5401)
add 931e309ad8 [IOTDB-2803]add AlterTimeSeriesNode and CreateAlignedTimeSeriesNode to PlanNodeType and its serialize and deserialize (#5444)
add 03f876ea19 [IOTDB-2864] Fix Read-only occurred when insert Text values to aligned timeseries (#5460)
add 960a6402fa Merge branch 'master' of https://github.com/apache/iotdb into InsertTabletNode
add 262997a1ea update
No new revisions were added by this update.
Summary of changes:
client-py/README.md | 19 +-
client-py/SessionExample.py | 14 +-
client-py/iotdb/utils/IoTDBConstants.py | 11 +
client-py/iotdb/utils/IoTDBRpcDataSet.py | 2 +-
client-py/iotdb/utils/NumpyTablet.py | 15 +-
client-py/iotdb/utils/Tablet.py | 23 +-
client-py/tests/test_numpy_tablet.py | 147 ++
client-py/tests/test_tablet.py | 109 ++
client-py/tests/test_todf.py | 4 +-
confignode/pom.xml | 5 +
.../resources/conf/iotdb-confignode.properties | 21 +-
.../iotdb/confignode/conf/ConfigNodeConf.java | 30 +-
.../confignode/conf/ConfigNodeDescriptor.java | 39 +-
.../consensus/response/PermissionInfoDataSet.java | 13 +-
.../statemachine/PartitionRegionStateMachine.java | 5 +-
.../iotdb/confignode/manager/ConfigManager.java | 16 +
.../iotdb/confignode/manager/ConsensusManager.java | 57 +-
.../apache/iotdb/confignode/manager/Manager.java | 8 +
.../confignode/manager/PermissionManager.java | 22 +-
.../persistence/AuthorInfoPersistence.java | 146 ++
.../persistence/RegionInfoPersistence.java | 6 +-
.../iotdb/confignode/physical/PhysicalPlan.java | 25 +-
.../confignode/physical/PhysicalPlanType.java | 20 +-
.../iotdb/confignode/physical/sys/AuthorPlan.java | 243 ++++
.../physical/sys/SchemaPartitionPlan.java | 3 +-
.../confignode/service/executor/PlanExecutor.java | 36 +-
.../server/ConfigNodeRPCServerProcessor.java | 29 +
.../apache/iotdb/confignode/auth/AuthorTest.java | 26 +-
.../server/ConfigNodeRPCServerProcessorTest.java | 56 +-
consensus/README.md | 126 +-
consensus/pom.xml | 2 +-
.../apache/iotdb/consensus/ConsensusFactory.java | 57 +
.../ConsensusGroupAlreadyExistException.java | 2 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 150 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 17 +-
.../consensus/standalone/StandAloneConsensus.java | 20 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 23 +-
.../apache/iotdb/consensus/ratis/UtilsTest.java | 7 +-
.../standalone/StandAloneConsensusTest.java | 43 +-
.../UserGuide/API/Programming-Python-Native-API.md | 19 +-
docs/UserGuide/Library-UDF/Anomaly-Detection.md | 523 -------
docs/zh/Community/About.md | 43 +
.../UserGuide/API/Programming-Python-Native-API.md | 18 +-
docs/zh/UserGuide/Library-UDF/Anomaly Detection.md | 530 -------
docs/zh/UserGuide/UDF-Library/Data-Repairing.md | 1 -
.../controller/DatabaseConnectController.java | 3 +-
.../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 43 +-
...luesIT.java => IoTDBInsertAlignedValuesIT.java} | 21 +-
library-udf/pom.xml | 2 +-
.../apache/iotdb/library/anomaly/UDTFKSigma.java | 127 --
.../org/apache/iotdb/library/anomaly/UDTFLOF.java | 215 ---
.../iotdb/library/anomaly/util/MissDetector.java | 240 ---
.../library/anomaly/util/StreamMissDetector.java | 189 ---
.../UDTFMissDetect.java => dmatch/UDAFCov.java} | 58 +-
.../UDAFDtw.java} | 83 +-
.../UDTFRange.java => dmatch/UDAFPearson.java} | 90 +-
.../UDTFPtnSym.java} | 92 +-
.../UDTFMissDetect.java => dmatch/UDTFXCorr.java} | 68 +-
.../library/dmatch/util/CrossCorrelation.java | 54 +
.../iotdb/library/dprofile/UDAFIntegral.java | 113 ++
.../UDAFIntegralAvg.java} | 80 +-
.../UDTFMissDetect.java => dprofile/UDAFMad.java} | 53 +-
.../UDAFMedian.java} | 53 +-
.../apache/iotdb/library/dprofile/UDAFMode.java | 177 +++
.../iotdb/library/dprofile/UDAFPercentile.java | 168 +++
.../apache/iotdb/library/dprofile/UDAFPeriod.java | 142 ++
.../UDTFMissDetect.java => dprofile/UDAFSkew.java} | 47 +-
.../apache/iotdb/library/dprofile/UDAFSpread.java | 124 ++
.../UDAFStddev.java} | 43 +-
.../UDTFMissDetect.java => dprofile/UDTFACF.java} | 49 +-
.../iotdb/library/dprofile/UDTFDistinct.java | 189 +++
.../UDTFRange.java => dprofile/UDTFHistogram.java} | 83 +-
.../UDTFIQR.java => dprofile/UDTFMinMax.java} | 69 +-
.../UDTFMvAvg.java} | 57 +-
.../UDTFRange.java => dprofile/UDTFPACF.java} | 88 +-
.../UDTFIQR.java => dprofile/UDTFQLB.java} | 91 +-
.../iotdb/library/dprofile/UDTFResample.java | 116 ++
.../apache/iotdb/library/dprofile/UDTFSample.java | 133 ++
.../apache/iotdb/library/dprofile/UDTFSegment.java | 123 ++
.../UDTFIQR.java => dprofile/UDTFSpline.java} | 89 +-
.../UDTFIQR.java => dprofile/UDTFZScore.java} | 68 +-
.../library/dprofile/util/CrossCorrelation.java | 53 +
.../dprofile/util/ExactOrderStatistics.java | 281 ++++
.../iotdb/library/dprofile/util/GKArray.java | 179 +++
.../iotdb/library/dprofile/util/MADSketch.java | 283 ++++
.../apache/iotdb/library/dprofile/util/Mad.java | 26 +-
.../iotdb/library/dprofile/util/MaxSelector.java | 76 +
.../iotdb/library/dprofile/util/Resampler.java | 243 ++++
.../iotdb/library/dprofile/util/Segment.java | 161 ++
.../iotdb/library/dprofile/util/YuleWalker.java | 71 +
.../iotdb/library/dquality/UDTFCompleteness.java | 76 +
.../iotdb/library/dquality/UDTFConsistency.java | 74 +
.../iotdb/library/dquality/UDTFTimeliness.java | 73 +
.../iotdb/library/dquality/UDTFValidity.java | 73 +
.../library/dquality/util/TimeSeriesQuality.java | 243 ++++
.../UDTFTimestampRepair.java} | 66 +-
.../UDTFValueFill.java} | 54 +-
.../UDTFValueRepair.java} | 70 +-
.../apache/iotdb/library/drepair/util/ARFill.java | 93 ++
.../iotdb/library/drepair/util/LikelihoodFill.java | 128 ++
.../iotdb/library/drepair/util/LinearFill.java | 57 +
.../iotdb/library/drepair/util/LsGreedy.java | 141 ++
.../apache/iotdb/library/drepair/util/MAFill.java | 57 +
.../iotdb/library/drepair/util/MeanFill.java | 28 +-
.../iotdb/library/drepair/util/PreviousFill.java | 45 +-
.../apache/iotdb/library/drepair/util/Screen.java | 138 ++
.../iotdb/library/drepair/util/ScreenFill.java | 154 ++
.../library/drepair/util/TimestampInterval.java | 213 +++
.../library/drepair/util/TimestampRepair.java | 154 ++
.../util/ValueFill.java} | 73 +-
.../iotdb/library/drepair/util/ValueRepair.java | 130 ++
.../UDTFConv.java} | 52 +-
.../apache/iotdb/library/frequency/UDTFDWT.java | 96 ++
.../apache/iotdb/library/frequency/UDTFDeconv.java | 112 ++
.../apache/iotdb/library/frequency/UDTFFFT.java | 106 ++
.../UDTFRange.java => frequency/UDTFHighPass.java} | 93 +-
.../apache/iotdb/library/frequency/UDTFIDWT.java | 97 ++
.../apache/iotdb/library/frequency/UDTFIFFT.java | 113 ++
.../UDTFRange.java => frequency/UDTFLowPass.java} | 90 +-
.../iotdb/library/frequency/util/DWTUtil.java | 228 +++
.../iotdb/library/frequency/util/FFTUtil.java | 82 ++
.../library/series/UDTFConsecutiveSequences.java | 78 +
.../library/series/UDTFConsecutiveWindows.java | 90 ++
.../iotdb/library/series/util/ConsecutiveUtil.java | 129 ++
.../UDTFRegexMatch.java} | 53 +-
.../iotdb/library/string/UDTFRegexReplace.java | 130 ++
.../UDTFRegexSplit.java} | 66 +-
.../iotdb/library/string/UDTFStrReplace.java | 153 ++
.../iotdb/library/util/LinearRegression.java | 8 +-
.../apache/iotdb/library/anomaly/AnomalyTests.java | 1533 --------------------
.../apache/iotdb/library/dmatch/DMatchTests.java | 826 +++++++++++
.../iotdb/library/dprofile/DProfileTests.java | 629 ++++++++
.../iotdb/library/dquality/DQualityTests.java | 385 +++++
.../apache/iotdb/library/drepair/DRepairTests.java | 317 ++++
.../iotdb/library/frequency/FrequencyTests.java | 300 ++++
.../apache/iotdb/library/series/SeriesTest.java | 467 ++++++
.../apache/iotdb/library/string/StringTests.java | 258 ++++
.../org/apache/iotdb/commons/cluster/Endpoint.java | 10 +
.../iotdb/commons/consensus/ConsensusGroupId.java | 81 +-
.../{ConsensusGroupId.java => DataRegionId.java} | 50 +-
...onsensusGroupId.java => PartitionRegionId.java} | 50 +-
.../{ConsensusGroupId.java => SchemaRegionId.java} | 50 +-
.../iotdb/commons/partition/DataNodeLocation.java | 6 +-
.../iotdb/commons/partition/RegionReplicaSet.java | 38 +-
.../apache/iotdb/commons/utils/CommonUtils.java | 10 +-
.../resources/conf/iotdb-engine.properties | 37 +-
.../db/auth/authorizer/AuthorizerManager.java | 190 +++
.../iotdb/db/auth/authorizer/BasicAuthorizer.java | 1 +
.../authorizer/ClusterAuthorizer.java} | 10 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 95 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 35 +
.../iotdb/db/consensus/ConsensusExample.java | 113 --
.../apache/iotdb/db/consensus/ConsensusImpl.java | 77 +
.../statemachine/DataRegionStateMachine.java | 11 +-
.../statemachine/SchemaRegionStateMachine.java | 11 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 15 +
.../apache/iotdb/db/engine/StorageEngineV2.java | 525 +------
.../apache/iotdb/db/engine/memtable/IMemTable.java | 5 +
.../db/engine/storagegroup/TsFileProcessor.java | 59 +
.../storagegroup/VirtualStorageGroupProcessor.java | 99 +-
.../iotdb/db/metadata/LocalConfigManager.java | 33 +-
.../db/metadata/LocalSchemaPartitionTable.java | 26 +-
.../db/metadata/schemaregion/SchemaEngine.java | 14 +-
.../db/metadata/schemaregion/SchemaRegion.java | 8 +-
.../iotdb/db/metadata/template/Template.java | 18 +-
.../db/metadata/template/TemplateManager.java | 6 +-
.../iotdb/db/mpp/buffer/DataBlockManager.java | 352 ++++-
.../db/mpp/buffer/DataBlockManagerService.java | 90 --
.../iotdb/db/mpp/buffer/DataBlockService.java | 141 ++
.../mpp/buffer/DataBlockServiceClientFactory.java | 24 +-
.../iotdb/db/mpp/buffer/DataBlockServiceImpl.java | 50 -
...ler.java => DataBlockServiceThriftHandler.java} | 2 +-
.../iotdb/db/mpp/buffer/IDataBlockManager.java | 20 +-
.../apache/iotdb/db/mpp/buffer/ISinkHandle.java | 35 +-
.../apache/iotdb/db/mpp/buffer/ISourceHandle.java | 21 +-
.../org/apache/iotdb/db/mpp/buffer/SinkHandle.java | 365 +++++
.../apache/iotdb/db/mpp/buffer/SourceHandle.java | 371 ++++-
.../apache/iotdb/db/mpp/buffer/StubSinkHandle.java | 29 +-
.../TsBlockSerde.java} | 20 +-
.../TsBlockSerdeFactory.java} | 16 +-
.../iotdb/db/mpp/common/FragmentInstanceId.java | 6 +
.../iotdb/db/mpp/common/MPPQueryContext.java | 25 +-
.../apache/iotdb/db/mpp/common/PlanFragmentId.java | 7 +
.../org/apache/iotdb/db/mpp/common/QueryId.java | 14 +
.../iotdb/db/mpp/common/ResultNodeContext.java | 67 +
.../iotdb/db/mpp/execution/ConfigExecution.java | 110 ++
.../apache/iotdb/db/mpp/execution/Coordinator.java | 64 +-
.../apache/iotdb/db/mpp/execution/DataDriver.java | 3 +-
.../db/mpp/execution/FragmentInstanceManager.java | 47 +-
.../db/mpp/execution/FragmentInstanceState.java | 28 +-
.../iotdb/db/mpp/execution/FutureStateChange.java | 74 +
.../{QueryStateMachine.java => IConfigTask.java} | 11 +-
...QueryStateMachine.java => IQueryExecution.java} | 14 +-
.../iotdb/db/mpp/execution/QueryExecution.java | 138 +-
.../{QueryStateMachine.java => QueryState.java} | 34 +-
.../iotdb/db/mpp/execution/QueryStateMachine.java | 106 +-
.../iotdb/db/mpp/execution/SampleConfigTask.java | 43 +-
.../iotdb/db/mpp/execution/SchemaDriver.java | 3 +-
.../iotdb/db/mpp/execution/StateMachine.java | 322 ++++
.../scheduler/AbstractFragInsStateTracker.java | 73 +
.../mpp/execution/scheduler/ClusterScheduler.java | 90 +-
.../scheduler/FixedRateFragInsStateTracker.java | 70 +
.../FragInstanceDispatchResult.java} | 19 +-
.../scheduler/IFragInstanceDispatcher.java} | 25 +-
.../IFragInstanceStateTracker.java} | 13 +-
.../IQueryTerminator.java} | 11 +-
.../db/mpp/execution/scheduler/IScheduler.java | 4 +-
.../scheduler/InternalServiceClientFactory.java} | 26 +-
.../scheduler/SimpleFragInstanceDispatcher.java | 61 +
.../execution/scheduler/SimpleQueryTerminator.java | 82 ++
.../execution/scheduler/StandaloneScheduler.java | 4 +-
.../iotdb/db/mpp/memory/LocalMemoryManager.java | 17 +-
.../org/apache/iotdb/db/mpp/memory/MemoryPool.java | 108 +-
.../org/apache/iotdb/db/mpp/operator/Operator.java | 4 +-
.../db/mpp/operator/process/LimitOperator.java | 4 +-
.../db/mpp/operator/process/TimeJoinOperator.java | 5 +-
.../db/mpp/operator/source/SeriesScanOperator.java | 56 +-
.../apache/iotdb/db/mpp/sql/analyze/Analyzer.java | 142 ++
.../mpp/sql/analyze/FakePartitionFetcherImpl.java | 13 +-
.../apache/iotdb/db/mpp/sql/parser/ASTVisitor.java | 223 ++-
.../db/mpp/sql/planner/DistributionPlanner.java | 92 +-
.../db/mpp/sql/planner/LocalExecutionPlanner.java | 47 +-
.../iotdb/db/mpp/sql/planner/LogicalPlanner.java | 184 ++-
.../db/mpp/sql/planner/plan/FragmentInstance.java | 4 +-
.../db/mpp/sql/planner/plan/PlanFragment.java | 11 +-
.../plan/SimpleFragmentParallelPlanner.java | 6 +-
.../iotdb/db/mpp/sql/planner/plan/SubPlan.java | 3 +-
.../db/mpp/sql/planner/plan/node/PlanNode.java | 8 +-
.../db/mpp/sql/planner/plan/node/PlanNodeType.java | 17 +-
.../node/metedata/write/AlterTimeSeriesNode.java | 129 +-
.../plan/node/metedata/write/AuthorNode.java | 268 ++++
.../write/CreateAlignedTimeSeriesNode.java | 192 ++-
.../planner/plan/node/process/DeviceMergeNode.java | 4 +-
.../planner/plan/node/process/ExchangeNode.java | 7 +-
.../sql/planner/plan/node/process/FillNode.java | 4 +-
.../sql/planner/plan/node/process/FilterNode.java | 4 +-
.../planner/plan/node/process/FilterNullNode.java | 4 +-
.../plan/node/process/GroupByLevelNode.java | 2 +-
.../sql/planner/plan/node/process/LimitNode.java | 7 +-
.../sql/planner/plan/node/process/OffsetNode.java | 4 +-
.../sql/planner/plan/node/process/SortNode.java | 4 +-
.../planner/plan/node/process/TimeJoinNode.java | 8 +-
.../planner/plan/node/sink/FragmentSinkNode.java | 40 +-
.../plan/node/source/SeriesAggregateScanNode.java | 2 +-
.../planner/plan/node/source/SeriesScanNode.java | 6 +-
.../planner/plan/node/write/InsertTabletNode.java | 2 +-
.../db/mpp/sql/statement/StatementVisitor.java | 102 +-
.../db/mpp/sql/statement/sys/AuthorStatement.java | 152 ++
.../db/protocol/influxdb/handler/QueryHandler.java | 3 +-
.../iotdb/db/protocol/mqtt/PublishHandler.java | 12 +-
.../rest/handler/AuthorizationHandler.java | 12 +-
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 2 +-
.../db/protocol/rest/impl/RestApiServiceImpl.java | 2 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 53 +-
.../iotdb/db/query/control/SessionManager.java | 118 +-
.../iotdb/db/query/expression/Expression.java | 3 +-
.../query/expression/binary/BinaryExpression.java | 3 +-
.../db/query/expression/unary/ConstantOperand.java | 3 +-
.../query/expression/unary/FunctionExpression.java | 6 +-
.../query/expression/unary/LogicNotExpression.java | 3 +-
.../query/expression/unary/NegationExpression.java | 3 +-
.../query/expression/unary/TimeSeriesOperand.java | 6 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 14 +-
.../iotdb/db/service/basic/ServiceProvider.java | 172 ---
.../service/thrift/impl/InfluxDBServiceImpl.java | 18 +-
.../db/service/thrift/impl/TSServiceImpl.java | 131 +-
.../db/utils/datastructure/AlignedTVList.java | 12 +-
.../apache/iotdb/db/mpp/buffer/SinkHandleTest.java | 448 ++++++
.../iotdb/db/mpp/buffer/SourceHandleTest.java | 591 ++++++++
.../java/org/apache/iotdb/db/mpp/buffer/Utils.java | 105 ++
.../db/mpp/execution/QueryStateMachineTest.java | 142 ++
.../apache/iotdb/db/mpp/memory/MemoryPoolTest.java | 140 +-
.../iotdb/db/mpp/operator/LimitOperatorTest.java | 2 +-
.../db/mpp/operator/SeriesScanOperatorTest.java | 2 +-
.../db/mpp/operator/TimeJoinOperatorTest.java | 2 +-
.../iotdb/db/mpp/sql/analyze/AnalyzerTest.java | 3 +-
.../db/mpp/sql/plan/DistributionPlannerTest.java | 81 +-
.../iotdb/db/mpp/sql/plan/LogicalPlannerTest.java | 222 ++-
.../iotdb/db/mpp/sql/plan/QueryPlannerTest.java | 6 +-
site/iotdb-doap.rdf | 16 +-
site/src/main/.vuepress/config.js | 2 +
.../src/main/thrift/confignode.thrift | 13 +
thrift/src/main/thrift/mpp.thrift | 27 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 24 +-
284 files changed, 18673 insertions(+), 6602 deletions(-)
create mode 100644 client-py/tests/test_numpy_tablet.py
create mode 100644 client-py/tests/test_tablet.py
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/QueryStateMachine.java => confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/PermissionInfoDataSet.java (76%)
copy consensus/src/main/java/org/apache/iotdb/consensus/exception/ConsensusGroupAlreadyExistException.java => confignode/src/main/java/org/apache/iotdb/confignode/manager/PermissionManager.java (59%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/AuthorInfoPersistence.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/sys/AuthorPlan.java
copy consensus/src/main/java/org/apache/iotdb/consensus/exception/ConsensusGroupAlreadyExistException.java => confignode/src/test/java/org/apache/iotdb/confignode/auth/AuthorTest.java (58%)
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/ConsensusFactory.java
delete mode 100644 docs/UserGuide/Library-UDF/Anomaly-Detection.md
delete mode 100644 docs/zh/UserGuide/Library-UDF/Anomaly Detection.md
rename integration/src/test/java/org/apache/iotdb/db/integration/aligned/{IOTDBInsertAlignedValuesIT.java => IoTDBInsertAlignedValuesIT.java} (92%)
delete mode 100644 library-udf/src/main/java/org/apache/iotdb/library/anomaly/UDTFKSigma.java
delete mode 100644 library-udf/src/main/java/org/apache/iotdb/library/anomaly/UDTFLOF.java
delete mode 100644 library-udf/src/main/java/org/apache/iotdb/library/anomaly/util/MissDetector.java
delete mode 100644 library-udf/src/main/java/org/apache/iotdb/library/anomaly/util/StreamMissDetector.java
copy library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFMissDetect.java => dmatch/UDAFCov.java} (56%)
copy library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFTwoSidedFilter.java => dmatch/UDAFDtw.java} (58%)
copy library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFRange.java => dmatch/UDAFPearson.java} (56%)
copy library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFTwoSidedFilter.java => dmatch/UDTFPtnSym.java} (50%)
copy library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFMissDetect.java => dmatch/UDTFXCorr.java} (53%)
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dmatch/util/CrossCorrelation.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDAFIntegral.java
copy library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFRange.java => dprofile/UDAFIntegralAvg.java} (57%)
copy library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFMissDetect.java => dprofile/UDAFMad.java} (56%)
copy library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFMissDetect.java => dprofile/UDAFMedian.java} (57%)
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDAFMode.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDAFPercentile.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDAFPeriod.java
copy library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFMissDetect.java => dprofile/UDAFSkew.java} (60%)
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDAFSpread.java
copy library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFMissDetect.java => dprofile/UDAFStddev.java} (60%)
copy library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFMissDetect.java => dprofile/UDTFACF.java} (60%)
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDTFDistinct.java
copy library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFRange.java => dprofile/UDTFHistogram.java} (56%)
copy library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFIQR.java => dprofile/UDTFMinMax.java} (70%)
copy library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFMissDetect.java => dprofile/UDTFMvAvg.java} (59%)
copy library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFRange.java => dprofile/UDTFPACF.java} (57%)
copy library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFIQR.java => dprofile/UDTFQLB.java} (52%)
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDTFResample.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDTFSample.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDTFSegment.java
copy library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFIQR.java => dprofile/UDTFSpline.java} (51%)
rename library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFIQR.java => dprofile/UDTFZScore.java} (66%)
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/CrossCorrelation.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/ExactOrderStatistics.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/GKArray.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/MADSketch.java
copy confignode/src/main/java/org/apache/iotdb/confignode/physical/PhysicalPlanType.java => library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/Mad.java (68%)
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/MaxSelector.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/Resampler.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/Segment.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dprofile/util/YuleWalker.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dquality/UDTFCompleteness.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dquality/UDTFConsistency.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dquality/UDTFTimeliness.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dquality/UDTFValidity.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dquality/util/TimeSeriesQuality.java
copy library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFTwoSidedFilter.java => drepair/UDTFTimestampRepair.java} (56%)
copy library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFTwoSidedFilter.java => drepair/UDTFValueFill.java} (62%)
rename library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFTwoSidedFilter.java => drepair/UDTFValueRepair.java} (56%)
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/ARFill.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/LikelihoodFill.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/LinearFill.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/LsGreedy.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/MAFill.java
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/PlanNodeIdAllocator.java => library-udf/src/main/java/org/apache/iotdb/library/drepair/util/MeanFill.java (62%)
copy consensus/src/main/java/org/apache/iotdb/consensus/common/ConsensusType.java => library-udf/src/main/java/org/apache/iotdb/library/drepair/util/PreviousFill.java (52%)
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/Screen.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/ScreenFill.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/TimestampInterval.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/TimestampRepair.java
rename library-udf/src/main/java/org/apache/iotdb/library/{anomaly/util/WindowDetect.java => drepair/util/ValueFill.java} (51%)
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/ValueRepair.java
copy library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFMissDetect.java => frequency/UDTFConv.java} (58%)
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/frequency/UDTFDWT.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/frequency/UDTFDeconv.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/frequency/UDTFFFT.java
copy library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFRange.java => frequency/UDTFHighPass.java} (53%)
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/frequency/UDTFIDWT.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/frequency/UDTFIFFT.java
rename library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFRange.java => frequency/UDTFLowPass.java} (54%)
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/frequency/util/DWTUtil.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/frequency/util/FFTUtil.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/series/UDTFConsecutiveSequences.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/series/UDTFConsecutiveWindows.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/series/util/ConsecutiveUtil.java
copy library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFMissDetect.java => string/UDTFRegexMatch.java} (55%)
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/string/UDTFRegexReplace.java
rename library-udf/src/main/java/org/apache/iotdb/library/{anomaly/UDTFMissDetect.java => string/UDTFRegexSplit.java} (54%)
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/string/UDTFStrReplace.java
delete mode 100644 library-udf/src/test/java/org/apache/iotdb/library/anomaly/AnomalyTests.java
create mode 100644 library-udf/src/test/java/org/apache/iotdb/library/dmatch/DMatchTests.java
create mode 100644 library-udf/src/test/java/org/apache/iotdb/library/dprofile/DProfileTests.java
create mode 100644 library-udf/src/test/java/org/apache/iotdb/library/dquality/DQualityTests.java
create mode 100644 library-udf/src/test/java/org/apache/iotdb/library/drepair/DRepairTests.java
create mode 100644 library-udf/src/test/java/org/apache/iotdb/library/frequency/FrequencyTests.java
create mode 100644 library-udf/src/test/java/org/apache/iotdb/library/series/SeriesTest.java
create mode 100644 library-udf/src/test/java/org/apache/iotdb/library/string/StringTests.java
copy node-commons/src/main/java/org/apache/iotdb/commons/consensus/{ConsensusGroupId.java => DataRegionId.java} (71%)
copy node-commons/src/main/java/org/apache/iotdb/commons/consensus/{ConsensusGroupId.java => PartitionRegionId.java} (71%)
copy node-commons/src/main/java/org/apache/iotdb/commons/consensus/{ConsensusGroupId.java => SchemaRegionId.java} (71%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/auth/authorizer/AuthorizerManager.java
copy server/src/main/java/org/apache/iotdb/db/{mpp/execution/QueryStateMachine.java => auth/authorizer/ClusterAuthorizer.java} (76%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/consensus/ConsensusExample.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/consensus/ConsensusImpl.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/DataBlockManagerService.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/DataBlockService.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/DataBlockServiceImpl.java
rename server/src/main/java/org/apache/iotdb/db/mpp/buffer/{DataBlockManagerServiceThriftHandler.java => DataBlockServiceThriftHandler.java} (94%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/SinkHandle.java
copy server/src/main/java/org/apache/iotdb/db/mpp/{sql/planner/plan/node/PlanNodeIdAllocator.java => buffer/TsBlockSerde.java} (68%)
copy server/src/main/java/org/apache/iotdb/db/mpp/{execution/QueryStateMachine.java => buffer/TsBlockSerdeFactory.java} (76%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/ResultNodeContext.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/ConfigExecution.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/FutureStateChange.java
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/{QueryStateMachine.java => IConfigTask.java} (80%)
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/{QueryStateMachine.java => IQueryExecution.java} (80%)
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/{QueryStateMachine.java => QueryState.java} (58%)
rename consensus/src/main/java/org/apache/iotdb/consensus/common/ConsensusType.java => server/src/main/java/org/apache/iotdb/db/mpp/execution/SampleConfigTask.java (52%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/StateMachine.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/AbstractFragInsStateTracker.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/FixedRateFragInsStateTracker.java
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/{QueryStateMachine.java => scheduler/FragInstanceDispatchResult.java} (73%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql/planner/plan/node/PlanNodeIdAllocator.java => execution/scheduler/IFragInstanceDispatcher.java} (64%)
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/{QueryStateMachine.java => scheduler/IFragInstanceStateTracker.java} (76%)
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/{QueryStateMachine.java => scheduler/IQueryTerminator.java} (76%)
copy server/src/main/java/org/apache/iotdb/db/mpp/{buffer/DataBlockServiceClientFactory.java => execution/scheduler/InternalServiceClientFactory.java} (57%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/SimpleFragInstanceDispatcher.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/SimpleQueryTerminator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/write/AuthorNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/sys/AuthorStatement.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/buffer/SinkHandleTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/buffer/SourceHandleTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/buffer/Utils.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/QueryStateMachineTest.java