源码类别
热门源码
 当前位置：源码 > Java源码 >

Java源码示例：org.apache.hadoop.mapreduce.TaskTrackerInfo

示例1
public TaskTrackerInfo[] getActiveTrackers() throws IOException,
    InterruptedException {
  try {
    return TypeConverter.fromYarnNodes(
        client.getNodeReports(NodeState.RUNNING));
  } catch (YarnException e) {
    throw new IOException(e);
  }
}
示例2
private  Collection<String> arrayToStringList(TaskTrackerInfo[] objs) {
  Collection<String> list = new ArrayList<String>();
  for (TaskTrackerInfo info: objs) {
    list.add(info.getTaskTrackerName());
  }
  return list;
}
示例3
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;
}
示例4
/**
 * 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());
  }
}
示例5
/**
 * 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());
  }
}
示例6
public TaskTrackerInfo[] getActiveTrackers() throws IOException,
    InterruptedException {
  try {
    return TypeConverter.fromYarnNodes(
        client.getNodeReports(NodeState.RUNNING));
  } catch (YarnException e) {
    throw new IOException(e);
  }
}
示例7
private  Collection<String> arrayToStringList(TaskTrackerInfo[] objs) {
  Collection<String> list = new ArrayList<String>();
  for (TaskTrackerInfo info: objs) {
    list.add(info.getTaskTrackerName());
  }
  return list;
}
示例8
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;
}
示例9
/**
 * 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());
  }
}
示例10
/**
 * 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());
  }
}
示例11
public TaskTrackerInfo[] getActiveTrackers() throws IOException,
    InterruptedException {
  try {
    return TypeConverter.fromYarnNodes(client.getNodeReports());
  } catch (YarnException e) {
    throw new IOException(e);
  }
}
示例12
public TaskTrackerInfo[] getActiveTrackers() throws IOException,
    InterruptedException {
  try {
    return TypeConverter.fromYarnNodes(client.getNodeReports());
  } catch (YarnException e) {
    throw new IOException(e);
  }
}
示例13
public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException,
    InterruptedException {
  // TODO: Implement getBlacklistedTrackers
  LOG.warn("getBlacklistedTrackers - Not implemented yet");
  return new TaskTrackerInfo[0];
}
示例14
@Override
public TaskTrackerInfo[] getActiveTrackers() throws IOException,
    InterruptedException {
  return resMgrDelegate.getActiveTrackers();
}
示例15
@Override
public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException,
    InterruptedException {
  return resMgrDelegate.getBlacklistedTrackers();
}
示例16
/** 
 * Get all active trackers in cluster. 
 * @return array of TaskTrackerInfo
 */
public TaskTrackerInfo[] getActiveTrackers() 
    throws IOException, InterruptedException {
  return new TaskTrackerInfo[0];
}
示例17
/** 
 * Get all blacklisted trackers in cluster. 
 * @return array of TaskTrackerInfo
 */
public TaskTrackerInfo[] getBlacklistedTrackers() 
    throws IOException, InterruptedException {
  return new TaskTrackerInfo[0];
}
示例18
public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException,
    InterruptedException {
  // TODO: Implement getBlacklistedTrackers
  LOG.warn("getBlacklistedTrackers - Not implemented yet");
  return new TaskTrackerInfo[0];
}
示例19
@Override
public TaskTrackerInfo[] getActiveTrackers() throws IOException,
    InterruptedException {
  return resMgrDelegate.getActiveTrackers();
}
示例20
@Override
public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException,
    InterruptedException {
  return resMgrDelegate.getBlacklistedTrackers();
}
示例21
/** 
 * Get all active trackers in cluster. 
 * @return array of TaskTrackerInfo
 */
public TaskTrackerInfo[] getActiveTrackers() 
    throws IOException, InterruptedException {
  return new TaskTrackerInfo[0];
}
示例22
/** 
 * Get all blacklisted trackers in cluster. 
 * @return array of TaskTrackerInfo
 */
public TaskTrackerInfo[] getBlacklistedTrackers() 
    throws IOException, InterruptedException {
  return new TaskTrackerInfo[0];
}
示例23
/** {@inheritDoc} */
@Override public TaskTrackerInfo[] getActiveTrackers() throws IOException, InterruptedException {
    return new TaskTrackerInfo[0];
}
示例24
/** {@inheritDoc} */
@Override public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException, InterruptedException {
    return new TaskTrackerInfo[0];
}
示例25
@Override
public TaskTrackerInfo[] getActiveTrackers() throws IOException,
    InterruptedException {
  throw new UnsupportedOperationException();
}
示例26
@Override
public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException,
    InterruptedException {
  throw new UnsupportedOperationException();
}
示例27
public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException,
    InterruptedException {
  // TODO: Implement getBlacklistedTrackers
  LOG.warn("getBlacklistedTrackers - Not implemented yet");
  return new TaskTrackerInfo[0];
}
示例28
@Override
public TaskTrackerInfo[] getActiveTrackers() throws IOException,
    InterruptedException {
  return resMgrDelegate.getActiveTrackers();
}
示例29
@Override
public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException,
    InterruptedException {
  return resMgrDelegate.getBlacklistedTrackers();
}
示例30
public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException,
    InterruptedException {
  // TODO: Implement getBlacklistedTrackers
  LOG.warn("getBlacklistedTrackers - Not implemented yet");
  return new TaskTrackerInfo[0];
}