respect createQuery limit in DirectStreamer