Major Description
Currently in StreamExecution, we first run the batch, then construct the next:
if (dataAvailable) runBatch()
constructNextBatch()
This is good if we run batches ASAP, where data would get processed in the very next batch:
However, if we run batches at trigger like ProcessTime("1 minute"), data - such as y below - may not get processed in the very next batch i.e. batch 1, but in batch 2:
