Uses of Class
org.apache.storm.trident.operation.BaseOperation

Packages that use BaseOperation

Package	Description
org.apache.storm.cassandra.trident.state
org.apache.storm.elasticsearch.trident	ElasticSearch Trident example classes.
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
org.apache.storm.mongodb.trident.state
org.apache.storm.mqtt.trident
org.apache.storm.opentsdb.trident
org.apache.storm.redis.trident.state
org.apache.storm.rocketmq.trident.state
org.apache.storm.solr.trident
org.apache.storm.starter.trident
org.apache.storm.trident.operation
org.apache.storm.trident.operation.builtin
org.apache.storm.trident.operation.impl
org.apache.storm.trident.state
org.apache.storm.trident.testing

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

Subclasses of BaseOperation in org.apache.storm.cassandra.trident.state

Modifier and Type	Class and Description
class	CassandraQuery
class	CassandraStateUpdater

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

Subclasses of BaseOperation in org.apache.storm.elasticsearch.trident

Modifier and Type	Class and Description
class	EsUpdater

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

Subclasses of BaseOperation in org.apache.storm.hbase.trident.state

Modifier and Type	Class and Description
class	HBaseQuery
class	HBaseUpdater

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

Subclasses of BaseOperation in org.apache.storm.hdfs.trident

Modifier and Type	Class and Description
class	HdfsUpdater

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

Subclasses of BaseOperation in org.apache.storm.hive.trident

Modifier and Type	Class and Description
class	HiveUpdater

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

Subclasses of BaseOperation in org.apache.storm.jdbc.trident.state

Modifier and Type	Class and Description
class	JdbcQuery
class	JdbcUpdater

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

Subclasses of BaseOperation in org.apache.storm.jms.trident

Modifier and Type	Class and Description
class	JmsUpdater

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

Subclasses of BaseOperation in org.apache.storm.kafka.trident

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

Uses of BaseOperation in org.apache.storm.mongodb.trident

Subclasses of BaseOperation in org.apache.storm.mongodb.trident

Modifier and Type	Class and Description
class	PrintFunction

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

Subclasses of BaseOperation in org.apache.storm.mongodb.trident.state

Modifier and Type	Class and Description
class	MongoStateQuery
class	MongoStateUpdater

Uses of BaseOperation in org.apache.storm.mqtt.trident

Subclasses of BaseOperation in org.apache.storm.mqtt.trident

Modifier and Type	Class and Description
class	MqttPublishFunction

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

Subclasses of BaseOperation in org.apache.storm.opentsdb.trident

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

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

Subclasses of BaseOperation in org.apache.storm.redis.trident.state

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

Uses of BaseOperation in org.apache.storm.rocketmq.trident.state

Subclasses of BaseOperation in org.apache.storm.rocketmq.trident.state

Modifier and Type	Class and Description
class	RocketMqStateUpdater

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

Subclasses of BaseOperation in org.apache.storm.solr.trident

Modifier and Type	Class and Description
class	SolrUpdater

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

Subclasses of BaseOperation in org.apache.storm.starter.trident

Modifier and Type	Class and Description
static class	TridentReach.ExpandList
static class	TridentWordCount.Split

Uses of BaseOperation in org.apache.storm.trident.operation

Subclasses of BaseOperation in org.apache.storm.trident.operation

Modifier and Type	Class and Description
class	BaseAggregator<T>
class	BaseFilter
class	BaseFunction

Uses of BaseOperation in org.apache.storm.trident.operation.builtin

Subclasses of BaseOperation in org.apache.storm.trident.operation.builtin

Modifier and Type	Class and Description
class	ComparisonAggregator<T> Abstract Aggregator for comparing two values in a stream.
class	Debug Filter for debugging purposes.
class	Equals
class	FilterNull Simple Filter implementation that filters out any tuples that have fields with a value of null.
static class	FirstN.FirstNAgg
static class	FirstN.FirstNSortedAgg
class	MapGet
class	Max This aggregator computes the maximum of aggregated tuples in a stream.
class	MaxWithComparator<T> This aggregator computes the maximum of aggregated tuples in a stream.
class	Min This aggregator computes the minimum of aggregated tuples in a stream.
class	MinWithComparator<T> This aggregator computes the minimum of aggregated tuples in a stream.
class	SnapshotGet
class	TupleCollectionGet

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

Subclasses of BaseOperation in org.apache.storm.trident.operation.impl

Modifier and Type	Class and Description
class	ConsumerExecutor
class	FlatMapFunctionExecutor
class	MapFunctionExecutor

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

Subclasses of BaseOperation in org.apache.storm.trident.state

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

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

Subclasses of BaseOperation in org.apache.storm.trident.testing

Modifier and Type	Class and Description
class	CountAsAggregator
class	Split
class	StringLength
class	TrueFilter
class	TuplifyArgs