Well BatchID is from storehaus, but most of it is the use of futures in general, FlatMapOperation is just a chain series of flatmaps. Also the OnlinePlanner can live here, that takes the producer graph and turns it into the physical graph -- even if the physical graph description lives in core?