change bulk query to return record stream