Re: [PR] PipeConsensus: initialize thrift service & connector and receiver logic [iotdb]

2024-05-17 Thread via GitHub
Caideyipi commented on code in PR #12355: URL: https://github.com/apache/iotdb/pull/12355#discussion_r1604662755 ## iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/PipeConsensusServerImpl.java: ## @@ -0,0 +1,377 @@ +/* + * Licensed to the Apache Software

Re: [PR] PipeConsensus: initialize thrift service & connector and receiver logic [iotdb]

2024-05-17 Thread via GitHub
Pengzna commented on code in PR #12355: URL: https://github.com/apache/iotdb/pull/12355#discussion_r1604917042 ## iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/config/PipeConsensusConfig.java: ## @@ -0,0 +1,345 @@ +package org.apache.iotdb.consensus.config;

Re: [PR] PipeConsensus: initialize thrift service & connector and receiver logic [iotdb]

2024-05-17 Thread via GitHub
Pengzna commented on code in PR #12355: URL: https://github.com/apache/iotdb/pull/12355#discussion_r1604917042 ## iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/config/PipeConsensusConfig.java: ## @@ -0,0 +1,345 @@ +package org.apache.iotdb.consensus.config;

Re: [PR] PipeConsensus: initialize thrift service & connector and receiver logic [iotdb]

2024-05-17 Thread via GitHub
Caideyipi commented on code in PR #12355: URL: https://github.com/apache/iotdb/pull/12355#discussion_r1604625313 ## iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/config/PipeConsensusConfig.java: ## @@ -0,0 +1,345 @@ +package org.apache.iotdb.consensus.config;

Re: [PR] PipeConsensus: initialize thrift service & connector and receiver logic [iotdb]

2024-04-17 Thread via GitHub
Pengzna commented on code in PR #12355: URL: https://github.com/apache/iotdb/pull/12355#discussion_r1568516568 ## iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/PipeConsensusAsyncConnector.java: ## @@ -0,0 +1,117 @@ +/* + * Licensed

Re: [PR] PipeConsensus: initialize thrift service & connector and receiver logic [iotdb]

2024-04-17 Thread via GitHub
Pengzna commented on code in PR #12355: URL: https://github.com/apache/iotdb/pull/12355#discussion_r1568514855 ## iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/event/EnrichedEvent.java: ## @@ -284,6 +289,21 @@ public void onCommitted() { } } +

Re: [PR] PipeConsensus: initialize thrift service & connector and receiver logic [iotdb]

2024-04-17 Thread via GitHub
Pengzna commented on code in PR #12355: URL: https://github.com/apache/iotdb/pull/12355#discussion_r1568516568 ## iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/PipeConsensusAsyncConnector.java: ## @@ -0,0 +1,117 @@ +/* + * Licensed

Re: [PR] PipeConsensus: initialize thrift service & connector and receiver logic [iotdb]

2024-04-17 Thread via GitHub
Pengzna commented on code in PR #12355: URL: https://github.com/apache/iotdb/pull/12355#discussion_r1568517420 ## iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/PipeConsensusAsyncConnector.java: ## @@ -0,0 +1,117 @@ +/* + * Licensed

Re: [PR] PipeConsensus: initialize thrift service & connector and receiver logic [iotdb]

2024-04-17 Thread via GitHub
Pengzna commented on code in PR #12355: URL: https://github.com/apache/iotdb/pull/12355#discussion_r1568157024 ## iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/PipeConsensusAsyncConnector.java: ## @@ -0,0 +1,113 @@ +/* + * Licensed

Re: [PR] PipeConsensus: initialize thrift service & connector and receiver logic [iotdb]

2024-04-17 Thread via GitHub
Pengzna commented on code in PR #12355: URL: https://github.com/apache/iotdb/pull/12355#discussion_r1568517420 ## iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/PipeConsensusAsyncConnector.java: ## @@ -0,0 +1,117 @@ +/* + * Licensed

Re: [PR] PipeConsensus: initialize thrift service & connector and receiver logic [iotdb]

2024-04-17 Thread via GitHub
DanielWang2035 commented on code in PR #12355: URL: https://github.com/apache/iotdb/pull/12355#discussion_r1568335911 ## iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/PipeConsensusAsyncConnector.java: ## @@ -0,0 +1,117 @@ +/* + *

Re: [PR] PipeConsensus: initialize thrift service & connector and receiver logic [iotdb]

2024-04-17 Thread via GitHub
DanielWang2035 commented on code in PR #12355: URL: https://github.com/apache/iotdb/pull/12355#discussion_r1568333531 ## iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/event/EnrichedEvent.java: ## @@ -284,6 +289,21 @@ public void onCommitted() { } }

Re: [PR] PipeConsensus: initialize thrift service & connector and receiver logic [iotdb]

2024-04-16 Thread via GitHub
Pengzna commented on code in PR #12355: URL: https://github.com/apache/iotdb/pull/12355#discussion_r1568157024 ## iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/PipeConsensusAsyncConnector.java: ## @@ -0,0 +1,113 @@ +/* + * Licensed

Re: [PR] PipeConsensus: initialize thrift service & connector and receiver logic [iotdb]

2024-04-16 Thread via GitHub
SzyWilliam commented on code in PR #12355: URL: https://github.com/apache/iotdb/pull/12355#discussion_r1568144839 ## iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/PipeConsensusAsyncConnector.java: ## @@ -0,0 +1,113 @@ +/* + *