Modifier and Type | Interface and Description |
---|---|
interface |
ChunkQueue
A generic interface for queues of Chunks.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractWrapper |
class |
MemBuffered |
class |
WriteaheadBuffered |
Modifier and Type | Method and Description |
---|---|
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) |
Constructor and Description |
---|
JMXTimer(ChunkReceiver receiver,
JMXAdaptor adaptor,
MBeanServerConnection mbsc) |
Constructor and Description |
---|
SigarRunner(ChunkReceiver dest,
SystemMetrics systemMetrics) |
Modifier and Type | Class and Description |
---|---|
class |
MemLimitQueue
An event queue that blocks once a fixed upper limit of data is enqueued.
|
class |
NonBlockingMemLimitQueue
An event queue that discards incoming chunks once a fixed upper limit of data
is enqueued.
|
class |
WaitingQueue |
Modifier and Type | Method and Description |
---|---|
void |
MaxRateSender.start(String adaptorID,
String type,
long offset,
ChunkReceiver dest) |
Copyright © 2016 Apache Software Foundation. All Rights Reserved.