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 |
DirTailingAdaptor
Explore a whole directory hierarchy, looking for files to tail.
|
class |
ExecAdaptor
Runs a command inside chukwa.
|
class |
FileAdaptor
File Adaptor push small size file in one chunk to collector
|
class |
JMXAdaptor
Query metrics through JMX interface.
|
class |
MemBuffered |
class |
OozieAdaptor |
class |
RegExDirTailingAdaptor |
class |
RestAdaptor |
class |
SocketAdaptor
SocketAdaptor reads TCP message from a port and convert the message to Chukwa
Chunk for transport from Chukwa Agent to Chukwa Collector.
|
class |
SyslogAdaptor
SyslogAdaptor 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 |
CharFileTailingAdaptorUTF8
A subclass of FileTailingAdaptor that reads UTF8/ascii files and splits
records at carriage returns.
|
class |
CharFileTailingAdaptorUTF8NewLineEscaped
A subclass of FileTailingAdaptor that reads UTF8/ascii files and splits
records at non-escaped carriage returns
|
class |
FileTailingAdaptor
An adaptor that repeatedly tails a specified file, sending the new bytes.
|
class |
FileTailingAdaptorPreserveLines
A subclass of FileTailingAdaptor that reads UTF8/ascii files and only send
chunks with complete lines.
|
class |
LWFTAdaptor
A base class for file tailing adaptors.
|
class |
RCheckFTAdaptor
Checkpoint 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 |
JMSAdaptor
Adaptor 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 |
ConstRateAdaptor
Emits chunks at a roughly constant data rate.
|
class |
MaxRateSender |
Copyright © 2014 Apache Software Foundation. All Rights Reserved.