Examples of ClusterStatus

com.alibaba.wasp.ClusterStatus
Status information on the Wasp cluster.
ClusterStatus provides clients with information such as:
- The count and names of fservers in the cluster.
- The count and names of dead fservers in the cluster.
- The name of the active master for the cluster.
- The name(s) of the backup master(s) for the cluster, if they exist.
- The average cluster load.
- The number of entity groups deployed on the cluster.
- The number of requests since last report.
- Detailed fserver loading and resource usage information, per server and per entityGroup.
- entityGroups in transition at master
- The unique cluster ID
com.vmware.bdd.apitypes.ClusterStatus
lcmc.crm.domain.ClusterStatus
This class parses pacemaker/heartbeat status, stores information in the hashes and provides methods to get this information.
org.apache.blur.manager.clusterstatus.ClusterStatus
org.apache.hadoop.hbase.ClusterStatus
Status information on the HBase cluster.
ClusterStatus provides clients with information such as:
- The count and names of region servers in the cluster.
- The count and names of dead region servers in the cluster.
- The name of the active master for the cluster.
- The name(s) of the backup master(s) for the cluster, if they exist.
- The average cluster load.
- The number of regions deployed on the cluster.
- The number of requests since last report.
- Detailed region server loading and resource usage information, per server and per region.
- Regions in transition at master
- The unique cluster ID
org.apache.hadoop.hdfs.server.namenode.ClusterJspHelper.ClusterStatus
org.apache.hadoop.mapred.ClusterStatus
Status information on the current state of the Map-Reduce cluster.
ClusterStatus provides clients with information such as:
1. Size of the cluster.
2. Name of the trackers.
3. Task capacity of the cluster.
4. The number of currently running map & reduce tasks.
5. State of the JobTracker.
Clients can query for the latest ClusterStatus, via {@link JobClient#getClusterStatus()}.
@see JobClient
org.apache.hama.bsp.ClusterStatus
Status information on the current state of the BSP cluster.
ClusterStatus provides clients with information such as:
1. Size of the cluster.
2. Name of the grooms.
3. Task capacity of the cluster.
4. The number of currently running bsp tasks.
5. State of the BSPMaster.
Clients can query for the latest ClusterStatus, via {@link BSPJobClient#getClusterStatus(boolean)}.
@see BSPMaster

Examples of org.apache.hadoop.mapred.ClusterStatus

      return printUsage();    
    }
    
    Configuration conf = getConf();
    JobClient client = new JobClient(conf);
    ClusterStatus cluster = client.getClusterStatus();
    int numMapsPerHost = conf.getInt(MAPS_PER_HOST, 10);
    long numBytesToWritePerMap = conf.getLong(BYTES_PER_MAP,
                                             1*1024*1024*1024);
    if (numBytesToWritePerMap == 0) {
      System.err.println("Cannot have " + BYTES_PER_MAP +" set to 0");
      return -2;
    }
    long totalBytesToWrite = conf.getLong(TOTAL_BYTES, 
         numMapsPerHost*numBytesToWritePerMap*cluster.getTaskTrackers());
    int numMaps = (int) (totalBytesToWrite / numBytesToWritePerMap);
    if (numMaps == 0 && totalBytesToWrite > 0) {
      numMaps = 1;
      conf.setLong(BYTES_PER_MAP, totalBytesToWrite);
    }

View Full Code Here

Examples of org.apache.hadoop.mapred.ClusterStatus


  /**
   * Return the status information about the Map-Reduce cluster
   */
  public ClusterStatus getClusterStatus() throws Exception {
    ClusterStatus cs;
    try {
      JobConf job = new JobConf(conf, ExecDriver.class);
      JobClient jc = new JobClient(job);
      cs = jc.getClusterStatus();
    } catch (Exception e) {
      e.printStackTrace();
      throw e;
    }
    LOG.info("Returning cluster status: " + cs.toString());
    return cs;
  }

View Full Code Here

Examples of org.apache.hama.bsp.ClusterStatus

    bsp.setOutputValueClass(DoubleWritable.class);
    bsp.setOutputFormat(TextOutputFormat.class);
    FileOutputFormat.setOutputPath(bsp, TMP_OUTPUT);


    BSPJobClient jobClient = new BSPJobClient(conf);
    ClusterStatus cluster = jobClient.getClusterStatus(true);


    if (args.length > 0) {
      bsp.setNumBspTask(Integer.parseInt(args[0]));
    } else {
      // Set to maximum
      bsp.setNumBspTask(cluster.getMaxTasks());
    }


    long startTime = System.currentTimeMillis();
    if (bsp.waitForCompletion(true)) {
      printOutput(conf);

View Full Code Here

Examples of org.apache.hama.bsp.ClusterStatus

    bsp.setInputFormat(NullInputFormat.class);
    bsp.setOutputFormat(NullOutputFormat.class);


    // Set the task size as a number of GroomServer
    BSPJobClient jobClient = new BSPJobClient(conf);
    ClusterStatus cluster = jobClient.getClusterStatus(false);
    bsp.setNumBspTask(cluster.getMaxTasks());


    long startTime = System.currentTimeMillis();
    if (bsp.waitForCompletion(true)) {
      System.out.println("Job Finished in "
          + (double) (System.currentTimeMillis() - startTime) / 1000.0

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.