public TaskTrackerInfo[] getActiveTrackers() throws IOException,
    InterruptedException {
  try {
    return TypeConverter.fromYarnNodes(
        client.getNodeReports(NodeState.RUNNING));
  } catch (YarnException e) {
    throw new IOException(e);
  }
}
 

private  Collection<String> arrayToStringList(TaskTrackerInfo[] objs) {
  Collection<String> list = new ArrayList<String>();
  for (TaskTrackerInfo info: objs) {
    list.add(info.getTaskTrackerName());
  }
  return list;
}
 

private  Collection<BlackListInfo> arrayToBlackListInfo(TaskTrackerInfo[] objs) {
  Collection<BlackListInfo> list = new ArrayList<BlackListInfo>();
  for (TaskTrackerInfo info: objs) {
    BlackListInfo binfo = new BlackListInfo();
    binfo.setTrackerName(info.getTaskTrackerName());
    binfo.setReasonForBlackListing(info.getReasonForBlacklist());
    binfo.setBlackListReport(info.getBlacklistReport());
    list.add(binfo);
  }
  return list;
}
 

/**
 * Display the list of active trackers
 */
private void listActiveTrackers(Cluster cluster) 
    throws IOException, InterruptedException {
  TaskTrackerInfo[] trackers = cluster.getActiveTaskTrackers();
  for (TaskTrackerInfo tracker : trackers) {
    System.out.println(tracker.getTaskTrackerName());
  }
}
 

/**
 * Display the list of blacklisted trackers
 */
private void listBlacklistedTrackers(Cluster cluster) 
    throws IOException, InterruptedException {
  TaskTrackerInfo[] trackers = cluster.getBlackListedTaskTrackers();
  if (trackers.length > 0) {
    System.out.println("BlackListedNode \t Reason");
  }
  for (TaskTrackerInfo tracker : trackers) {
    System.out.println(tracker.getTaskTrackerName() + "\t" + 
      tracker.getReasonForBlacklist());
  }
}
 

public TaskTrackerInfo[] getActiveTrackers() throws IOException,
    InterruptedException {
  try {
    return TypeConverter.fromYarnNodes(
        client.getNodeReports(NodeState.RUNNING));
  } catch (YarnException e) {
    throw new IOException(e);
  }
}
 

private  Collection<String> arrayToStringList(TaskTrackerInfo[] objs) {
  Collection<String> list = new ArrayList<String>();
  for (TaskTrackerInfo info: objs) {
    list.add(info.getTaskTrackerName());
  }
  return list;
}
 

private  Collection<BlackListInfo> arrayToBlackListInfo(TaskTrackerInfo[] objs) {
  Collection<BlackListInfo> list = new ArrayList<BlackListInfo>();
  for (TaskTrackerInfo info: objs) {
    BlackListInfo binfo = new BlackListInfo();
    binfo.setTrackerName(info.getTaskTrackerName());
    binfo.setReasonForBlackListing(info.getReasonForBlacklist());
    binfo.setBlackListReport(info.getBlacklistReport());
    list.add(binfo);
  }
  return list;
}
 

/**
 * Display the list of active trackers
 */
private void listActiveTrackers(Cluster cluster) 
    throws IOException, InterruptedException {
  TaskTrackerInfo[] trackers = cluster.getActiveTaskTrackers();
  for (TaskTrackerInfo tracker : trackers) {
    System.out.println(tracker.getTaskTrackerName());
  }
}
 

/**
 * Display the list of blacklisted trackers
 */
private void listBlacklistedTrackers(Cluster cluster) 
    throws IOException, InterruptedException {
  TaskTrackerInfo[] trackers = cluster.getBlackListedTaskTrackers();
  if (trackers.length > 0) {
    System.out.println("BlackListedNode \t Reason");
  }
  for (TaskTrackerInfo tracker : trackers) {
    System.out.println(tracker.getTaskTrackerName() + "\t" + 
      tracker.getReasonForBlacklist());
  }
}
 

public TaskTrackerInfo[] getActiveTrackers() throws IOException,
    InterruptedException {
  try {
    return TypeConverter.fromYarnNodes(client.getNodeReports());
  } catch (YarnException e) {
    throw new IOException(e);
  }
}
 

public TaskTrackerInfo[] getActiveTrackers() throws IOException,
    InterruptedException {
  try {
    return TypeConverter.fromYarnNodes(client.getNodeReports());
  } catch (YarnException e) {
    throw new IOException(e);
  }
}
 

public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException,
    InterruptedException {
  // TODO: Implement getBlacklistedTrackers
  LOG.warn("getBlacklistedTrackers - Not implemented yet");
  return new TaskTrackerInfo[0];
}
 

@Override
public TaskTrackerInfo[] getActiveTrackers() throws IOException,
    InterruptedException {
  return resMgrDelegate.getActiveTrackers();
}
 

@Override
public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException,
    InterruptedException {
  return resMgrDelegate.getBlacklistedTrackers();
}
 

/** 
 * Get all active trackers in cluster. 
 * @return array of TaskTrackerInfo
 */
public TaskTrackerInfo[] getActiveTrackers() 
    throws IOException, InterruptedException {
  return new TaskTrackerInfo[0];
}
 

/** 
 * Get all blacklisted trackers in cluster. 
 * @return array of TaskTrackerInfo
 */
public TaskTrackerInfo[] getBlacklistedTrackers() 
    throws IOException, InterruptedException {
  return new TaskTrackerInfo[0];
}
 

public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException,
    InterruptedException {
  // TODO: Implement getBlacklistedTrackers
  LOG.warn("getBlacklistedTrackers - Not implemented yet");
  return new TaskTrackerInfo[0];
}
 

@Override
public TaskTrackerInfo[] getActiveTrackers() throws IOException,
    InterruptedException {
  return resMgrDelegate.getActiveTrackers();
}
 

@Override
public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException,
    InterruptedException {
  return resMgrDelegate.getBlacklistedTrackers();
}
 

/** 
 * Get all active trackers in cluster. 
 * @return array of TaskTrackerInfo
 */
public TaskTrackerInfo[] getActiveTrackers() 
    throws IOException, InterruptedException {
  return new TaskTrackerInfo[0];
}
 

/** 
 * Get all blacklisted trackers in cluster. 
 * @return array of TaskTrackerInfo
 */
public TaskTrackerInfo[] getBlacklistedTrackers() 
    throws IOException, InterruptedException {
  return new TaskTrackerInfo[0];
}
 

/** {@inheritDoc} */
@Override public TaskTrackerInfo[] getActiveTrackers() throws IOException, InterruptedException {
    return new TaskTrackerInfo[0];
}
 

/** {@inheritDoc} */
@Override public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException, InterruptedException {
    return new TaskTrackerInfo[0];
}
 

@Override
public TaskTrackerInfo[] getActiveTrackers() throws IOException,
    InterruptedException {
  throw new UnsupportedOperationException();
}
 

@Override
public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException,
    InterruptedException {
  throw new UnsupportedOperationException();
}
 

public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException,
    InterruptedException {
  // TODO: Implement getBlacklistedTrackers
  LOG.warn("getBlacklistedTrackers - Not implemented yet");
  return new TaskTrackerInfo[0];
}
 

@Override
public TaskTrackerInfo[] getActiveTrackers() throws IOException,
    InterruptedException {
  return resMgrDelegate.getActiveTrackers();
}
 

@Override
public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException,
    InterruptedException {
  return resMgrDelegate.getBlacklistedTrackers();
}
 

public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException,
    InterruptedException {
  // TODO: Implement getBlacklistedTrackers
  LOG.warn("getBlacklistedTrackers - Not implemented yet");
  return new TaskTrackerInfo[0];
}