in src/main/java/software/amazon/qldb/tutorial/streams/StreamJournal.java [573:595]
private static JournalBlock blockSummaryRecordToJournalBlock(BlockSummaryRecord blockSummaryRecord,
Map<ByteBuffer, QldbRevision> revisionsByHash) {
List<QldbRevision> revisions = null;
if (blockSummaryRecord.getRevisionSummaries() != null) {
revisions = blockSummaryRecord.getRevisionSummaries().stream().map(revisionSummary -> {
if (revisionSummary.getDocumentId() != null) {
return revisionsByHash.get(wrap(revisionSummary.getHash()).asReadOnlyBuffer());
} else {
return new QldbRevision(null, null, revisionSummary.getHash(), null);
}
}).collect(Collectors.toList());
}
return new JournalBlock(
blockSummaryRecord.getBlockAddress(),
blockSummaryRecord.getTransactionId(),
blockSummaryRecord.getBlockTimestamp(),
blockSummaryRecord.getBlockHash(),
blockSummaryRecord.getEntriesHash(),
blockSummaryRecord.getPreviousBlockHash(),
blockSummaryRecord.getEntriesHashList(),
blockSummaryRecord.getTransactionInfo(),
revisions);
}