C D E G O P S

C

cleanup() - Method in class org.apache.ignite.stream.storm.StormStreamer

Cleans up the streamer when the bolt is going to shutdown.

D

declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.ignite.stream.storm.StormStreamer

Normally declares output fields for the stream of the topology.

E

execute(Tuple) - Method in class org.apache.ignite.stream.storm.StormStreamer

Transfers data into grid.

G

getAllowOverwrite() - Method in class org.apache.ignite.stream.storm.StormStreamer

Obtains flag for enabling overwriting existing values in cache.

getAutoFlushFrequency() - Method in class org.apache.ignite.stream.storm.StormStreamer

Obtains data flush frequency.

getCacheName() - Method in class org.apache.ignite.stream.storm.StormStreamer

Gets the cache name.

getComponentConfiguration() - Method in class org.apache.ignite.stream.storm.StormStreamer

Not used.

getIgnite() - Static method in class org.apache.ignite.stream.storm.StormStreamer.StreamerContext

Obtains grid instance.

getIgniteConfigFile() - Method in class org.apache.ignite.stream.storm.StormStreamer

Gets Ignite configuration file.

getIgniteTupleField() - Method in class org.apache.ignite.stream.storm.StormStreamer

Gets Ignite tuple field, by which tuple data is obtained in topology.

getStreamer() - Static method in class org.apache.ignite.stream.storm.StormStreamer.StreamerContext

Obtains data streamer instance.

O

org.apache.ignite.stream.storm - package org.apache.ignite.stream.storm

StormStreamer -- integration with Apache Storm.

P

prepare(Map, TopologyContext, OutputCollector) - Method in class org.apache.ignite.stream.storm.StormStreamer

Initializes Ignite client instance from a configuration file and declares the output collector of the bolt.

S

setAllowOverwrite(boolean) - Method in class org.apache.ignite.stream.storm.StormStreamer

Enables overwriting existing values in cache.

setAutoFlushFrequency(long) - Method in class org.apache.ignite.stream.storm.StormStreamer

Specifies data flush frequency into the grid.

setCacheName(String) - Method in class org.apache.ignite.stream.storm.StormStreamer

Sets the cache name.

setIgniteConfigFile(String) - Method in class org.apache.ignite.stream.storm.StormStreamer

Specifies Ignite configuration file.

setIgniteTupleField(String) - Method in class org.apache.ignite.stream.storm.StormStreamer

Names Ignite tuple field, by which tuple data is obtained in topology.

start() - Method in class org.apache.ignite.stream.storm.StormStreamer

Starts streamer.

stop() - Method in class org.apache.ignite.stream.storm.StormStreamer

Stops streamer.

StormStreamer<K,V> - Class in org.apache.ignite.stream.storm

Apache Storm streamer implemented as a Storm bolt.

StormStreamer() - Constructor for class org.apache.ignite.stream.storm.StormStreamer

StormStreamer.StreamerContext - Class in org.apache.ignite.stream.storm

Streamer context initializing grid and data streamer instances on demand.

C D E G O P S