distributed streambenchwordcountagg