Nice to see different example of how to process historical and streaming data that doesn't use a complicated lambda architecture.