| Package | Description |
|---|---|
| backtype.storm.spout | |
| net.lag.kestrel.thrift |
| Modifier and Type | Method and Description |
|---|---|
List<Item> |
KestrelThriftClient.get(String queue_name,
int max_items,
int timeout_msec,
int auto_abort_msec) |
| Modifier and Type | Method and Description |
|---|---|
Item |
Item.deepCopy() |
| Modifier and Type | Method and Description |
|---|---|
Iterator<Item> |
Kestrel.get_result.get_success_iterator() |
List<Item> |
Kestrel.get_result.get_success() |
List<Item> |
Kestrel.Iface.get(String queue_name,
int max_items,
int timeout_msec,
int auto_abort_msec) |
List<Item> |
Kestrel.Client.get(String queue_name,
int max_items,
int timeout_msec,
int auto_abort_msec) |
List<Item> |
Kestrel.AsyncClient.get_call.getResult() |
List<Item> |
Kestrel.Client.recv_get() |
| Modifier and Type | Method and Description |
|---|---|
void |
Kestrel.get_result.add_to_success(Item elem) |
int |
Item.compareTo(Item other) |
boolean |
Item.equals(Item that) |
| Modifier and Type | Method and Description |
|---|---|
void |
Kestrel.get_result.set_success(List<Item> success) |
| Constructor and Description |
|---|
Item(Item other)
Performs a deep copy on other.
|
| Constructor and Description |
|---|
get_result(List<Item> success) |