fapifta commented on a change in pull request #2702:
URL: https://github.com/apache/ozone/pull/2702#discussion_r722097625
##########
File path:
hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/io/BlockOutputStreamEntryPool.java
##########
@@ -283,26 +338,21 @@ void commitKey(long offset) throws IOException {
}
}
- public BlockOutputStreamEntry getCurrentStreamEntry() {
+ BlockOutputStreamEntry getCurrentStreamEntry() {
if (streamEntries.isEmpty() || streamEntries.size() <= currentStreamIndex)
{
return null;
} else {
return streamEntries.get(currentStreamIndex);
}
}
- public int getCurrIdx(){
- return currentStreamIndex;
- }
-
- public void setCurrIdx(int currIdx) {
- this.currentStreamIndex = currIdx;
- }
-
- public void updateToNextStream(int rotation) {
- currentStreamIndex = (currentStreamIndex + 1) % rotation;
- }
-
+ /**
+ * Allocates a new block with OM, currently ECKeyOutputStream is an exclusive
Review comment:
I have corrected this, and also removed the EC related notes and
descriptions in #2709
--
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]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
