@Override
  public List<StreamSpec> getIntermediateStreams() {
    return getIntermediateStreamEdges().stream()
        .map(StreamEdge::getStreamSpec)
        .collect(Collectors.toList());
  }
The JobGraph is only constructed by the {@link ExecutionPlanner}.

@param config configuration for the application
@param appDesc {@link ApplicationDescriptorImpl} describing the application
samza-core/src/main/java/org/apache/samza/execution/JobGraph.java