| Package | Description |
|---|---|
| backtype.storm.spout | |
| org.openimaj.kestrel | |
| org.openimaj.rdf.storm.utils | |
| org.openimaj.storm.tool | |
| org.openimaj.storm.utils |
| Constructor and Description |
|---|
UnreliableKestrelThriftSpout(List<KestrelServerSpec> serverSpecs,
backtype.storm.spout.Scheme scheme,
String inputQueue) |
| Modifier and Type | Method and Description |
|---|---|
static KestrelServerSpec |
KestrelServerSpec.localMemcached() |
static KestrelServerSpec |
KestrelServerSpec.localText() |
static KestrelServerSpec |
KestrelServerSpec.localThrift() |
| Modifier and Type | Method and Description |
|---|---|
static List<KestrelServerSpec> |
KestrelServerSpec.parseKestrelAddressList(List<String> kestrelHosts)
Parse a list of strings in the format: host:port.
|
| Modifier and Type | Method and Description |
|---|---|
static String |
KestrelServerSpec.kestrelAddressListAsString(List<KestrelServerSpec> kestrelSpecList,
int port)
Construct a string that looks like this: "host1:port1 host2:port2" from
the list of
KestrelServerSpec |
static Iterator<KestrelThriftClient> |
KestrelServerSpec.thriftClientIterator(List<KestrelServerSpec> kestrelSpecList)
An iterator to access a list of
KestrelServerSpec in a round
robin fasion. |
| Modifier and Type | Method and Description |
|---|---|
KestrelServerSpec |
JenaStormUtils.KestrelServerSpec_Serializer.read(com.esotericsoftware.kryo.Kryo kryo,
com.esotericsoftware.kryo.io.Input input,
Class<KestrelServerSpec> type) |
| Modifier and Type | Method and Description |
|---|---|
void |
JenaStormUtils.KestrelServerSpec_Serializer.write(com.esotericsoftware.kryo.Kryo kryo,
com.esotericsoftware.kryo.io.Output output,
KestrelServerSpec object) |
| Modifier and Type | Method and Description |
|---|---|
KestrelServerSpec |
JenaStormUtils.KestrelServerSpec_Serializer.read(com.esotericsoftware.kryo.Kryo kryo,
com.esotericsoftware.kryo.io.Input input,
Class<KestrelServerSpec> type) |
| Modifier and Type | Field and Description |
|---|---|
List<KestrelServerSpec> |
StormToolOptions.kestrelSpecList
parsed kestrel server specs
|
| Modifier and Type | Method and Description |
|---|---|
static void |
KestrelUtils.deleteQueues(KestrelServerSpec spec,
String... queues) |