import storm.trident.util.IndexedEdge; //导入依赖的package包/类
protected void registerSourcedNode(List<Stream> sources, Node newNode) {
    registerNode(newNode);
    int streamIndex = 0;
    for(Stream s: sources) {
        _graph.addEdge(s._node, newNode, new IndexedEdge(s._node, newNode, streamIndex));
        streamIndex++;
    }        
}
 

import storm.trident.util.IndexedEdge; //导入依赖的package包/类
private static void addEdge(DirectedGraph g, Object source, Object target, int index) {
    g.addEdge(source, target, new IndexedEdge(source, target, index));
}
 

import storm.trident.util.IndexedEdge; //导入依赖的package包/类
public GraphGrouper(DirectedGraph<Node, IndexedEdge> graph, Collection<Group> initialGroups) {
    this.graph = graph;
    this.currGroups = new LinkedHashSet<>(initialGroups);
    reindex();
}
 

import storm.trident.util.IndexedEdge; //导入依赖的package包/类
public GraphGrouper(DirectedGraph<Node, IndexedEdge> graph, Collection<Group> initialGroups) {
    this.graph = graph;
    this.currGroups = new HashSet(initialGroups);
    reindex();      
}
 

import storm.trident.util.IndexedEdge; //导入依赖的package包/类
private TridentTopology(DefaultDirectedGraph<Node, IndexedEdge> graph, Map<String, List<Node>> colocate, UniqueIdGen gen) {
    _graph = graph;
    _colocate = colocate;
    _gen = gen;
}
 

import storm.trident.util.IndexedEdge; //导入依赖的package包/类
public GraphGrouper(DirectedGraph<Node, IndexedEdge> graph, Collection<Group> initialGroups) {
    this.graph = graph;
    this.currGroups = new HashSet(initialGroups);
    reindex();
}
 

import storm.trident.util.IndexedEdge; //导入依赖的package包/类
public TridentTopology() {
    this(new DefaultDirectedGraph<Node, IndexedEdge>(new ErrorEdgeFactory()),
            new LinkedHashMap<String, List<Node>>(),
            new UniqueIdGen());
}