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

Packages that use StateFactory

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.starter.trident
org.apache.storm.trident
org.apache.storm.trident.fluent
org.apache.storm.trident.state
org.apache.storm.trident.testing
org.apache.storm.trident.windowing

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

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

Modifier and Type	Class and Description
class	CassandraStateFactory

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

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

Modifier and Type	Class and Description
class	DruidBeamStateFactory<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 StateFactory in org.apache.storm.elasticsearch.trident

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

Modifier and Type	Class and Description
class	EsStateFactory StateFactory for providing EsState.

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

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

Modifier and Type	Class and Description
protected static class	HBaseMapState.Factory
class	HBaseStateFactory

Methods in org.apache.storm.hbase.trident.state that return StateFactory

Modifier and Type	Method and Description
static StateFactory	HBaseMapState.nonTransactional()
static StateFactory	HBaseMapState.nonTransactional(HBaseMapState.Options<Object> opts)
static StateFactory	HBaseMapState.opaque()
static StateFactory	HBaseMapState.opaque(HBaseMapState.Options<OpaqueValue> opts)
static StateFactory	HBaseMapState.transactional()
static StateFactory	HBaseMapState.transactional(HBaseMapState.Options<TransactionalValue> opts)

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

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

Modifier and Type	Class and Description
class	HdfsStateFactory

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

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

Modifier and Type	Class and Description
class	HiveStateFactory

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

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

Modifier and Type	Class and Description
class	JdbcStateFactory

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

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

Modifier and Type	Class and Description
class	JmsStateFactory

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

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

Modifier and Type	Class and Description
class	TridentKafkaStateFactory

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

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

Modifier and Type	Class and Description
class	MongoStateFactory

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

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

Modifier and Type	Class and Description
class	OpenTsdbStateFactory Trident StateFactory implementation for OpenTSDB.

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

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

Modifier and Type	Class and Description
protected static class	RedisClusterMapState.Factory RedisClusterMapState.Factory provides Redis Cluster environment version of StateFactory.
static class	RedisClusterState.Factory RedisClusterState.Factory implements StateFactory for Redis Cluster environment.
protected static class	RedisMapState.Factory RedisMapState.Factory provides single Redis environment version of StateFactory.
static class	RedisState.Factory RedisState.Factory implements StateFactory for single Redis environment.

Methods in org.apache.storm.redis.trident.state that return StateFactory

Modifier and Type	Method and Description
static StateFactory	RedisClusterMapState.nonTransactional(JedisClusterConfig jedisClusterConfig) Provides StateFactory for non transactional.
static StateFactory	RedisClusterMapState.nonTransactional(JedisClusterConfig jedisClusterConfig, KeyFactory factory) Provides StateFactory for non transactional.
static StateFactory	RedisClusterMapState.nonTransactional(JedisClusterConfig jedisClusterConfig, Options<Object> opts) Provides StateFactory for non transactional.
static StateFactory	RedisClusterMapState.nonTransactional(JedisClusterConfig jedisClusterConfig, RedisDataTypeDescription dataTypeDescription) Provides StateFactory for non transactional.
static StateFactory	RedisMapState.nonTransactional(JedisPoolConfig jedisPoolConfig) Provides StateFactory for non transactional.
static StateFactory	RedisMapState.nonTransactional(JedisPoolConfig jedisPoolConfig, KeyFactory factory) Provides StateFactory for non transactional.
static StateFactory	RedisMapState.nonTransactional(JedisPoolConfig jedisPoolConfig, Options<Object> opts) Provides StateFactory for non transactional.
static StateFactory	RedisMapState.nonTransactional(JedisPoolConfig jedisPoolConfig, RedisDataTypeDescription dataTypeDescription) Provides StateFactory for non transactional.
static StateFactory	RedisClusterMapState.opaque(JedisClusterConfig jedisClusterConfig) Provides StateFactory for opaque transactional.
static StateFactory	RedisClusterMapState.opaque(JedisClusterConfig jedisClusterConfig, KeyFactory factory) Provides StateFactory for opaque transactional.
static StateFactory	RedisClusterMapState.opaque(JedisClusterConfig jedisClusterConfig, Options<OpaqueValue> opts) Provides StateFactory for opaque transactional.
static StateFactory	RedisClusterMapState.opaque(JedisClusterConfig jedisClusterConfig, RedisDataTypeDescription dataTypeDescription) Provides StateFactory for opaque transactional.
static StateFactory	RedisMapState.opaque(JedisPoolConfig jedisPoolConfig) Provides StateFactory for opaque transactional.
static StateFactory	RedisMapState.opaque(JedisPoolConfig jedisPoolConfig, KeyFactory factory) Provides StateFactory for opaque transactional.
static StateFactory	RedisMapState.opaque(JedisPoolConfig jedisPoolConfig, Options<OpaqueValue> opts) Provides StateFactory for opaque transactional.
static StateFactory	RedisMapState.opaque(JedisPoolConfig jedisPoolConfig, RedisDataTypeDescription dataTypeDescription) Provides StateFactory for opaque transactional.
static StateFactory	RedisClusterMapState.transactional(JedisClusterConfig jedisClusterConfig) Provides StateFactory for transactional.
static StateFactory	RedisClusterMapState.transactional(JedisClusterConfig jedisClusterConfig, KeyFactory factory) Provides StateFactory for transactional.
static StateFactory	RedisClusterMapState.transactional(JedisClusterConfig jedisClusterConfig, Options<TransactionalValue> opts) Provides StateFactory for transactional.
static StateFactory	RedisClusterMapState.transactional(JedisClusterConfig jedisClusterConfig, RedisDataTypeDescription dataTypeDescription) Provides StateFactory for transactional.
static StateFactory	RedisMapState.transactional(JedisPoolConfig jedisPoolConfig) Provides StateFactory for transactional.
static StateFactory	RedisMapState.transactional(JedisPoolConfig jedisPoolConfig, KeyFactory factory) Provides StateFactory for transactional.
static StateFactory	RedisMapState.transactional(JedisPoolConfig jedisPoolConfig, Options<TransactionalValue> opts) Provides StateFactory for transactional.
static StateFactory	RedisMapState.transactional(JedisPoolConfig jedisPoolConfig, RedisDataTypeDescription dataTypeDescription) Provides StateFactory for transactional.

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

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

Modifier and Type	Class and Description
class	SolrStateFactory

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

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

Modifier and Type	Method and Description
StateFactory	SimpleSqlTridentConsumer.getStateFactory()
StateFactory	ISqlTridentDataSource.SqlTridentConsumer.getStateFactory()

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

Constructor and Description
SimpleSqlTridentConsumer(StateFactory stateFactory, StateUpdater stateUpdater)

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

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

Modifier and Type	Class and Description
static class	SocketState.Factory

Uses of StateFactory in org.apache.storm.starter.trident

Classes in org.apache.storm.starter.trident that implement StateFactory

Modifier and Type	Class and Description
static class	DebugMemoryMapState.Factory
static class	TridentReach.StaticSingleKeyMapState.Factory

Uses of StateFactory in org.apache.storm.trident

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

Modifier and Type	Method and Description
TridentState	TridentTopology.newStaticState(StateFactory factory)
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.persistentAggregate(StateFactory stateFactory, CombinerAggregator agg, Fields functionFields)
TridentState	Stream.persistentAggregate(StateFactory stateFactory, Fields inputFields, CombinerAggregator agg, Fields functionFields)
TridentState	Stream.persistentAggregate(StateFactory stateFactory, Fields inputFields, ReducerAggregator agg, Fields functionFields)
TridentState	Stream.persistentAggregate(StateFactory stateFactory, ReducerAggregator agg, Fields functionFields)

Uses of StateFactory in org.apache.storm.trident.fluent

Methods in org.apache.storm.trident.fluent with parameters of type StateFactory

Modifier and Type	Method and Description
TridentState	GroupedStream.persistentAggregate(StateFactory stateFactory, CombinerAggregator agg, Fields functionFields)
TridentState	GroupedStream.persistentAggregate(StateFactory stateFactory, Fields inputFields, CombinerAggregator agg, Fields functionFields)
TridentState	GroupedStream.persistentAggregate(StateFactory stateFactory, Fields inputFields, ReducerAggregator agg, Fields functionFields)
TridentState	GroupedStream.persistentAggregate(StateFactory stateFactory, ReducerAggregator agg, Fields functionFields)

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

Fields in org.apache.storm.trident.state declared as StateFactory

Modifier and Type	Field and Description
StateFactory	StateSpec.stateFactory

Constructors in org.apache.storm.trident.state with parameters of type StateFactory

Constructor and Description
StateSpec(StateFactory stateFactory)

Uses of StateFactory in org.apache.storm.trident.testing

Classes in org.apache.storm.trident.testing that implement StateFactory

Modifier and Type	Class and Description
static class	LRUMemoryMapState.Factory
static class	MemoryMapState.Factory

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

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

Modifier and Type	Class and Description
class	WindowsStateFactory StateFactory instance for creating WindowsState instances.