This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch PathToCommon
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from d135df1398 Move all path related class to node-commons module
add 8ff428b0ae Add Error log for ConfigExecution (#7436)
add a29d38dacd change port to InternalPort for show cluster (#7440)
add b01996544a [IOTDB-4456][IOTDB-4459] Sync cluster framework in
ConfigNode and PipeSink operation (#7386)
add b4da41d1a8 Resolve conflicts
No new revisions were added by this update.
Summary of changes:
.../consensus/request/ConfigPhysicalPlan.java | 12 +
.../consensus/request/ConfigPhysicalPlanType.java | 5 +-
.../sync/CreatePipeSinkPlan.java} | 30 +--
.../DropPipeSinkPlan.java} | 29 ++-
.../GetPipeSinkPlan.java} | 30 ++-
.../{TemplateInfoResp.java => PipeSinkResp.java} | 15 +-
.../iotdb/confignode/manager/ConfigManager.java | 49 +++-
.../apache/iotdb/confignode/manager/IManager.java | 28 +++
.../iotdb/confignode/manager/SyncManager.java | 101 ++++++++
.../persistence/executor/ConfigPlanExecutor.java | 16 +-
.../persistence/sync/ClusterSyncInfo.java | 118 +++++++++
.../thrift/ConfigNodeRPCServiceProcessor.java | 21 ++
.../request/ConfigPhysicalPlanSerDeTest.java | 47 ++++
docs/UserGuide/Cluster/Cluster-Setup.md | 48 ++--
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 48 ++--
.../apache/iotdb/db/it/sync/IoTDBPipeSinkIT.java | 18 +-
.../db/integration/sync/IoTDBSyncReceiverIT.java | 2 +-
.../db/integration/sync/IoTDBSyncSenderIT.java | 2 +-
.../exception/sync/PipeDataLoadException.java | 2 +-
.../commons}/exception/sync/PipeException.java | 2 +-
.../exception/sync/PipeServerException.java | 2 +-
.../commons}/exception/sync/PipeSinkException.java | 2 +-
.../iotdb/commons/sync/metadata/SyncMetadata.java | 212 +++++++++++++++++
.../apache/iotdb/commons/sync}/pipe/PipeInfo.java | 4 +-
.../iotdb/commons/sync}/pipe/PipeMessage.java | 2 +-
.../apache/iotdb/commons/sync/pipe/PipeStatus.java | 10 +-
.../pipe/SyncOperation.java} | 10 +-
.../iotdb/commons/sync}/pipe/TsFilePipeInfo.java | 4 +-
.../commons/sync/pipesink}/IoTDBPipeSink.java | 29 ++-
.../iotdb/commons/sync/pipesink}/PipeSink.java | 25 +-
.../commons/sync/{ => utils}/SyncConstant.java | 2 +-
.../commons/sync/{ => utils}/SyncPathUtil.java | 2 +-
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 19 ++
.../apache/iotdb/db/client/ConfigNodeClient.java | 52 ++++
.../iotdb/db/localconfignode/LocalConfigNode.java | 18 +-
.../mpp/plan/execution/config/ConfigExecution.java | 9 +-
.../config/executor/ClusterConfigTaskExecutor.java | 90 +++++--
.../executor/StandaloneConfigTaskExecutor.java | 16 +-
.../config/sys/sync/ShowPipeSinkTask.java | 27 ++-
.../memory/StatementMemorySourceVisitor.java | 2 +-
.../sys/sync/CreatePipeSinkStatement.java | 2 +-
.../statement/sys/sync/CreatePipeStatement.java | 2 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 6 +-
.../iotdb/db/qp/physical/sys/CreatePipePlan.java | 2 +-
.../db/qp/physical/sys/CreatePipeSinkPlan.java | 2 +-
.../java/org/apache/iotdb/db/sync/SyncService.java | 35 +--
.../iotdb/db/sync/common/ISyncInfoFetcher.java | 6 +-
.../apache/iotdb/db/sync/common/LocalSyncInfo.java | 164 +++++++++++++
.../iotdb/db/sync/common/LocalSyncInfoFetcher.java | 92 +++----
.../org/apache/iotdb/db/sync/common/SyncInfo.java | 264 ---------------------
.../db/sync/common/persistence/SyncLogReader.java | 8 +-
.../db/sync/common/persistence/SyncLogWriter.java | 11 +-
.../iotdb/db/sync/pipedata/TsFilePipeData.java | 2 +-
.../sync/pipedata/queue/BufferedPipeDataQueue.java | 4 +-
.../db/sync/receiver/load/DeletionLoader.java | 2 +-
.../iotdb/db/sync/receiver/load/ILoader.java | 2 +-
.../iotdb/db/sync/receiver/load/SchemaLoader.java | 2 +-
.../iotdb/db/sync/receiver/load/TsFileLoader.java | 2 +-
.../db/sync/sender/pipe/ExternalPipeSink.java | 10 +-
.../org/apache/iotdb/db/sync/sender/pipe/Pipe.java | 14 +-
.../{PipeMessage.java => PipeSinkFactory.java} | 45 ++--
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 11 +-
.../db/sync/sender/recovery/TsFilePipeLogger.java | 4 +-
.../db/sync/transport/client/IoTDBSyncClient.java | 4 +-
.../db/sync/transport/client/SenderManager.java | 8 +-
.../sync/transport/client/SyncClientFactory.java | 6 +-
.../db/sync/transport/server/ReceiverManager.java | 6 +-
.../apache/iotdb/db/utils/sync/SyncPipeUtil.java | 32 ++-
.../org/apache/iotdb/db/sync/SyncTestUtils.java | 8 +-
.../sync/pipedata/BufferedPipeDataQueueTest.java | 4 +-
.../{SyncInfoTest.java => LocalSyncInfoTest.java} | 46 ++--
.../db/sync/receiver/recovery/SyncLogTest.java | 16 +-
.../iotdb/db/sync/transport/SyncTransportTest.java | 6 +-
.../src/main/thrift/confignode.thrift | 34 ++-
74 files changed, 1362 insertions(+), 660 deletions(-)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{read/template/GetPathsSetTemplatePlan.java
=> write/sync/CreatePipeSinkPlan.java} (61%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{DropFunctionPlan.java
=> sync/DropPipeSinkPlan.java} (66%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{DropFunctionPlan.java
=> sync/GetPipeSinkPlan.java} (66%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{TemplateInfoResp.java
=> PipeSinkResp.java} (79%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/SyncManager.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/persistence/sync/ClusterSyncInfo.java
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/exception/sync/PipeDataLoadException.java
(95%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/exception/sync/PipeException.java
(96%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/exception/sync/PipeServerException.java
(96%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/exception/sync/PipeSinkException.java
(96%)
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/sync/metadata/SyncMetadata.java
rename {server/src/main/java/org/apache/iotdb/db/sync/sender =>
node-commons/src/main/java/org/apache/iotdb/commons/sync}/pipe/PipeInfo.java
(95%)
copy {server/src/main/java/org/apache/iotdb/db/sync/sender =>
node-commons/src/main/java/org/apache/iotdb/commons/sync}/pipe/PipeMessage.java
(97%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/RegionMaintainType.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/sync/pipe/PipeStatus.java
(85%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/{schema/tree/ITreeNode.java
=> sync/pipe/SyncOperation.java} (87%)
rename {server/src/main/java/org/apache/iotdb/db/sync/sender =>
node-commons/src/main/java/org/apache/iotdb/commons/sync}/pipe/TsFilePipeInfo.java
(97%)
rename {server/src/main/java/org/apache/iotdb/db/sync/sender/pipe =>
node-commons/src/main/java/org/apache/iotdb/commons/sync/pipesink}/IoTDBPipeSink.java
(78%)
rename {server/src/main/java/org/apache/iotdb/db/sync/sender/pipe =>
node-commons/src/main/java/org/apache/iotdb/commons/sync/pipesink}/PipeSink.java
(65%)
rename node-commons/src/main/java/org/apache/iotdb/commons/sync/{ =>
utils}/SyncConstant.java (98%)
rename node-commons/src/main/java/org/apache/iotdb/commons/sync/{ =>
utils}/SyncPathUtil.java (99%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/sync/common/LocalSyncInfo.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/common/SyncInfo.java
rename
server/src/main/java/org/apache/iotdb/db/sync/sender/pipe/{PipeMessage.java =>
PipeSinkFactory.java} (55%)
rename
server/src/test/java/org/apache/iotdb/db/sync/receiver/manager/{SyncInfoTest.java
=> LocalSyncInfoTest.java} (62%)
