Fairly horrible implementation of the data ingestor. However - this completes the basic implementation of the map/reduce query engine enough that the tests are green :-)

It's pretty inefficient to reduce in each event as it arrives, and there's a bunch of code repeated from the ProductAdmin class.