Separated query processing into two streamlets