Set<String> getNextOperatorIds(String streamId) {
    if (!appDesc.getInputOperators().containsKey(streamId) || !inEdges.containsKey(streamId)) {
      return new HashSet<>();
    }
    return appDesc.getInputOperators().get(streamId).getRegisteredOperatorSpecs().stream()
        .map(op -> op.getOpId()).collect(Collectors.toSet());
  }
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