Modifier and Type | Method and Description |
---|---|
String |
FileAdaptor.getCurrentStatus() |
String |
ExecAdaptor.getCurrentStatus() |
String |
Adaptor.getCurrentStatus()
Return the adaptor's state Should not include class name, datatype or byte
offset, which are written by caller.
|
void |
FileAdaptor.hardStop()
Stop tailing the file, effective immediately.
|
void |
ExecAdaptor.hardStop() |
void |
Adaptor.hardStop()
Signals this adaptor to come to an abrupt stop, as quickly as it can.
|
long |
FileAdaptor.shutdown()
We want to keep trying
|
long |
ExecAdaptor.shutdown() |
long |
Adaptor.shutdown()
Signals this adaptor to come to an orderly stop.
|
void |
ExecAdaptor.start(long adaptorID,
String type,
String status,
long offset,
ChunkReceiver dest) |
void |
Adaptor.start(long adaptorID,
String type,
String status,
long offset,
ChunkReceiver dest)
Start this adaptor
|
Modifier and Type | Method and Description |
---|---|
void |
FileTailingAdaptor.hardStop()
Stop tailing the file, effective immediately.
|
long |
FileTailingAdaptor.shutdown()
Do one last tail, and then stop
|
Modifier and Type | Method and Description |
---|---|
String |
AgentControlSocketListener.formatAdaptorStatus(Adaptor a) |
static void |
ChukwaAgent.main(String[] args) |
Modifier and Type | Method and Description |
---|---|
String |
MaxRateSender.getCurrentStatus() |
String |
ConstRateAdaptor.getCurrentStatus() |
void |
MaxRateSender.hardStop() |
void |
ConstRateAdaptor.hardStop() |
long |
MaxRateSender.shutdown() |
long |
ConstRateAdaptor.shutdown() |
void |
MaxRateSender.start(long adaptor,
String type,
String status,
long offset,
ChunkReceiver dest) |
void |
ConstRateAdaptor.start(long adaptor,
String type,
String bytesPerSecParam,
long offset,
ChunkReceiver dest) |
Copyright © ${year} The Apache Software Foundation