所有程序包的分层结构

程序包分层结构:

• com.github.panhongan.util,
• com.github.panhongan.util.collection,
• com.github.panhongan.util.conf,
• com.github.panhongan.util.control,
• com.github.panhongan.util.control.workflow,
• com.github.panhongan.util.dag,
• com.github.panhongan.util.db,
• com.github.panhongan.util.hadoop,
• com.github.panhongan.util.hash,
• com.github.panhongan.util.hive,
• com.github.panhongan.util.kafka,
• com.github.panhongan.util.mod,
• com.github.panhongan.util.path,
• com.github.panhongan.util.process,
• com.github.panhongan.util.sql,
• com.github.panhongan.util.thread,
• com.github.panhongan.util.uri,
• com.github.panhongan.util.web.page,
• com.github.panhongan.util.web.url,
• com.github.panhongan.util.zookeeper

类分层结构

• java.lang.Object
  • com.github.panhongan.util.kafka.AbstractMessageProcessor (implements com.github.panhongan.util.control.Lifecycleable)
    • com.github.panhongan.util.kafka.MessageConsoleWriter
    • com.github.panhongan.util.kafka.MessageKafkaWriter (implements com.github.panhongan.util.control.Lifecycleable)
    • com.github.panhongan.util.kafka.MessageLocalWriter
  • com.github.panhongan.util.collection.ArrayUtil
  • com.github.panhongan.util.hash.CityHash
  • com.github.panhongan.util.collection.CollectionUtil
  • com.github.panhongan.util.conf.Config (implements java.io.Serializable)
  • com.github.panhongan.util.control.workflow.Context
  • com.github.panhongan.util.dag.DAGTopo
  • com.github.panhongan.util.dag.Edge
  • org.apache.hadoop.mapred.FileOutputFormat<K,V> (implements org.apache.hadoop.mapred.OutputFormat<K,V>)
    • org.apache.hadoop.mapred.lib.MultipleOutputFormat<K,V>
      • org.apache.hadoop.mapred.lib.MultipleTextOutputFormat<K,V>
        • com.github.panhongan.util.hadoop.SuffixMultipleTextOutputFormat
  • com.github.panhongan.util.FileUtil
  • com.github.panhongan.util.kafka.HighLevelConsumer (implements java.lang.Runnable)
  • com.github.panhongan.util.kafka.HighLevelConsumerGroup (implements com.github.panhongan.util.control.Lifecycleable)
  • com.github.panhongan.util.hive.HiveSession
  • com.github.panhongan.util.hive.HiveUtil
  • com.github.panhongan.util.web.url.HTTPConstants
  • com.github.panhongan.util.web.url.HTTPConstants.Method
  • org.apache.hadoop.mapreduce.InputFormat<K,V>
    • org.apache.hadoop.mapreduce.lib.input.FileInputFormat<K,V>
      • org.apache.hadoop.mapreduce.lib.input.CombineFileInputFormat<K,V>
        • com.github.panhongan.util.hadoop.CombineSequenceFileInputFormat<K,V>
  • com.github.panhongan.util.db.JedisUtil
  • com.github.panhongan.util.kafka.KafkaExporter (implements com.github.panhongan.util.control.Lifecycleable)
  • com.github.panhongan.util.kafka.KafkaExporterConfig
  • com.github.panhongan.util.kafka.KafkaExporterService
  • com.github.panhongan.util.kafka.KafkaUtil
  • com.github.panhongan.util.hadoop.MapReduceTaskXmlParser
  • com.github.panhongan.util.mod.Mod
  • com.github.panhongan.util.db.MysqlSession
  • com.github.panhongan.util.db.MysqlUtil
  • com.github.panhongan.util.db.MysqlUtil.MysqlPool
  • com.github.panhongan.util.ObjectUtil
  • com.github.panhongan.util.OSType
  • com.github.panhongan.util.OSUtil
  • com.github.panhongan.util.Pair<First,Second>
  • org.apache.hadoop.mapreduce.Partitioner<KEY,VALUE>
    • com.github.panhongan.util.hadoop.FirstKeyIntPartitioner (implements org.apache.hadoop.mapred.Partitioner<K2,V2>)
  • com.github.panhongan.util.path.PathUtil
  • com.github.panhongan.util.web.url.QueryStringParser
  • org.apache.hadoop.mapreduce.RecordReader<KEYIN,VALUEIN> (implements java.io.Closeable)
    • com.github.panhongan.util.hadoop.CombineSequenceFileRecordReader<K,V>
  • com.github.panhongan.util.process.RuntimeUtil
  • com.github.panhongan.util.uri.ServerURI
  • com.github.panhongan.util.hash.SimpleHash
  • com.github.panhongan.util.hash.SimplePartitioner
  • com.github.panhongan.util.sql.SqlUtil
  • com.github.panhongan.util.StringUtil
  • java.lang.Thread (implements java.lang.Runnable)
    • com.github.panhongan.util.thread.ControllableThread (implements com.github.panhongan.util.control.Freezable, com.github.panhongan.util.control.Lifecycleable)
      • com.github.panhongan.util.zookeeper.PersistentWatcher (implements com.github.panhongan.util.zookeeper.SessionHoldable)
      • com.github.panhongan.util.zookeeper.ZookeeperSessionMonitor
    • com.github.panhongan.util.kafka.KafkaExporterShutdownHook
  • com.github.panhongan.util.thread.ThreadManager
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • com.github.panhongan.util.hadoop.InvalidSuffixMultipleTextOutputFormatException
      • com.github.panhongan.util.mod.ModException
      • com.github.panhongan.util.Value.ValueTypeException
  • com.github.panhongan.util.TimeUtil
  • com.github.panhongan.util.TimeUtil.TimeSection
  • com.github.panhongan.util.web.page.UrlWorkflow (implements com.github.panhongan.util.control.workflow.Workflowable)
  • com.github.panhongan.util.Value
  • com.github.panhongan.util.Value.ValueType
  • com.github.panhongan.util.dag.Vertex
  • com.github.panhongan.util.control.workflow.Workflow (implements com.github.panhongan.util.control.workflow.Workflowable)
  • com.github.panhongan.util.control.workflow.WorkflowNode (implements com.github.panhongan.util.control.workflow.Workflowable)
    • com.github.panhongan.util.web.page.AbstractOutputWriter
    • com.github.panhongan.util.web.page.AbstractWebPageParser
    • com.github.panhongan.util.web.page.Crawler
  • com.github.panhongan.util.control.workflow.WorkflowStage
  • com.github.panhongan.util.zookeeper.ZKUtil

接口分层结构

• com.github.panhongan.util.FileUtil.LineProcessor
• com.github.panhongan.util.control.Freezable
• com.github.panhongan.util.control.Lifecycleable
• com.github.panhongan.util.zookeeper.SessionExceptionProcessable
• com.github.panhongan.util.zookeeper.SessionHoldable
• com.github.panhongan.util.control.workflow.Workflowable
• com.github.panhongan.util.zookeeper.ZKEventPrcoessable