simingweng commented on a change in pull request #3223: fix saving and
restoring checkpoint from dlog
URL: https://github.com/apache/incubator-heron/pull/3223#discussion_r268917608
##########
File path: heron/io/dlog/src/java/org/apache/heron/dlog/DLInputStream.java
##########
@@ -100,6 +60,25 @@ private static LogRecordWithInputStream
nextLogRecord(LogReader reader) throws I
}
}
+ public long getNumOfBytesRead() {
+ return numOfBytesRead;
+ }
+
+ /**
+ * Get input stream representing next entry in the
+ * ledger.
+ *
+ * @return input stream, or null if no more entries
+ */
+ private LogRecordWithInputStream nextLogRecord() throws IOException {
+ try {
+ return nextLogRecord(reader);
+ } catch (EndOfStreamException e) {
+ eos = true;
Review comment:
I didn’t really change this part of the file, it was my IDE automatically
re-orgonized the code. But, I do think log here is helpful. Will update the
pull request.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
