SammyVimes commented on code in PR #1016:
URL: https://github.com/apache/ignite-3/pull/1016#discussion_r957362774
##########
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/TableManager.java:
##########
@@ -606,6 +708,32 @@ private void
updateAssignmentInternal(ConfigurationNotificationEvent<byte[]> ass
CompletableFuture.allOf(futures).join();
}
+ /**
+ * Calculates the quantity of the data nodes for the partition of the
table.
+ *
+ * @param tblId Table id.
+ * @param partId Partition id.
+ * @param partAssignments Partition assignments.
+ * @return A future that will hold the quantity of data nodes.
+ */
+ private CompletableFuture<Long> queryDataNodesCount(UUID tblId, int
partId, List<ClusterNode> partAssignments) {
Review Comment:
What can I say, Stream#count returns `long`...
##########
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/TableManager.java:
##########
@@ -606,6 +708,32 @@ private void
updateAssignmentInternal(ConfigurationNotificationEvent<byte[]> ass
CompletableFuture.allOf(futures).join();
}
+ /**
+ * Calculates the quantity of the data nodes for the partition of the
table.
+ *
+ * @param tblId Table id.
+ * @param partId Partition id.
+ * @param partAssignments Partition assignments.
+ * @return A future that will hold the quantity of data nodes.
+ */
+ private CompletableFuture<Long> queryDataNodesCount(UUID tblId, int
partId, List<ClusterNode> partAssignments) {
Review Comment:
What can I say, `Stream#count` returns `long`...
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
