Uses of Interface
org.apache.storm.trident.operation.Operation

Packages that use Operation

Package	Description
org.apache.storm.cassandra.trident.state
org.apache.storm.druid.trident
org.apache.storm.elasticsearch.trident
org.apache.storm.eventhubs.samples
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.mqtt.trident
org.apache.storm.opentsdb.trident
org.apache.storm.redis.trident
org.apache.storm.redis.trident.state
org.apache.storm.solr.trident
org.apache.storm.sql.runtime.datasource.socket.trident
org.apache.storm.sql.runtime.trident.functions
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.state.map
org.apache.storm.trident.testing
org.apache.storm.trident.windowing

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

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

Modifier and Type	Class and Description
class	CassandraQuery
class	CassandraStateUpdater

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

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

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 Operation in org.apache.storm.elasticsearch.trident

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

Modifier and Type	Class and Description
class	EsUpdater

Uses of Operation in org.apache.storm.eventhubs.samples

Classes in org.apache.storm.eventhubs.samples that implement Operation

Modifier and Type	Class and Description
static class	TransactionalTridentEventCount.LoggingFilter

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

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

Modifier and Type	Class and Description
class	HBaseQuery
class	HBaseUpdater

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

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

Modifier and Type	Class and Description
class	HdfsUpdater

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

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

Modifier and Type	Class and Description
class	HiveUpdater

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

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

Modifier and Type	Class and Description
class	JdbcQuery
class	JdbcUpdater

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

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

Modifier and Type	Class and Description
class	JmsUpdater

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

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

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

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

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

Modifier and Type	Class and Description
class	MongoStateUpdater

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

Classes in org.apache.storm.mqtt.trident that implement Operation

Modifier and Type	Class and Description
class	MqttPublishFunction

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

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

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

Uses of Operation in org.apache.storm.redis.trident

Classes in org.apache.storm.redis.trident that implement Operation

Modifier and Type	Class and Description
class	PrintFunction

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

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

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 Operation in org.apache.storm.solr.trident

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

Modifier and Type	Class and Description
class	SolrUpdater

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

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

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

Uses of Operation in org.apache.storm.sql.runtime.trident.functions

Classes in org.apache.storm.sql.runtime.trident.functions that implement Operation

Modifier and Type	Class and Description
class	EvaluationCalc
class	EvaluationFilter
class	EvaluationFunction
class	ForwardFunction

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

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

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

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

Subinterfaces of Operation in org.apache.storm.trident.operation

Modifier and Type	Interface and Description
interface	Aggregator<T>
interface	EachOperation
interface	Filter Filters take in a tuple as input and decide whether or not to keep that tuple or not.
interface	Function A function takes in a set of input fields and emits zero or more tuples as output.
interface	OperationAwareFlatMapFunction A one to many transformation function which is aware of Operation (lifecycle of the Trident component)
interface	OperationAwareMapFunction A one-one transformation function which is aware of Operation (lifecycle of the Trident component)

Classes in org.apache.storm.trident.operation that implement Operation

Modifier and Type	Class and Description
class	BaseAggregator<T>
class	BaseFilter
class	BaseFunction
class	BaseOperation Convenience implementation of the Operation interface.

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

Classes in org.apache.storm.trident.operation.builtin that implement Operation

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	Negate A Filter implementation that inverts another delegate Filter.
class	SnapshotGet
class	TupleCollectionGet

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

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

Modifier and Type	Class and Description
class	ChainedAggregatorImpl
class	CombinerAggregatorCombineImpl
class	CombinerAggregatorInitImpl
class	CombinerAggStateUpdater
class	ConsumerExecutor
class	FilterExecutor
class	FlatMapFunctionExecutor
class	GroupedAggregator
class	MapFunctionExecutor
class	ReducerAggregatorImpl
class	ReducerAggStateUpdater
class	SingleEmitAggregator
class	TrueFilter

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

Subinterfaces of Operation in org.apache.storm.trident.state

Modifier and Type	Interface and Description
interface	QueryFunction<S extends State,T>
interface	StateUpdater<S extends State>

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

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

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

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

Modifier and Type	Class and Description
class	MapCombinerAggStateUpdater
class	MapReducerAggStateUpdater

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

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

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

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

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

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