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 |
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.
|
Modifier and Type | Method and Description |
---|---|
Map<Long,Adaptor> |
ChukwaAgent.getAdaptorList() |
Modifier and Type | Method and Description |
---|---|
String |
AgentControlSocketListener.formatAdaptorStatus(Adaptor a) |
long |
ChukwaAgent.getOffset(Adaptor a)
Returns the last offset at which a given adaptor was checkpointed
|
void |
ChukwaAgent.reportCommit(Adaptor src,
long uuid) |
Modifier and Type | Field and Description |
---|---|
Adaptor |
ChukwaHttpSender.CommitListEntry.adaptor |
Constructor and Description |
---|
ChukwaHttpSender.CommitListEntry(Adaptor a,
long uuid) |
Modifier and Type | Class and Description |
---|---|
class |
ConstRateAdaptor |
class |
MaxRateSender |
Copyright © ${year} The Apache Software Foundation