org.apache.hadoop.chukwa.datacollection.adaptor

Class SyslogAdaptor

java.lang.Object

org.apache.hadoop.chukwa.datacollection.adaptor.AbstractAdaptor

org.apache.hadoop.chukwa.datacollection.adaptor.UDPAdaptor

org.apache.hadoop.chukwa.datacollection.adaptor.SyslogAdaptor

All Implemented Interfaces:

Adaptor

public class SyslogAdaptor
extends UDPAdaptor

SyslogAdaptor reads UDP syslog message from a port and convert the message to Chukwa Chunk for transport from Chukwa Agent to Chukwa Collector. Usage: add SyslogAdaptor [DataType] [Port] [SequenceNumber] Syslog protocol facility name is mapped to Chukwa Data Type by SyslogAdaptor, hence each UDP port can support up to 24 data streams. Data Type mapping can be overwritten in Chukwa Agent Configuration file, i.e.: syslog.adaptor.port.9095.facility.LOCAL1 HADOOP When demux takes place, data received on port 9095 with facility name LOCAL0 will be processed by demux parser for data type "HADOOP".

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SyslogAdaptor.FacilityType

Field Summary

Fields

Modifier and Type	Field and Description
HashMap<Integer,String>	facilityMap

Fields inherited from class org.apache.hadoop.chukwa.datacollection.adaptor.AbstractAdaptor

adaptorID, control, dest, type

Constructor Summary

Constructors

Constructor and Description
SyslogAdaptor()

Method Summary

Methods

Modifier and Type	Method and Description
String	parseArgs(String s)
void	send(byte[] buf, DatagramPacket dp)

Methods inherited from class org.apache.hadoop.chukwa.datacollection.adaptor.UDPAdaptor

getCurrentStatus, shutdown, start

Methods inherited from class org.apache.hadoop.chukwa.datacollection.adaptor.AbstractAdaptor

deregisterAndStop, getType, hardStop, parseArgs, shutdown, start

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

facilityMap

public HashMap<Integer,String> facilityMap

Constructor Detail

SyslogAdaptor

public SyslogAdaptor()

Method Detail

send

public void send(byte[] buf,
        DatagramPacket dp)
          throws InterruptedException,
                 IOException

Overrides:

send in class UDPAdaptor

Throws:

InterruptedException

IOException

parseArgs

public String parseArgs(String s)

Overrides:

parseArgs in class UDPAdaptor