reswqa commented on code in PR #20371:
URL: https://github.com/apache/flink/pull/20371#discussion_r933073774
##########
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionMemoryDataManager.java:
##########
@@ -114,16 +115,16 @@ public DataType peekNextToConsumeDataType(int
nextToConsumeIndex) {
/**
* Check whether the head of {@link #unConsumedBuffers} is the buffer to
be consumed. If so,
- * return the buffer and next data type.
+ * return the buffer and backlog.
*
* @param toConsumeIndex index of buffer to be consumed.
* @return If the head of {@link #unConsumedBuffers} is target, return
optional of the buffer
- * and next data type. Otherwise, return {@link Optional#empty()}.
+ * and backlog. Otherwise, return {@link Optional#empty()}.
*/
@SuppressWarnings("FieldAccessNotGuarded")
// Note that: callWithLock ensure that code block guarded by
resultPartitionReadLock and
// subpartitionLock.
- public Optional<HsMemoryDataManager.BufferAndNextDataType>
consumeBuffer(int toConsumeIndex) {
+ public Optional<BufferAndBacklog> consumeBuffer(int toConsumeIndex) {
Review Comment:
Added.
--
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]
