in ambari-infra-manager/src/main/java/org/apache/ambari/infra/job/archive/DocumentItemReader.java [52:67]
public Document read() throws Exception {
if (documentIterator == null)
openStream();
Document next = getNext();
if (next == null && count > readBlockSize) {
openStream();
next = getNext();
}
eof = next == null;
if (eof && documentIterator != null)
documentIterator.close();
previous = current;
current = next;
return current;
}