You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2022/04/27 09:53:18 UTC
[iotdb] 01/01: Merge branch 'master' of github.com:apache/iotdb into iotdb-2933
This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch iotdb-2933
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 7ab8a745902664621d224315d89fabfa028908ce
Merge: cd6af308cd 5f6a986b1c
Author: Steve Yurong Su <ro...@apache.org>
AuthorDate: Wed Apr 27 17:53:00 2022 +0800
Merge branch 'master' of github.com:apache/iotdb into iotdb-2933
.../query/manage/ClusterSessionManager.java | 1 +
.../iotdb/confignode/manager/ConfigManager.java | 11 +
.../apache/iotdb/confignode/manager/Manager.java | 9 +
.../iotdb/confignode/persistence/AuthorInfo.java | 21 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 +
.../apache/iotdb/consensus/ratis/RatisClient.java | 107 +++++
.../iotdb/consensus/ratis/RatisClientFactory.java | 67 ----
.../iotdb/consensus/ratis/RatisConsensus.java | 93 ++---
.../iotdb/consensus/ratis/RatisConsensusTest.java | 2 +-
.../Data-Concept/Data-Model-and-Terminology.md | 2 +-
docs/UserGuide/Maintenance-Tools/Sync-Tool.md | 119 +++++-
docs/zh/UserGuide/Maintenance-Tools/Sync-Tool.md | 23 +-
.../iotdb/db/integration/IoTDBInsertNullIT.java | 207 ++++++++++
.../sync/IoTDBSyncReceiverCollectorIT.java | 12 +-
.../db/integration/sync/IoTDBSyncSenderIT.java | 327 +++++++++++++--
.../db/integration/sync/TransportClientMock.java | 12 +-
.../db/integration/sync/TransportHandlerMock.java | 61 +++
.../resources/conf/iotdb-engine.properties | 5 +
.../db/auth/authorizer/AuthorizerManager.java | 55 +++
.../db/auth/authorizer/ClusterAuthorizer.java | 24 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 16 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 14 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 5 +
.../iotdb/db/engine/memtable/AbstractMemTable.java | 23 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 13 +-
.../iotdb/db/metadata/LocalSchemaProcessor.java | 6 +-
.../db/metadata/tree/AbstractTreeVisitor.java | 376 +++++++++++++++++
.../tree/AbstractTreeVisitorWithLimitOffset.java | 106 +++++
.../tree/ITreeNode.java} | 20 +-
.../iotdb/db/mpp/common/MPPQueryContext.java | 25 +-
.../db/mpp/common/schematree/DeviceSchemaInfo.java | 40 +-
.../iotdb/db/mpp/common/schematree/SchemaTree.java | 33 +-
.../mpp/common/schematree/SchemaTreeVisitor.java | 237 -----------
.../schematree/{ => node}/SchemaEntityNode.java | 2 +-
.../schematree/{ => node}/SchemaInternalNode.java | 2 +-
.../{ => node}/SchemaMeasurementNode.java | 2 +-
.../common/schematree/{ => node}/SchemaNode.java | 6 +-
.../visitor/SchemaTreeDeviceVisitor.java | 61 +++
.../visitor/SchemaTreeMeasurementVisitor.java | 80 ++++
.../schematree/visitor/SchemaTreeVisitor.java | 60 +++
.../apache/iotdb/db/mpp/execution/Coordinator.java | 21 +-
.../iotdb/db/mpp/execution/QueryExecution.java | 4 +-
.../scheduler/AbstractFragInsStateTracker.java | 6 +-
.../scheduler/SimpleFragInstanceDispatcher.java | 6 +-
.../execution/scheduler/SimpleQueryTerminator.java | 9 +-
.../mpp/sql/analyze/ClusterPartitionFetcher.java | 446 +++++++++++++++++++--
.../mpp/sql/analyze/FakePartitionFetcherImpl.java | 11 +
.../db/mpp/sql/analyze/FakeSchemaFetcherImpl.java | 8 +-
.../db/mpp/sql/analyze/IPartitionFetcher.java | 4 +
.../sql/analyze/StandalonePartitionFetcher.java | 11 +
.../db/mpp/sql/planner/DistributionPlanner.java | 6 +-
.../db/mpp/sql/planner/LocalExecutionPlanner.java | 13 +-
.../sql/planner/SimpleFragmentParallelPlanner.java | 9 +-
.../db/mpp/sql/planner/plan/FragmentInstance.java | 25 +-
.../db/qp/physical/sys/DeleteTimeSeriesPlan.java | 12 +
.../java/org/apache/iotdb/db/service/IoTDB.java | 2 +-
.../thrift/impl/DataNodeTSIServiceImpl.java | 6 +-
.../apache/iotdb/db/sync/conf/SyncConstant.java | 54 +--
.../apache/iotdb/db/sync/conf/SyncPathUtil.java | 82 ++--
.../iotdb/db/sync/pipedata/DeletionPipeData.java | 2 +-
.../sync/pipedata/queue/BufferedPipeDataQueue.java | 31 +-
.../db/sync/pipedata/queue/PipeDataQueue.java | 2 +
.../db/sync/receiver/collector/Collector.java | 4 +-
.../db/sync/receiver/manager/ReceiverManager.java | 4 +-
.../db/sync/sender/manager/SchemaSyncManager.java | 18 +-
.../iotdb/db/sync/sender/pipe/IoTDBPipeSink.java | 18 +
.../org/apache/iotdb/db/sync/sender/pipe/Pipe.java | 10 +
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 61 ++-
.../db/sync/sender/recovery/SenderLogAnalyzer.java | 25 +-
.../db/sync/sender/recovery/SenderLogger.java | 12 +-
.../db/sync/sender/recovery/TsFilePipeLogger.java | 2 +-
.../iotdb/db/sync/sender/service/MsgManager.java | 114 ++++++
.../db/sync/sender/service/SenderService.java | 81 ++--
.../db/sync/sender/service/TransportHandler.java | 47 ++-
.../db/sync/transport/client/TransportClient.java | 35 +-
.../db/mpp/common/schematree/SchemaTreeTest.java | 167 +++++++-
.../operator/schema/SchemaFetchOperatorTest.java | 2 +-
.../db/mpp/sql/plan/DistributionPlannerTest.java | 18 +-
.../iotdb/db/mpp/sql/plan/QueryPlannerTest.java | 6 +-
.../sync/pipedata/BufferedPipeDataQueueTest.java | 26 +-
.../receiver/recovery/ReceiverLogAnalyzerTest.java | 4 +-
.../iotdb/rpc/ConfigNodeConnectionException.java | 21 +-
.../src/main/thrift/confignode.thrift | 7 +
83 files changed, 2913 insertions(+), 830 deletions(-)