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) |