sendEdgeAdded(graphId, time, edgeId, fromNodeId, toNodeId, directed);
}
}
public void nodeAdded(String graphId, long time, String nodeId) {
if (sinkTime.isNewEvent(graphId, time)) {
<BUG>addNode(graphId, nodeId);
sendNodeAdded(graphId, time, nodeId);</BUG>
}
}
public void edgeRemoved(String graphId, long time, String edgeId) {

sendEdgeAdded(graphId, time, edgeId, fromNodeId, toNodeId, directed);
}
}
public void nodeAdded(String graphId, long time, String nodeId) {
if (sinkTime.isNewEvent(graphId, time)) {
NodeParticle np = addNode(graphId, nodeId);
sendNodeAdded(graphId, time, nodeId);
}
}
public void edgeRemoved(String graphId, long time, String edgeId) {
