private static void analyzeHadoopCluster(){
  try {
    JobConf job=ConfigurationManager.getCachedJobConf();
    JobClient client=new JobClient(job);
    ClusterStatus stat=client.getClusterStatus();
    if (stat != null) {
      _remotePar=stat.getTaskTrackers();
      _remoteParMap=stat.getMaxMapTasks();
      _remoteParReduce=stat.getMaxReduceTasks();
      analyzeHadoopConfiguration();
    }
  }
 catch (  IOException e) {
    throw new RuntimeException("Unable to analyze infrastructure.",e);
  }
}

private static void analyzeHadoopCluster ( ) { try { JobConf job = ConfigurationManager . getCachedJobConf ( ) ; JobClient client = new JobClient ( job ) ; ClusterStatus stat = client . getClusterStatus ( ) ; if ( stat != null ) { _remotePar = stat . getTaskTrackers ( ) ; _remoteParMap = stat . getMaxMapTasks ( ) ; _remoteParReduce = stat . getMaxReduceTasks ( ) ; analyzeHadoopConfiguration ( ) ; } } catch ( IOException e ) { throw new RuntimeException ( "Unable to analyze infrastructure." , e ) ; } }
analyzes properties of hadoop cluster and configuration .
