refine streaming in executeAsStream