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