| 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