| Modifier and Type | Method and Description | 
|---|---|
| Adaptor | ChunkImpl. getInitiator() | 
| Adaptor | Chunk. getInitiator()Retrieve a reference to the adaptor that sent this event. | 
| Modifier and Type | Method and Description | 
|---|---|
| void | ChunkImpl. setInitiator(Adaptor a) | 
| Constructor and Description | 
|---|
| ChunkImpl(String dataType,
         String streamName,
         long seq,
         byte[] data,
         Adaptor source) | 
| Modifier and Type | Interface and Description | 
|---|---|
| interface  | NotifyOnCommitAdaptor | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | AbstractAdaptor | 
| class  | AbstractWrapper | 
| class  | DirTailingAdaptorExplore a whole directory hierarchy, looking for files to tail. | 
| class  | ExecAdaptorRuns a command inside chukwa. | 
| class  | FileAdaptorFile Adaptor push small size file in one chunk to collector | 
| class  | JMXAdaptorQuery metrics through JMX interface. | 
| class  | MemBuffered | 
| class  | OozieAdaptor | 
| class  | RegExDirTailingAdaptor | 
| class  | RestAdaptor | 
| class  | SocketAdaptorSocketAdaptor reads TCP message from a port and convert the message to Chukwa
 Chunk for transport from Chukwa Agent to Chukwa Collector. | 
| class  | SyslogAdaptorSyslogAdaptor reads UDP syslog message from a port and convert the message to Chukwa
 Chunk for transport from Chukwa Agent to Chukwa Collector. | 
| class  | UDPAdaptor | 
| class  | WriteaheadBuffered | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | CharFileTailingAdaptorUTF8A subclass of FileTailingAdaptor that reads UTF8/ascii files and splits
 records at carriage returns. | 
| class  | CharFileTailingAdaptorUTF8NewLineEscapedA subclass of FileTailingAdaptor that reads UTF8/ascii files and splits
 records at non-escaped carriage returns | 
| class  | FileTailingAdaptorAn adaptor that repeatedly tails a specified file, sending the new bytes. | 
| class  | FileTailingAdaptorPreserveLinesA subclass of FileTailingAdaptor that reads UTF8/ascii files and only send
 chunks with complete lines. | 
| class  | LWFTAdaptorA base class for file tailing adaptors. | 
| class  | RCheckFTAdaptorCheckpoint state:
   date modified of most-recently tailed file, offset of first byte of that file,
   then regular FTA arts | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | JMSAdaptorAdaptor that is able to listen to a JMS topic or queue for messages, receive
 the message, and transform it to a Chukwa chunk. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | SystemMetrics | 
| Modifier and Type | Method and Description | 
|---|---|
| static Adaptor | AdaptorFactory. createAdaptor(String className)Instantiate an adaptor that can be added by the  ChukwaAgent | 
| Adaptor | ChukwaAgent. getAdaptor(String name) | 
| Adaptor | AdaptorManager. getAdaptor(String id) | 
| Modifier and Type | Method and Description | 
|---|---|
| String | ChukwaAgent. getAdaptorName(Adaptor initiator) | 
| ChukwaAgent.Offset | ChukwaAgent. offset(Adaptor a) | 
| String | ChukwaAgent. reportCommit(Adaptor src,
            long uuid) | 
| String | AdaptorManager. reportCommit(Adaptor src,
            long uuid)Called to update the Agent status table. | 
| void | AdaptorResetThread. reportStop(Adaptor a) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | AdaptorResetThread. reportCommits(Set<Adaptor> commits) | 
| Modifier and Type | Field and Description | 
|---|---|
| Adaptor | ChukwaHttpSender.CommitListEntry. adaptor | 
| Constructor and Description | 
|---|
| AsyncAckSender.DelayedCommit(Adaptor a,
                            long uuid,
                            long len,
                            String fname,
                            long offset,
                            String aName) | 
| ChukwaHttpSender.CommitListEntry(Adaptor a,
                                long uuid,
                                long start) | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | ConstRateAdaptorEmits chunks at a roughly constant data rate. | 
| class  | MaxRateSender | 
Copyright © 2014 Apache Software Foundation. All Rights Reserved.