private void findReachableOperators(Collection<OperatorSpec> inputOperatorsInJobNode,
      Set<OperatorSpec> reachableOperators) {
    inputOperatorsInJobNode.forEach(op -> {
      if (reachableOperators.contains(op)) {
        return;
      }
      reachableOperators.add(op);
      findReachableOperators(op.getRegisteredOperatorSpecs(), reachableOperators);
    });
  }
Generate the configs for a job
@param executionPlanJson JSON representation of the execution plan
@return config of the job
samza-core/src/main/java/org/apache/samza/execution/JobNode.java