<%@ page contentType="text/html; charset=UTF-8" import="javax.servlet.*" import="javax.servlet.http.*" import="java.io.*" import="java.util.*" import="java.text.DecimalFormat" import="org.apache.hama.bsp.*" import="org.apache.hama.util.*"%> <%!private static final long serialVersionUID = 1L;%> <% BSPMaster tracker = (BSPMaster) application .getAttribute("bsp.master"); ClusterStatus status = tracker.getClusterStatus(true); String trackerName = tracker.getBSPMasterName(); JobStatus[] runningJobs = tracker.jobsToComplete(); JobStatus[] allJobs = tracker.getAllJobs(); %> <%!private static DecimalFormat percentFormat = new DecimalFormat("##0.00"); public void generateSummaryTable(JspWriter out, ClusterStatus status, BSPMaster tracker) throws IOException { String tasksPerNode = status.getGroomServers() > 0 ? percentFormat .format(((double) (status.getMaxTasks()) / status .getGroomServers())) : "-"; out.print("\n" + "" + "" + "" + "\n"); out.print("
Groom ServersBSP Task CapacityAvg. Tasks/NodeBlacklisted Nodes
" + status.getActiveGroomNames().size() + "" + status.getMaxTasks() + "" + tasksPerNode + "" + 0 + "" + "
\n"); out.print("
"); }%> <%=trackerName%> Hama BSP Administration

<%=trackerName%> Hama BSP Administration



Cluster Summary

<% generateSummaryTable(out, status, tracker); %>

Running Jobs

<%=BSPServletUtil.generateJobTable("Running", runningJobs, 30, 0)%>

All Jobs History

<%=BSPServletUtil.generateJobTable("All", allJobs, 30, 0)%>


Local Logs

Log directory <% out.println(BSPServletUtil.htmlFooter()); %>