Function parseEdge

storm-webapp/src/main/webapp/js/visualization.js:317–346

(edgeJson, sourceId)

}

function parseEdge(edgeJson, sourceId) {
    //console.log(edgeJson);

    // Make this stream available
    addAvailableStream(edgeJson[":stream"], edgeJson[":sani-stream"])

    // Create a unique Id
    var id = edgeJson[":component"] + ":" + sourceId + ":" + edgeJson[":sani-stream"];

    // Determine if stream is enabled
    if (!isStreamEnabled(edgeJson[":sani-stream"])) {
        // Remove edge
        visNS.edges.remove({ "id": id });
        return
    }

    if (!visNS.edges.get(id)) {
        visNS.edges.update({
            "id": id,
            "from": edgeJson[":component"],
            "to": sourceId,
            "label": edgeJson[":stream"],
            "title": tooltipElement([
                { text: "From: " + edgeJson[":component"] },
                { text: "To: " + sourceId },
                { text: "Grouping: " + edgeJson[":grouping"] }
            ])
        });
    }
}

function addAvailableStream(streamId, streamIdSanitized) {
    // Create a master list of all streams