<BUG>MapReduceManager mrManager = applicationManager.getMapReduceManager("BodyTracker");mrManager.start();</BUG><CONTEXT>streamManager.send(createEvent(schema, "AAPL", 5, 300.0f));streamManager.send(createEvent(schema, "AAPL", 3, 298.34f));streamManager.send(createEvent(schema, "AAPL", 50, 305.23f));streamManager.send(createEvent(schema, "AAPL", 1000, 284.13f));float aaplTotal = 5 * 300.0f + 3 * 298.34f + 50 * 305.23f + 1000 * 284.13f;<extra_id_0>mrManager.waitForFinish(180, TimeUnit.SECONDS);KeyValueTable pricesDS = (KeyValueTable) getDataset("prices").get();</CONTEXT>
MapReduceManager mrManager = applicationManager.getMapReduceManager("BodyTracker").start();