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 | Class and Description |
---|---|
class |
AbstractAdaptor |
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
|
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 |
LWFTAdaptor
A base class for file tailing adaptors.
|
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 © ${year} The Apache Software Foundation