void |
AbstractAdaptor.hardStop()
Deprecated.
|
long |
AbstractAdaptor.shutdown()
Deprecated.
|
long |
WriteaheadBuffered.shutdown(AdaptorShutdownPolicy p) |
long |
UDPAdaptor.shutdown(AdaptorShutdownPolicy shutdownPolicy) |
long |
SocketAdaptor.shutdown(AdaptorShutdownPolicy shutdownPolicy) |
long |
RestAdaptor.shutdown(AdaptorShutdownPolicy shutdownPolicy) |
long |
OozieAdaptor.shutdown(AdaptorShutdownPolicy shutdownPolicy) |
long |
MemBuffered.shutdown(AdaptorShutdownPolicy p) |
long |
JMXAdaptor.shutdown(AdaptorShutdownPolicy shutdownPolicy) |
long |
ExecAdaptor.shutdown(AdaptorShutdownPolicy shutdownPolicy) |
long |
DirTailingAdaptor.shutdown(AdaptorShutdownPolicy shutdownPolicy) |
long |
Adaptor.shutdown(AdaptorShutdownPolicy shutdownPolicy)
Signals this adaptor to come to an orderly stop.
|
long |
AbstractWrapper.shutdown(AdaptorShutdownPolicy shutdownPolicy) |
void |
UDPAdaptor.start(long offset) |
void |
SocketAdaptor.start(long offset) |
void |
RestAdaptor.start(long offset) |
void |
OozieAdaptor.start(long offset) |
void |
JMXAdaptor.start(long offset) |
void |
ExecAdaptor.start(long offset) |
void |
DirTailingAdaptor.start(long offset) |
abstract void |
AbstractAdaptor.start(long offset) |
void |
WriteaheadBuffered.start(String adaptorID,
String type,
long offset,
ChunkReceiver dest) |
void |
MemBuffered.start(String adaptorID,
String type,
long offset,
ChunkReceiver dest) |
void |
Adaptor.start(String adaptorID,
String type,
long offset,
ChunkReceiver dest)
Start this adaptor
|
void |
AbstractWrapper.start(String adaptorID,
String type,
long offset,
ChunkReceiver dest)
Note that the name of the inner class will get parsed out as a type
|
void |
AbstractAdaptor.start(String adaptorID,
String type,
long offset,
ChunkReceiver dest) |