Set<StreamEdge> getInputStreams() {
    return Collections.unmodifiableSet(inputStreams);
  }
Returns the input streams in the graph
@return unmodifiable set of {@link StreamEdge}
samza-core/src/main/java/org/apache/samza/execution/JobGraph.java