v0.9.4 Class details

• FlumeMaster
  • implements Reportable
  • MasterAdminServer (for shell clients)
  • MasterClientServer (for heartbeating and acking node clients)
  • ThriftReporterServer (for metric reports from nodes)
  • AvroReportServer (for metric reports from noes)
  • InternalHttpServer (jetty master status)
  • CommandManager (handles commands from shell/web)
  • ConfigurationManager (manages node configurations)
  • StatusManager (manages node heartbeat state)
  • MasterAckManager (manages acks from nodes)
  • SystemInfo (gets jmx info for status of master reports)
  • FlumeVMInfo (gets jmx info for status of master reports)
  • Thread reaper (converts nodes that haven't repored to LOST state)