public static int[] getStreamingEvaluatorNums(VectorPTFEvaluatorBase[] evaluators) {
    final int evaluatorCount = evaluators.length;
    ArrayList<Integer> streamingEvaluatorNums = new ArrayList<Integer>();
    for (int i = 0; i < evaluatorCount; i++) {
      final VectorPTFEvaluatorBase evaluator = evaluators[i];
      if (evaluator.streamsResult()) {
        streamingEvaluatorNums.add(i);
      }
    }
    return ArrayUtils.toPrimitive(streamingEvaluatorNums.toArray(new Integer[0]));
  }
VectorPTFDesc.

Extra parameters beyond PTFDesc just for the VectorPTFOperator.

We don't extend PTFDesc because the base OperatorDesc doesn't support
clone and adding it is a lot work for little gain.
ql/src/java/org/apache/hadoop/hive/ql/plan/VectorPTFDesc.java