A C D E F G M N O S T U W

A

ack(Object) - Method in class org.apache.storm.elasticsearch.bolt.EsIndexTopology.UserDataSpout

Acknowledges the message with id msgId.

ack(long) - Method in class org.apache.storm.elasticsearch.trident.TridentEsTopology.FixedBatchSpout

Acknowledges the message with id msgId.

C

close() - Method in class org.apache.storm.elasticsearch.trident.TridentEsTopology.FixedBatchSpout

Closes the spout.

CLUSTER_NAME - Static variable in class org.apache.storm.elasticsearch.common.EsConstants

The cluster name.

D

declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.elasticsearch.bolt.EsIndexTopology.UserDataSpout

Declares source, index, type and id.

E

emitBatch(long, TridentCollector) - Method in class org.apache.storm.elasticsearch.trident.TridentEsTopology.FixedBatchSpout

Emits a batch.

EsConstants - Class in org.apache.storm.elasticsearch.common

Constants used in ElasticSearch examples.

EsIndexTopology - Class in org.apache.storm.elasticsearch.bolt

Demonstrates an ElasticSearch Storm topology.

EsIndexTopology.UserDataSpout - Class in org.apache.storm.elasticsearch.bolt

The user data spout.

EsTestUtil - Class in org.apache.storm.elasticsearch.common

ElasticSearch example utilities.

F

fail(Object) - Method in class org.apache.storm.elasticsearch.bolt.EsIndexTopology.UserDataSpout

Marks the message with id msgId as failed.

FixedBatchSpout(int) - Constructor for class org.apache.storm.elasticsearch.trident.TridentEsTopology.FixedBatchSpout

Creates a new fixed batch spout.

G

generateDefaultTupleMapper() - Static method in class org.apache.storm.elasticsearch.common.EsTestUtil

Generates a new tuple mapper.

generateTestTuple(String, String, String, String) - Static method in class org.apache.storm.elasticsearch.common.EsTestUtil

Generates a test tuple.

getComponentConfiguration() - Method in class org.apache.storm.elasticsearch.trident.TridentEsTopology.FixedBatchSpout

Get the component configuration.

getOutputFields() - Method in class org.apache.storm.elasticsearch.trident.TridentEsTopology.FixedBatchSpout

Gets the output fields.

M

main(String[]) - Static method in class org.apache.storm.elasticsearch.bolt.EsIndexTopology

The example’s main method.

main(String[]) - Static method in class org.apache.storm.elasticsearch.trident.TridentEsTopology

The example’s main method.

N

nextTuple() - Method in class org.apache.storm.elasticsearch.bolt.EsIndexTopology.UserDataSpout

Makes the spout emit the next tuple, if any.

O

open(Map<String, Object>, TopologyContext, SpoutOutputCollector) - Method in class org.apache.storm.elasticsearch.bolt.EsIndexTopology.UserDataSpout

Acquires collector and initializes pending.

open(Map<String, Object>, TopologyContext) - Method in class org.apache.storm.elasticsearch.trident.TridentEsTopology.FixedBatchSpout

Opens the spout.

org.apache.storm.elasticsearch.bolt - package org.apache.storm.elasticsearch.bolt

ElasticSearch examples classes.

org.apache.storm.elasticsearch.common - package org.apache.storm.elasticsearch.common

Shared code for example classes.

org.apache.storm.elasticsearch.trident - package org.apache.storm.elasticsearch.trident

ElasticSearch Trident example classes.

S

startEsNode() - Static method in class org.apache.storm.elasticsearch.common.EsTestUtil

Starts an ElasticSearch node.

T

TridentEsTopology - Class in org.apache.storm.elasticsearch.trident

A Trident topology example.

TridentEsTopology.FixedBatchSpout - Class in org.apache.storm.elasticsearch.trident

A fixed batch spout.

U

UserDataSpout() - Constructor for class org.apache.storm.elasticsearch.bolt.EsIndexTopology.UserDataSpout

W

WAIT_DEFAULT_SECS - Static variable in class org.apache.storm.elasticsearch.common.EsConstants

The default wait value in seconds.

waitForSeconds(int) - Static method in class org.apache.storm.elasticsearch.common.EsTestUtil

Waits for specified seconds and ignores InterruptedException.

A C D E F G M N O S T U W