}
logger.info("packing to {} with flags {}", getOutputFile(), flags);
Closer closer = Closer.create();
try {
BinaryRatingPacker packer = closer.register(BinaryRatingPacker.open(getOutputFile(), flags));
Cursor<Rating> ratings = closer.register(dao.streamEvents(Rating.class));
packer.writeRatings(ratings);
logger.info("packed {} ratings", packer.getRatingCount());
} catch (Throwable th) {
throw closer.rethrow(th);
} finally {