1. 包列表
  2. 类列表
  3. org.apache.hadoop.mapreduce.server.tasktracker.userlogs.UserLogManager

Java 类org.apache.hadoop.mapreduce.server.tasktracker.userlogs.UserLogManager 实例源码

项目：hadoop-2.6.0-cdh5.4.3    文件：TestJvmManager.java    
public TestJvmManager() throws Exception {
  user = UserGroupInformation.getCurrentUser().getShortUserName();
  tt = new TaskTracker();
  ttConf = new JobConf();
  ttConf.setLong("mapred.tasktracker.tasks.sleeptime-before-sigkill", 2000);
  tt.setConf(ttConf);
  tt.setMaxMapSlots(MAP_SLOTS);
  tt.setMaxReduceSlots(REDUCE_SLOTS);
  TaskController dtc;
  tt.setTaskController((dtc = new DefaultTaskController()));
  Configuration conf = new Configuration();
  dtc.setConf(conf);
  LocalDirAllocator ldirAlloc =
      new LocalDirAllocator(JobConf.MAPRED_LOCAL_DIR_PROPERTY);
  tt.getTaskController().setup(ldirAlloc, new LocalStorage(ttConf.getLocalDirs()));
  JobID jobId = new JobID("test", 0);
  jvmManager = new JvmManager(tt);
  tt.setJvmManagerInstance(jvmManager);
  tt.setUserLogManager(new UserLogManager(ttConf));
  tt.setCleanupThread(new InlineCleanupQueue());
}
项目：hadoop-on-lustre    文件：TestJvmManager.java    
public TestJvmManager() throws Exception {
  user = UserGroupInformation.getCurrentUser().getShortUserName();
  tt = new TaskTracker();
  ttConf = new JobConf();
  ttConf.setLong("mapred.tasktracker.tasks.sleeptime-before-sigkill", 2000);
  tt.setConf(ttConf);
  tt.setMaxMapSlots(MAP_SLOTS);
  tt.setMaxReduceSlots(REDUCE_SLOTS);
  TaskController dtc;
  tt.setTaskController((dtc = new DefaultTaskController()));
  Configuration conf = new Configuration();
  dtc.setConf(conf);
  LocalDirAllocator ldirAlloc =
      new LocalDirAllocator(JobConf.MAPRED_LOCAL_DIR_PROPERTY);
  tt.getTaskController().setup(ldirAlloc, new LocalStorage(ttConf.getLocalDirs()));
  JobID jobId = new JobID("test", 0);
  jvmManager = new JvmManager(tt);
  tt.setJvmManagerInstance(jvmManager);
  tt.setUserLogManager(new UserLogManager(ttConf));
  tt.setCleanupThread(new InlineCleanupQueue());
}
项目：hanoi-hadoop-2.0.0-cdh    文件：TestJvmManager.java    
public TestJvmManager() throws Exception {
  user = UserGroupInformation.getCurrentUser().getShortUserName();
  tt = new TaskTracker();
  ttConf = new JobConf();
  ttConf.setLong("mapred.tasktracker.tasks.sleeptime-before-sigkill", 2000);
  tt.setConf(ttConf);
  tt.setMaxMapSlots(MAP_SLOTS);
  tt.setMaxReduceSlots(REDUCE_SLOTS);
  TaskController dtc;
  tt.setTaskController((dtc = new DefaultTaskController()));
  Configuration conf = new Configuration();
  dtc.setConf(conf);
  LocalDirAllocator ldirAlloc =
      new LocalDirAllocator(JobConf.MAPRED_LOCAL_DIR_PROPERTY);
  tt.getTaskController().setup(ldirAlloc, new LocalStorage(ttConf.getLocalDirs()));
  JobID jobId = new JobID("test", 0);
  jvmManager = new JvmManager(tt);
  tt.setJvmManagerInstance(jvmManager);
  tt.setUserLogManager(new UserLogManager(ttConf));
  tt.setCleanupThread(new InlineCleanupQueue());
}
项目：hortonworks-extension    文件：TestJvmManager.java    
public TestJvmManager() throws Exception {
  user = UserGroupInformation.getCurrentUser().getShortUserName();
  tt = new TaskTracker();
  ttConf = new JobConf();
  ttConf.setLong("mapred.tasktracker.tasks.sleeptime-before-sigkill", 2000);
  tt.setConf(ttConf);
  tt.setMaxMapSlots(MAP_SLOTS);
  tt.setMaxReduceSlots(REDUCE_SLOTS);
  TaskController dtc;
  tt.setTaskController((dtc = new DefaultTaskController()));
  Configuration conf = new Configuration();
  dtc.setConf(conf);
  LocalDirAllocator ldirAlloc =
      new LocalDirAllocator(JobConf.MAPRED_LOCAL_DIR_PROPERTY);
  tt.getTaskController().setup(ldirAlloc, new LocalStorage(ttConf.getLocalDirs()));
  JobID jobId = new JobID("test", 0);
  jvmManager = new JvmManager(tt);
  tt.setJvmManagerInstance(jvmManager);
  tt.setUserLogManager(new UserLogManager(ttConf));
  tt.setCleanupThread(new InlineCleanupQueue());
}
项目：hortonworks-extension    文件：TestJvmManager.java    
public TestJvmManager() throws Exception {
  user = UserGroupInformation.getCurrentUser().getShortUserName();
  tt = new TaskTracker();
  ttConf = new JobConf();
  ttConf.setLong("mapred.tasktracker.tasks.sleeptime-before-sigkill", 2000);
  tt.setConf(ttConf);
  tt.setMaxMapSlots(MAP_SLOTS);
  tt.setMaxReduceSlots(REDUCE_SLOTS);
  TaskController dtc;
  tt.setTaskController((dtc = new DefaultTaskController()));
  Configuration conf = new Configuration();
  dtc.setConf(conf);
  LocalDirAllocator ldirAlloc =
      new LocalDirAllocator(JobConf.MAPRED_LOCAL_DIR_PROPERTY);
  tt.getTaskController().setup(ldirAlloc, new LocalStorage(ttConf.getLocalDirs()));
  JobID jobId = new JobID("test", 0);
  jvmManager = new JvmManager(tt);
  tt.setJvmManagerInstance(jvmManager);
  tt.setUserLogManager(new UserLogManager(ttConf));
  tt.setCleanupThread(new InlineCleanupQueue());
}
项目：hadoop-on-lustre    文件：TestTaskEnvironment.java    
public TestTaskEnvironment() throws Exception {
  tt = new TaskTracker();
  ttConf = new JobConf();
  ttConf.setLong("mapred.tasktracker.tasks.sleeptime-before-sigkill", 2000);
  tt.setConf(ttConf);
  tt.setMaxMapSlots(MAP_SLOTS);
  tt.setMaxReduceSlots(REDUCE_SLOTS);
  tt.setTaskController(new DefaultTaskController());
  jvmManager = new JvmManager(tt);
  tt.setJvmManagerInstance(jvmManager);
  tt.setUserLogManager(new UserLogManager(ttConf));
}
项目：hortonworks-extension    文件：TestTaskEnvironment.java    
public TestTaskEnvironment() throws Exception {
  tt = new TaskTracker();
  ttConf = new JobConf();
  ttConf.setLong("mapred.tasktracker.tasks.sleeptime-before-sigkill", 2000);
  tt.setConf(ttConf);
  tt.setMaxMapSlots(MAP_SLOTS);
  tt.setMaxReduceSlots(REDUCE_SLOTS);
  tt.setTaskController(new DefaultTaskController());
  jvmManager = new JvmManager(tt);
  tt.setJvmManagerInstance(jvmManager);
  tt.setUserLogManager(new UserLogManager(ttConf));
}
项目：hortonworks-extension    文件：TestTaskEnvironment.java    
public TestTaskEnvironment() throws Exception {
  tt = new TaskTracker();
  ttConf = new JobConf();
  ttConf.setLong("mapred.tasktracker.tasks.sleeptime-before-sigkill", 2000);
  tt.setConf(ttConf);
  tt.setMaxMapSlots(MAP_SLOTS);
  tt.setMaxReduceSlots(REDUCE_SLOTS);
  tt.setTaskController(new DefaultTaskController());
  jvmManager = new JvmManager(tt);
  tt.setJvmManagerInstance(jvmManager);
  tt.setUserLogManager(new UserLogManager(ttConf));
}