所有程序包的分层结构

程序包分层结构:

• 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.kafka.export,
• com.github.panhongan.util.kafka.handler,
• com.github.panhongan.util.mod,
• com.github.panhongan.util.path,
• com.github.panhongan.util.probability,
• com.github.panhongan.util.process,
• com.github.panhongan.util.sql,
• com.github.panhongan.util.thread,
• com.github.panhongan.util.uri,
• com.github.panhongan.util.url,
• 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.AbstractKafkaMessageProcessor (implements com.github.panhongan.util.control.Lifecycleable)
    • com.github.panhongan.util.kafka.handler.KafkaMessageWorkflow
    • 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.kafka.handler.AbstractMessageHandler (implements com.github.panhongan.util.control.Lifecycleable)
    • com.github.panhongan.util.kafka.export.DefaultMessageHandler
  • 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.IntegerCirculator
  • com.github.panhongan.util.db.JedisUtil
  • com.github.panhongan.util.kafka.export.KafkaExporter (implements com.github.panhongan.util.control.Lifecycleable)
  • com.github.panhongan.util.kafka.export.KafkaExporterConfig
  • com.github.panhongan.util.kafka.export.KafkaExporterService
  • com.github.panhongan.util.kafka.handler.KafkaMessageService (implements com.github.panhongan.util.control.Lifecycleable)
  • com.github.panhongan.util.kafka.handler.KafkaMessageServiceConfig
  • com.github.panhongan.util.kafka.KafkaProducerSendFailedCallback (implements org.apache.kafka.clients.producer.Callback)
  • 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.Optional<T>
  • com.github.panhongan.util.OSUtil
  • com.github.panhongan.util.OSUtil.OSType
  • 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.probability.ProbabilityMocker
  • 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
  • com.github.panhongan.util.TestArrayUtil
  • com.github.panhongan.util.hash.TestCityHash
  • com.github.panhongan.util.conf.TestConfig
  • com.github.panhongan.util.control.workflow.TestContext
  • com.github.panhongan.util.TestFileUtil
  • com.github.panhongan.util.TestFileUtil.TestLineProcessor (implements com.github.panhongan.util.FileUtil.LineProcessor)
  • com.github.panhongan.util.hive.TestHiveUtil
  • com.github.panhongan.util.TestIntegerCirculator
  • com.github.panhongan.util.db.TestJedisUtil
  • com.github.panhongan.util.kafka.export.TestKafkaMessageHandlerService
  • com.github.panhongan.util.kafka.TestKafkaUtil
  • com.github.panhongan.util.kafka.TestMessageConsoleWriter
  • com.github.panhongan.util.kafka.TestMessageConsoleWriterGroup
  • com.github.panhongan.util.kafka.TestMessageKafkaWriter
  • com.github.panhongan.util.kafka.TestMessageKafkaWriterGroup
  • com.github.panhongan.util.kafka.TestMessageLocalWriter
  • com.github.panhongan.util.kafka.TestMessageLocalWriterGroup
  • com.github.panhongan.util.mod.TestMod
  • com.github.panhongan.util.db.TestMysqlUtil
  • com.github.panhongan.util.TestOptional
  • com.github.panhongan.util.path.TestPathUtil
  • com.github.panhongan.util.zookeeper.TestPersistentWatcher
  • com.github.panhongan.util.url.TestQueryStringParser
  • com.github.panhongan.util.uri.TestServerURI
  • com.github.panhongan.util.hash.TestSimpleHash
  • com.github.panhongan.util.hash.TestSimplePartitioner
  • com.github.panhongan.util.TestStringUtil
  • com.github.panhongan.util.TestTimeUtil
  • com.github.panhongan.util.TestTuple
  • com.github.panhongan.util.TestValue
  • com.github.panhongan.util.dag.TestVertex
  • com.github.panhongan.util.zookeeper.TestWatcher (implements org.apache.zookeeper.Watcher)
  • com.github.panhongan.util.control.workflow.TestWorkflow
  • com.github.panhongan.util.control.workflow.TestWorkflowNode
  • com.github.panhongan.util.control.workflow.TestWorkflowStage
  • com.github.panhongan.util.zookeeper.TestZookeeper
  • 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.kafka.handler.KafkaMessageWorkflow.InnerMessageProcessor
      • com.github.panhongan.util.zookeeper.PersistentWatcher (implements com.github.panhongan.util.zookeeper.SessionHoldable)
      • com.github.panhongan.util.zookeeper.ZookeeperSessionMonitor
    • com.github.panhongan.util.kafka.export.KafkaExporterShutdownHook
    • com.github.panhongan.util.kafka.handler.KafkaMessageServiceShutdownHook
  • 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.Tuple
  • com.github.panhongan.util.Tuple.Tuple2<T1,T2>
  • com.github.panhongan.util.Tuple.Tuple3<T1,T2,T3>
  • com.github.panhongan.util.Tuple.Tuple4<T1,T2,T3,T4>
  • com.github.panhongan.util.Tuple.Tuple5<T1,T2,T3,T4,T5>
  • 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