merge conflict
remove Pipeline and related objects
move emit callbacks to core.js, add ingest callback hook
convert existing objects and tests to use streams
dayCountRankerBolt gets batch constructor and more robust key checking