Vladsz83 commented on code in PR #10262:
URL: https://github.com/apache/ignite/pull/10262#discussion_r983397201
##########
modules/core/src/main/java/org/apache/ignite/stream/StreamReceiver.java:
##########
@@ -41,4 +43,18 @@
* @throws org.apache.ignite.IgniteException If failed.
*/
public void receive(IgniteCache<K, V> cache, Collection<Map.Entry<K, V>>
entries) throws IgniteException;
+
+ /**
+ * Sets max parallel batches (operations) per node if {@link
IgniteDataStreamer#perNodeParallelOperations()} is not
+ * positive. In same way takes place only if positive.
+ *
+ * @param node Node to send to.
+ * @param persistant {@code True} if the cache is persistent. {@code
False} otherwise.
+ *
+ * @return Max parallel batches.
+ * @see IgniteDataStreamer#perNodeParallelOperations(int)
+ */
+ public default int perNodeParallelOperations(ClusterNode node, boolean
persistant) {
Review Comment:
Fixed. In other places too.
--
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]
