Hadoop学习笔记4：【org.apache.hadoop.util】包文件解析

红太狼 2022-10-02 05:00 141阅读 0赞

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][]

Hadoop 【org.apache.hadoop.util】包文件说明
    
    1.Daemon 【类】
    
    public class Daemon extends Thread 
    {
       {
    　　 注意：这里有一行静态代码，总是设置线程为守护线程。
       }
    
    　　成员变量：
    　　Runnable runnable = null;
    　　
    　　函数变量：
       
      public Daemon() 
      {
    　　　什么都不做  
      }
    
      public Daemon(Runnable runnable) 
      {
    　　　将runnable传给父类Thread;
    　　　将本地runnable指向参数runnable.
    　　　设置线程名字为runnable.toString()
      }
    
      public Runnable getRunnable() 
      {
        获取本地的runnable 变量。
      }
    }
    
    
    
    2 
    
    
    2 LogFormatter【类】
    日志类不建议过多关注，非系统核心功能。
    public class LogFormatter extends Formatter 
    {
    　　成员变量：
      private static final String FORMAT = "yyMMdd HHmmss";
      private static final String NEWLINE 
    　　= 	System.getProperty("line.separator");
      private final Date date = new Date();
      private final SimpleDateFormat formatter 
    　　   = new SimpleDateFormat(FORMAT);
      private static boolean loggedSevere= false;
      private static boolean showTime = true;
      private static boolean showThreadIDs = false;
    
    
    函数变量：
     public static Logger getLogger(String name) 
     {
    　　通过工厂模式获得一个日志记录对象。
     }
    
    
      public static void showTime(boolean showTime) 
      {
         1 本函数为静态函数
    　　  2 设置LogFormatter类的静态变量showTime.
      }
    
      public static void setShowThreadIDs(boolean showThreadIDs) 
      {
        1 本函数为静态函数
        2 设置LogFormatter类的静态变量showThreadIDs 
      }
    
     
      public static boolean hasLoggedSevere() 
      {
        1 本函数为静态函数
        2 返回静态变量loggedSevere
      }
    　　
    
    
    
    　　public synchronized String format(LogRecord record) 
    　　{
    　　1 普通方法，意味着要生成一个对象才能调用。
    　　2 返回的字符串根据以下规则生成：
    　　  2.1）需要显示时间，则显示当前时间。
    　　  2.2）需要显示线程ID,则显示线程ID。
    　　  2.3）如果是严重的消息，就显示严重并设置全局静态变量loggedSevere为true.
    　　  2.4) 显示record对应的消息。
    　　  2.5）如果record.getThrown()存在，则继续打印这个对象的相应消息。
    　　  
    　　}
    　　
        Public static PrintStream getLogStream
    　　(final Logger logger,final Level level)
    　　{
    　　返回一个自定义的PrintStream.
    　　细节不用去深究，日志类，不涉及系统核心功能。
    　　}
    }
    
    
    3 PrintJarMainClass 【类】
    public class PrintJarMainClass
    {
    　　函数成员：
    　　public static void main(String[] args) 
    　　{
    　　打印一个Jar包的主类名字。很简单。
    　　}
    }
    
    4 Progress【类】
    public class Progress 
    {
    　　成员变量：
      private String status = "";
      private float progress;
      private int currentPhase;
      private ArrayList phases = new ArrayList();
      private Progress parent;
      private float progressPerPhase;
    
    函数变量：
      public Progress() 
      {
    　　 什么都不做。
      }
    
      public Progress addPhase() 
      {
    　　　1-先生成一个Progress节点。
    　　　2 加入到phases列表中，并设置新节点的parent为当前this.
    　　　 这样构成了父子关系映射。
    　　　3 由于phases列表更新了，所以相应重新设置progressPerPhase,实际上也就		是如果一个子节点完成了，相应的进度增加多少。
    　　　 	比如 如果有10个子节点,则每个节点完成则进度增加10%
    　　　        如果有 5个子节点,则每个节点完成则进度增加20%    
    　　　4 最终返回新生成的节点。
      }
    
    public Progress addPhase(String status) 
      {
        1 新增一个计算子节点。
    　　　2设置这个新节点的status变量。 
    　　　最终返回新增子节点。
      }
    
    
     public void setStatus(String status) 
     {
        设置本地status变量的setter方法。
     }
    
      public void set(float progress) 
      {
    　　设置当前节点的进度progress的setter 方法。
      }
    
      
    
      public void startNextPhase() 
      {
    　　　currentPhase增加1，很简单。
      }
    
      public Progress phase() 
      {
        返回当前正在运行的子节点对象。
      }
    
      public void complete() 
      {
        通常是子节点调用。
    　　　1 设置当前进度为1,表示自己已经完成了任务。
    　　　2 如果自己还有父节点的话，则告知父节点请将父节点的currentPhase自	增1.
    　　　
    　　　相当于说”hey,man, 我已经完成了，你可以去让下一个节点工作了。”
        
      }
    
      private float getInternal() 
      {
    　　 返回当前节点的总的进度。
    　　 注意：一个树的组织的进度算法是如何计算的，就跟生活中的算法一样的。
      }
    
     
    
    
    
      public float get() 
      {
        计算当前节点所在的root树的全局进度。
      }
    
     private void toString(StringBuffer buffer) 
     {
       打印出从一个字符串，形式如：
      “a>b>c”
      其中a是当前节点的status名称，
          b是a节点中当前运行未完成子节点的名称
          c是b节点中当前运行未完成子节点的名称
     }
    
    　　public String toString() 
    　　{
    　　    打印出从一个字符串，形式如：
    　　  “a>b>c”
    　　  其中a是当前节点的status名称，
    　　      b是a节点中当前运行未完成子节点的名称
    　　      c是b节点中当前运行未完成子节点的名称
    　　
    　　}
    
    }

转载于:https://my.oschina.net/qiangzigege/blog/228771

[2019_Python_]: https://my.oschina.net/u/2663968/blog/3061697
[hot3.png]: /images/20220113/0498608417b1417f9fad01a63c766d42.png