reswqa commented on code in PR #20371:
URL: https://github.com/apache/flink/pull/20371#discussion_r933010674
##########
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsMemoryDataManager.java:
##########
@@ -115,6 +123,22 @@ public void append(ByteBuffer record, int targetChannel,
Buffer.DataType dataTyp
}
}
+ /**
+ * Register {@link HsSubpartitionViewInternalOperations} to {@link
+ * #subpartitionViewOperationsMap}. It is used to obtain the consumption
progress of the
+ * subpartition.
+ */
+ public void registerSubpartitionView(
+ int subpartitionId, HsSubpartitionViewInternalOperations
viewOperations) {
+ HsSubpartitionViewInternalOperations oldView =
+ subpartitionViewOperationsMap.put(subpartitionId,
viewOperations);
+ if (oldView != null) {
+ LOG.debug(
+ "subpartition : {} register subpartition view will replace
old view. ",
+ subpartitionId);
+ }
Review Comment:
Once `SubpartitionView` register to upstream, it will be available, and no
additional notification is required.
--
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]
