Does this not have the side effect that down stream partition is recalculated because it affects historical data? Would it not be better to honour event time with a delay window. Late arriving facts are easier to handle in batch than streaming but at some point the fact loses value because it arrives too late.