now query/queryAggregate can be re-run as stream, added type parameter for query to avoid scala.Any via set type, pimp-map conversion is completed, null check for IndexTask