Uses of Interface
org.apache.storm.trident.state.StateUpdater

Packages that use StateUpdater

Package	Description
org.apache.storm.cassandra.trident.state
org.apache.storm.druid.trident
org.apache.storm.elasticsearch.trident
org.apache.storm.hbase.trident.state
org.apache.storm.hdfs.trident
org.apache.storm.hive.trident
org.apache.storm.jdbc.trident.state
org.apache.storm.jms.trident
org.apache.storm.kafka.trident
org.apache.storm.mongodb.trident.state
org.apache.storm.opentsdb.trident
org.apache.storm.redis.trident.state
org.apache.storm.solr.trident
org.apache.storm.sql.runtime
org.apache.storm.sql.runtime.datasource.socket.trident
org.apache.storm.trident
org.apache.storm.trident.operation.impl
org.apache.storm.trident.planner.processor
org.apache.storm.trident.state
org.apache.storm.trident.state.map
org.apache.storm.trident.windowing

Uses of StateUpdater in org.apache.storm.cassandra.trident.state

Classes in org.apache.storm.cassandra.trident.state that implement StateUpdater

Modifier and Type	Class and Description
class	CassandraStateUpdater

Uses of StateUpdater in org.apache.storm.druid.trident

Classes in org.apache.storm.druid.trident that implement StateUpdater

Modifier and Type	Class and Description
class	DruidBeamStateUpdater<E> Deprecated. the preferred way to ingest streaming events to druid is through Kafka, as such storm-druid is deprecated and will be removed in 2.x releases of storm.

Uses of StateUpdater in org.apache.storm.elasticsearch.trident

Classes in org.apache.storm.elasticsearch.trident that implement StateUpdater

Modifier and Type	Class and Description
class	EsUpdater

Uses of StateUpdater in org.apache.storm.hbase.trident.state

Classes in org.apache.storm.hbase.trident.state that implement StateUpdater

Modifier and Type	Class and Description
class	HBaseUpdater

Uses of StateUpdater in org.apache.storm.hdfs.trident

Classes in org.apache.storm.hdfs.trident that implement StateUpdater

Modifier and Type	Class and Description
class	HdfsUpdater

Uses of StateUpdater in org.apache.storm.hive.trident

Classes in org.apache.storm.hive.trident that implement StateUpdater

Modifier and Type	Class and Description
class	HiveUpdater

Uses of StateUpdater in org.apache.storm.jdbc.trident.state

Classes in org.apache.storm.jdbc.trident.state that implement StateUpdater

Modifier and Type	Class and Description
class	JdbcUpdater

Uses of StateUpdater in org.apache.storm.jms.trident

Classes in org.apache.storm.jms.trident that implement StateUpdater

Modifier and Type	Class and Description
class	JmsUpdater

Uses of StateUpdater in org.apache.storm.kafka.trident

Classes in org.apache.storm.kafka.trident that implement StateUpdater

Modifier and Type	Class and Description
class	TridentKafkaStateUpdater<K,V>
class	TridentKafkaUpdater

Uses of StateUpdater in org.apache.storm.mongodb.trident.state

Classes in org.apache.storm.mongodb.trident.state that implement StateUpdater

Modifier and Type	Class and Description
class	MongoStateUpdater

Uses of StateUpdater in org.apache.storm.opentsdb.trident

Classes in org.apache.storm.opentsdb.trident that implement StateUpdater

Modifier and Type	Class and Description
class	OpenTsdbStateUpdater Trident StateUpdater implementation for OpenTSDB.

Uses of StateUpdater in org.apache.storm.redis.trident.state

Classes in org.apache.storm.redis.trident.state that implement StateUpdater

Modifier and Type	Class and Description
class	AbstractRedisStateUpdater<T extends State> AbstractRedisStateUpdater is base class of any RedisStateUpdater, which implements BaseStateUpdater.
class	RedisClusterStateUpdater BaseStateUpdater implementation for Redis Cluster environment.
class	RedisStateUpdater BaseStateUpdater implementation for single Redis environment.

Uses of StateUpdater in org.apache.storm.solr.trident

Classes in org.apache.storm.solr.trident that implement StateUpdater

Modifier and Type	Class and Description
class	SolrUpdater

Uses of StateUpdater in org.apache.storm.sql.runtime

Methods in org.apache.storm.sql.runtime that return StateUpdater

Modifier and Type	Method and Description
StateUpdater	SimpleSqlTridentConsumer.getStateUpdater()
StateUpdater	ISqlTridentDataSource.SqlTridentConsumer.getStateUpdater()

Constructors in org.apache.storm.sql.runtime with parameters of type StateUpdater

Constructor and Description
SimpleSqlTridentConsumer(StateFactory stateFactory, StateUpdater stateUpdater)

Uses of StateUpdater in org.apache.storm.sql.runtime.datasource.socket.trident

Classes in org.apache.storm.sql.runtime.datasource.socket.trident that implement StateUpdater

Modifier and Type	Class and Description
class	SocketStateUpdater StateUpdater for SocketState.

Uses of StateUpdater in org.apache.storm.trident

Methods in org.apache.storm.trident with parameters of type StateUpdater

Modifier and Type	Method and Description
TridentState	Stream.partitionPersist(StateFactory stateFactory, Fields inputFields, StateUpdater updater)
TridentState	Stream.partitionPersist(StateFactory stateFactory, Fields inputFields, StateUpdater updater, Fields functionFields)
TridentState	Stream.partitionPersist(StateFactory stateFactory, StateUpdater updater)
TridentState	Stream.partitionPersist(StateFactory stateFactory, StateUpdater updater, Fields functionFields)
TridentState	Stream.partitionPersist(StateSpec stateSpec, Fields inputFields, StateUpdater updater)
TridentState	Stream.partitionPersist(StateSpec stateSpec, Fields inputFields, StateUpdater updater, Fields functionFields)
TridentState	Stream.partitionPersist(StateSpec stateSpec, StateUpdater updater)
TridentState	Stream.partitionPersist(StateSpec stateSpec, StateUpdater updater, Fields functionFields)

Uses of StateUpdater in org.apache.storm.trident.operation.impl

Classes in org.apache.storm.trident.operation.impl that implement StateUpdater

Modifier and Type	Class and Description
class	CombinerAggStateUpdater
class	ReducerAggStateUpdater

Uses of StateUpdater in org.apache.storm.trident.planner.processor

Constructors in org.apache.storm.trident.planner.processor with parameters of type StateUpdater

Constructor and Description
PartitionPersistProcessor(String stateId, Fields inputFields, StateUpdater updater)

Uses of StateUpdater in org.apache.storm.trident.state

Classes in org.apache.storm.trident.state that implement StateUpdater

Modifier and Type	Class and Description
class	BaseStateUpdater<S extends State>

Uses of StateUpdater in org.apache.storm.trident.state.map

Classes in org.apache.storm.trident.state.map that implement StateUpdater

Modifier and Type	Class and Description
class	MapCombinerAggStateUpdater
class	MapReducerAggStateUpdater

Uses of StateUpdater in org.apache.storm.trident.windowing

Classes in org.apache.storm.trident.windowing that implement StateUpdater

Modifier and Type	Class and Description
class	WindowsStateUpdater StateUpdater<WindowState> instance which removes successfully emitted triggers from store