xtern commented on code in PR #1501:
URL: https://github.com/apache/ignite-3/pull/1501#discussion_r1092296660
##########
modules/table/src/main/java/org/apache/ignite/internal/table/InternalTable.java:
##########
@@ -357,6 +385,29 @@ Publisher<BinaryRow> lookup(
@Nullable BitSet columnsToInclude
);
+ /**
+ * Lookup rows corresponding to the given key given partition index,
providing {@link Publisher}
+ * that reactively notifies about partition rows.
+ *
+ * @param partId The partition.
+ * @param txId Transaction id.
+ * @param leaderNode Raft group leader node that must handle given get
request.
+ * @param leaderTerm Raft group leader term.
+ * @param indexId Index id.
+ * @param key Key to search.
+ * @param columnsToInclude Row projection.
+ * @return {@link Publisher} that reactively notifies about partition rows.
+ */
+ Publisher<BinaryRow> lookup(
+ int partId,
+ UUID txId,
+ ClusterNode leaderNode,
+ long leaderTerm,
Review Comment:
Replaced with a `PrimaryReplica` object as you suggested below, thanks.
--
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]
