org.apache.hadoop.mapreduce.TaskTrackerInfo源码实例Demo

类org.apache.hadoop.mapreduce.TaskTrackerInfo源码实例Demo

下面列出了org.apache.hadoop.mapreduce.TaskTrackerInfo 类实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。

源代码1 项目: hadoop   文件: ResourceMgrDelegate.java
public TaskTrackerInfo[] getActiveTrackers() throws IOException,
    InterruptedException {
  try {
    return TypeConverter.fromYarnNodes(
        client.getNodeReports(NodeState.RUNNING));
  } catch (YarnException e) {
    throw new IOException(e);
  }
}
 
源代码2 项目: hadoop   文件: JobClient.java
private  Collection<String> arrayToStringList(TaskTrackerInfo[] objs) {
  Collection<String> list = new ArrayList<String>();
  for (TaskTrackerInfo info: objs) {
    list.add(info.getTaskTrackerName());
  }
  return list;
}
 
源代码3 项目: hadoop   文件: JobClient.java
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 项目: hadoop   文件: CLI.java
/**
 * 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 项目: hadoop   文件: CLI.java
/**
 * 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 项目: big-c   文件: ResourceMgrDelegate.java
public TaskTrackerInfo[] getActiveTrackers() throws IOException,
    InterruptedException {
  try {
    return TypeConverter.fromYarnNodes(
        client.getNodeReports(NodeState.RUNNING));
  } catch (YarnException e) {
    throw new IOException(e);
  }
}
 
源代码7 项目: big-c   文件: JobClient.java
private  Collection<String> arrayToStringList(TaskTrackerInfo[] objs) {
  Collection<String> list = new ArrayList<String>();
  for (TaskTrackerInfo info: objs) {
    list.add(info.getTaskTrackerName());
  }
  return list;
}
 
源代码8 项目: big-c   文件: JobClient.java
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 项目: big-c   文件: CLI.java
/**
 * 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 项目: big-c   文件: CLI.java
/**
 * 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 项目: incubator-tez   文件: ResourceMgrDelegate.java
public TaskTrackerInfo[] getActiveTrackers() throws IOException,
    InterruptedException {
  try {
    return TypeConverter.fromYarnNodes(client.getNodeReports());
  } catch (YarnException e) {
    throw new IOException(e);
  }
}
 
源代码12 项目: tez   文件: ResourceMgrDelegate.java
public TaskTrackerInfo[] getActiveTrackers() throws IOException,
    InterruptedException {
  try {
    return TypeConverter.fromYarnNodes(client.getNodeReports());
  } catch (YarnException e) {
    throw new IOException(e);
  }
}
 
源代码13 项目: hadoop   文件: ResourceMgrDelegate.java
public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException,
    InterruptedException {
  // TODO: Implement getBlacklistedTrackers
  LOG.warn("getBlacklistedTrackers - Not implemented yet");
  return new TaskTrackerInfo[0];
}
 
源代码14 项目: hadoop   文件: YARNRunner.java
@Override
public TaskTrackerInfo[] getActiveTrackers() throws IOException,
    InterruptedException {
  return resMgrDelegate.getActiveTrackers();
}
 
源代码15 项目: hadoop   文件: YARNRunner.java
@Override
public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException,
    InterruptedException {
  return resMgrDelegate.getBlacklistedTrackers();
}
 
源代码16 项目: hadoop   文件: LocalJobRunner.java
/** 
 * Get all active trackers in cluster. 
 * @return array of TaskTrackerInfo
 */
public TaskTrackerInfo[] getActiveTrackers() 
    throws IOException, InterruptedException {
  return new TaskTrackerInfo[0];
}
 
源代码17 项目: hadoop   文件: LocalJobRunner.java
/** 
 * Get all blacklisted trackers in cluster. 
 * @return array of TaskTrackerInfo
 */
public TaskTrackerInfo[] getBlacklistedTrackers() 
    throws IOException, InterruptedException {
  return new TaskTrackerInfo[0];
}
 
源代码18 项目: big-c   文件: ResourceMgrDelegate.java
public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException,
    InterruptedException {
  // TODO: Implement getBlacklistedTrackers
  LOG.warn("getBlacklistedTrackers - Not implemented yet");
  return new TaskTrackerInfo[0];
}
 
源代码19 项目: big-c   文件: YARNRunner.java
@Override
public TaskTrackerInfo[] getActiveTrackers() throws IOException,
    InterruptedException {
  return resMgrDelegate.getActiveTrackers();
}
 
源代码20 项目: big-c   文件: YARNRunner.java
@Override
public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException,
    InterruptedException {
  return resMgrDelegate.getBlacklistedTrackers();
}
 
源代码21 项目: big-c   文件: LocalJobRunner.java
/** 
 * Get all active trackers in cluster. 
 * @return array of TaskTrackerInfo
 */
public TaskTrackerInfo[] getActiveTrackers() 
    throws IOException, InterruptedException {
  return new TaskTrackerInfo[0];
}
 
源代码22 项目: big-c   文件: LocalJobRunner.java
/** 
 * Get all blacklisted trackers in cluster. 
 * @return array of TaskTrackerInfo
 */
public TaskTrackerInfo[] getBlacklistedTrackers() 
    throws IOException, InterruptedException {
  return new TaskTrackerInfo[0];
}
 
源代码23 项目: ignite   文件: HadoopClientProtocol.java
/** {@inheritDoc} */
@Override public TaskTrackerInfo[] getActiveTrackers() throws IOException, InterruptedException {
    return new TaskTrackerInfo[0];
}
 
源代码24 项目: ignite   文件: HadoopClientProtocol.java
/** {@inheritDoc} */
@Override public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException, InterruptedException {
    return new TaskTrackerInfo[0];
}
 
源代码25 项目: RDFS   文件: MockSimulatorJobTracker.java
@Override
public TaskTrackerInfo[] getActiveTrackers() throws IOException,
    InterruptedException {
  throw new UnsupportedOperationException();
}
 
源代码26 项目: RDFS   文件: MockSimulatorJobTracker.java
@Override
public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException,
    InterruptedException {
  throw new UnsupportedOperationException();
}
 
源代码27 项目: incubator-tez   文件: ResourceMgrDelegate.java
public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException,
    InterruptedException {
  // TODO: Implement getBlacklistedTrackers
  LOG.warn("getBlacklistedTrackers - Not implemented yet");
  return new TaskTrackerInfo[0];
}
 
源代码28 项目: incubator-tez   文件: YARNRunner.java
@Override
public TaskTrackerInfo[] getActiveTrackers() throws IOException,
    InterruptedException {
  return resMgrDelegate.getActiveTrackers();
}
 
源代码29 项目: incubator-tez   文件: YARNRunner.java
@Override
public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException,
    InterruptedException {
  return resMgrDelegate.getBlacklistedTrackers();
}
 
源代码30 项目: tez   文件: ResourceMgrDelegate.java
public TaskTrackerInfo[] getBlacklistedTrackers() throws IOException,
    InterruptedException {
  // TODO: Implement getBlacklistedTrackers
  LOG.warn("getBlacklistedTrackers - Not implemented yet");
  return new TaskTrackerInfo[0];
}
 
源代码评论
动弹
沙发等你来抢
 类方法
 同包方法