/* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ // timeFormat: StreamingPage.scala will generate a global "timeFormat" dictionary to store the time // and its formatted string. Because we cannot specify a timezone in JavaScript, to make sure the // server and client use the same timezone, we use the "timeFormat" dictionary to format all time // values used in the graphs. // A global margin left for all timeline graphs. It will be set in "registerTimeline". This will be // used to align all timeline graphs. var maxMarginLeftForTimeline = 0; // The max X values for all histograms. It will be set in "registerHistogram". var maxXForHistogram = 0; var histogramBinCount = 10; var yValueFormat = d3.format(",.2f"); // Show a tooltip "text" for "node" function showBootstrapTooltip(node, text) { $(node).tooltip({title: text, trigger: "manual", container: "body"}); $(node).tooltip("show"); } // Hide the tooltip for "node" function hideBootstrapTooltip(node) { $(node).tooltip("destroy"); } // Register a timeline graph. All timeline graphs should be register before calling any // "drawTimeline" so that we can determine the max margin left for all timeline graphs. function registerTimeline(minY, maxY) { var numOfChars = yValueFormat(maxY).length; // A least width for "maxY" in the graph var pxForMaxY = numOfChars * 8 + 10; // Make sure we have enough space to show the ticks in the y axis of timeline maxMarginLeftForTimeline = pxForMaxY > maxMarginLeftForTimeline? pxForMaxY : maxMarginLeftForTimeline; } // Register a histogram graph. All histogram graphs should be register before calling any // "drawHistogram" so that we can determine the max X value for histograms. function registerHistogram(values, minY, maxY) { var data = d3.layout.histogram().range([minY, maxY]).bins(histogramBinCount)(values); // d.x is the y values while d.y is the x values var maxX = d3.max(data, function(d) { return d.y; }); maxXForHistogram = maxX > maxXForHistogram ? maxX : maxXForHistogram; } // Draw a line between (x1, y1) and (x2, y2) function drawLine(svg, xFunc, yFunc, x1, y1, x2, y2) { var line = d3.svg.line() .x(function(d) { return xFunc(d.x); }) .y(function(d) { return yFunc(d.y); }); var data = [{x: x1, y: y1}, {x: x2, y: y2}]; svg.append("path") .datum(data) .style("stroke-dasharray", ("6, 6")) .style("stroke", "lightblue") .attr("class", "line") .attr("d", line); } /** * @param id the `id` used in the html `div` tag * @param data the data for the timeline graph * @param minX the min value of X axis * @param maxX the max value of X axis * @param minY the min value of Y axis * @param maxY the max value of Y axis * @param unitY the unit of Y axis * @param batchInterval if "batchInterval" is specified, we will draw a line for "batchInterval" in the graph */ function drawTimeline(id, data, minX, maxX, minY, maxY, unitY, batchInterval) { // Hide the right border of "". We cannot use "css" directly, or "sorttable.js" will override them. d3.select(d3.select(id).node().parentNode) .style("padding", "8px 0 8px 8px") .style("border-right", "0px solid white"); var margin = {top: 20, right: 27, bottom: 30, left: maxMarginLeftForTimeline}; var width = 500 - margin.left - margin.right; var height = 150 - margin.top - margin.bottom; var x = d3.scale.linear().domain([minX, maxX]).range([0, width]); var y = d3.scale.linear().domain([minY, maxY]).range([height, 0]); var xAxis = d3.svg.axis().scale(x).orient("bottom").tickFormat(function(d) { var formattedDate = timeFormat[d]; var dotIndex = formattedDate.indexOf('.'); if (dotIndex >= 0) { // Remove milliseconds return formattedDate.substring(0, dotIndex); } else { return formattedDate; } }); var formatYValue = d3.format(",.2f"); var yAxis = d3.svg.axis().scale(y).orient("left").ticks(5).tickFormat(formatYValue); var line = d3.svg.line() .x(function(d) { return x(d.x); }) .y(function(d) { return y(d.y); }); var svg = d3.select(id).append("svg") .attr("width", width + margin.left + margin.right) .attr("height", height + margin.top + margin.bottom) .append("g") .attr("transform", "translate(" + margin.left + "," + margin.top + ")"); // Only show the first and last time in the graph xAxis.tickValues(x.domain()); svg.append("g") .attr("class", "x axis") .attr("transform", "translate(0," + height + ")") .call(xAxis) svg.append("g") .attr("class", "y axis") .call(yAxis) .append("text") .attr("transform", "translate(0," + (-3) + ")") .text(unitY); if (batchInterval && batchInterval <= maxY) { drawLine(svg, x, y, minX, batchInterval, maxX, batchInterval); } svg.append("path") .datum(data) .attr("class", "line") .attr("d", line); // Add points to the line. However, we make it invisible at first. But when the user moves mouse // over a point, it will be displayed with its detail. svg.selectAll(".point") .data(data) .enter().append("circle") .attr("stroke", "white") // white and opacity = 0 make it invisible .attr("fill", "white") .attr("opacity", "0") .attr("cx", function(d) { return x(d.x); }) .attr("cy", function(d) { return y(d.y); }) .attr("r", function(d) { return 3; }) .on('mouseover', function(d) { var tip = formatYValue(d.y) + " " + unitY + " at " + timeFormat[d.x]; showBootstrapTooltip(d3.select(this).node(), tip); // show the point d3.select(this) .attr("stroke", "steelblue") .attr("fill", "steelblue") .attr("opacity", "1"); }) .on('mouseout', function() { hideBootstrapTooltip(d3.select(this).node()); // hide the point d3.select(this) .attr("stroke", "white") .attr("fill", "white") .attr("opacity", "0"); }) .on("click", function(d) { window.location.href = "batch/?id=" + d.x; }); } /** * @param id the `id` used in the html `div` tag * @param values the data for the histogram graph * @param minY the min value of Y axis * @param maxY the max value of Y axis * @param unitY the unit of Y axis * @param batchInterval if "batchInterval" is specified, we will draw a line for "batchInterval" in the graph */ function drawHistogram(id, values, minY, maxY, unitY, batchInterval) { // Hide the left border of "". We cannot use "css" directly, or "sorttable.js" will override them. d3.select(d3.select(id).node().parentNode) .style("padding", "8px 8px 8px 0") .style("border-left", "0px solid white"); var margin = {top: 20, right: 30, bottom: 30, left: 10}; var width = 300 - margin.left - margin.right; var height = 150 - margin.top - margin.bottom; var x = d3.scale.linear().domain([0, maxXForHistogram]).range([0, width]); var y = d3.scale.linear().domain([minY, maxY]).range([height, 0]); var xAxis = d3.svg.axis().scale(x).orient("top").ticks(5); var yAxis = d3.svg.axis().scale(y).orient("left").ticks(0).tickFormat(function(d) { return ""; }); var data = d3.layout.histogram().range([minY, maxY]).bins(histogramBinCount)(values); var svg = d3.select(id).append("svg") .attr("width", width + margin.left + margin.right) .attr("height", height + margin.top + margin.bottom) .append("g") .attr("transform", "translate(" + margin.left + "," + margin.top + ")"); if (batchInterval && batchInterval <= maxY) { drawLine(svg, x, y, 0, batchInterval, maxXForHistogram, batchInterval); } svg.append("g") .attr("class", "x axis") .call(xAxis) svg.append("g") .attr("class", "y axis") .call(yAxis) var bar = svg.selectAll(".bar") .data(data) .enter() .append("g") .attr("transform", function(d) { return "translate(0," + (y(d.x) - height + y(d.dx)) + ")";}) .attr("class", "bar").append("rect") .attr("width", function(d) { return x(d.y); }) .attr("height", function(d) { return height - y(d.dx); }) .on('mouseover', function(d) { var percent = yValueFormat(d.y * 100.0 / values.length) + "%"; var tip = d.y + " batches (" + percent + ") between " + yValueFormat(d.x) + " and " + yValueFormat(d.x + d.dx) + " " + unitY; showBootstrapTooltip(d3.select(this).node(), tip); }) .on('mouseout', function() { hideBootstrapTooltip(d3.select(this).node()); }); if (batchInterval && batchInterval <= maxY) { // Add the "stable" text to the graph below the batch interval line. var stableXOffset = x(maxXForHistogram) - 20; var stableYOffset = y(batchInterval) + 15; svg.append("text") .style("fill", "lightblue") .attr("class", "stable-text") .attr("text-anchor", "middle") .attr("transform", "translate(" + stableXOffset + "," + stableYOffset + ")") .text("stable") .on('mouseover', function(d) { var tip = "Processing Time <= Batch Interval (" + yValueFormat(batchInterval) +" " + unitY +")"; showBootstrapTooltip(d3.select(this).node(), tip); }) .on('mouseout', function() { hideBootstrapTooltip(d3.select(this).node()); }); } } $(function() { var status = window.localStorage && window.localStorage.getItem("show-streams-detail") == "true"; $("span.expand-input-rate").click(function() { status = !status; $("#inputs-table").toggle('collapsed'); // Toggle the class of the arrow between open and closed $(this).find('.expand-input-rate-arrow').toggleClass('arrow-open').toggleClass('arrow-closed'); if (window.localStorage) { window.localStorage.setItem("show-streams-detail", "" + status); } }); if (status) { $("#inputs-table").toggle('collapsed'); // Toggle the class of the arrow between open and closed $(this).find('.expand-input-rate-arrow').toggleClass('arrow-open').toggleClass('arrow-closed'); } });