sashapolo commented on code in PR #3352:
URL: https://github.com/apache/ignite-3/pull/3352#discussion_r1516022608
##########
modules/storage-api/src/main/java/org/apache/ignite/internal/storage/util/MvPartitionStorages.java:
##########
@@ -432,6 +434,26 @@ private String
createStorageInProgressOfRebalanceErrorMessage(int partitionId) {
return null;
}
+ /**
+ * Returns a list of all existing storages.
+ *
+ * <p>Note: this method may produce races when a rebalance is happening
concurrently as the underlying storage array may change.
+ * The callers of this method should resolve these races themselves.
+ */
+ public List<T> getAll() {
+ var list = new ArrayList<T>(storageByPartitionId.length());
Review Comment:
But less effective! =)
--
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]
