I think we should leverage the emitter model and get rid of this dependency on RollupBatchWriter. So RollupBatchWriter would be a listener. What do you think?