Continuous query scheduler based on operators clustering