[scala] [streaming] Modified aggregations to work on scala tuples