Serialized Form

Package org.apache.ignite.stream.storm

Class org.apache.ignite.stream.storm.StormStreamer extends StreamAdapter<org.apache.storm.tuple.Tuple,K,V> implements Serializable

Serialized Fields

log

IgniteLogger log

Logger.

igniteTupleField

String igniteTupleField

Field by which tuple data is obtained in topology.

autoFlushFrequency

long autoFlushFrequency

Automatic flush frequency.

allowOverwrite

boolean allowOverwrite

Enables overwriting existing values in cache.

collector

org.apache.storm.task.OutputCollector collector

Storm output collector.