This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch iotdb-2933
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from cd6af308cd Expression
add 4bf3dbb674 [IOTDB-2960]Add partition cache (#5685)
add 9b5f18318e Set correct InternalEndpoint and DataBlockEndpoint when
planning (#5679)
add 6946f3031a [IOTDB-2938]Some improvements and bug fix for New Sync
(#5563)
add 112758a997 [IOTDB-2701]User guide for Sync (#5676)
add 300903d2bb Update the description of ** (#5690)
add dd5071df75 New schema tree traverse implementation (#5686)
add 660fc05f31 [IOTDB-2998] Pooling RatisConsensus Raft client (#5683)
add b06d314762 [IOTDB-3015] Authenticate login via confignode (#5678)
add 5f6a986b1c [IOTDB-2753] Insert a time series with a null value and
report 500 (#5694)
new 7ab8a74590 Merge branch 'master' of github.com:apache/iotdb into
iotdb-2933
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:
.../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 +-
.../{IoTDBInIT.java => IoTDBInsertNullIT.java} | 145 +++----
.../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 +++++
.../apache/iotdb/db/metadata/tree/ITreeNode.java | 7 +-
.../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 | 12 +-
.../src/main/thrift/confignode.thrift | 7 +
83 files changed, 2756 insertions(+), 903 deletions(-)
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/ratis/RatisClient.java
delete mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/ratis/RatisClientFactory.java
copy integration/src/test/java/org/apache/iotdb/db/integration/{IoTDBInIT.java
=> IoTDBInsertNullIT.java} (52%)
create mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/sync/TransportHandlerMock.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/tree/AbstractTreeVisitor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/tree/AbstractTreeVisitorWithLimitOffset.java
copy
cluster/src/main/java/org/apache/iotdb/cluster/server/raft/MetaRaftServiceMBean.java
=> server/src/main/java/org/apache/iotdb/db/metadata/tree/ITreeNode.java (89%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/SchemaTreeVisitor.java
rename server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/{ =>
node}/SchemaEntityNode.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/{ =>
node}/SchemaInternalNode.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/{ =>
node}/SchemaMeasurementNode.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/{ =>
node}/SchemaNode.java (92%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/visitor/SchemaTreeDeviceVisitor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/visitor/SchemaTreeMeasurementVisitor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/visitor/SchemaTreeVisitor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/sync/sender/service/MsgManager.java
copy
metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/MonitorType.java
=>
service-rpc/src/main/java/org/apache/iotdb/rpc/ConfigNodeConnectionException.java
(82%)
