Uses of Package
org.apache.storm.trident.operation

Packages that use org.apache.storm.trident.operation

Package	Description
org.apache.storm.cassandra.trident.state
org.apache.storm.elasticsearch.trident	ElasticSearch Trident example classes.
org.apache.storm.eventhubs.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.spout.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
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.spout
org.apache.storm.starter.trident
org.apache.storm.trident
org.apache.storm.trident.drpc
org.apache.storm.trident.fluent
org.apache.storm.trident.operation
org.apache.storm.trident.operation.builtin
org.apache.storm.trident.operation.impl
org.apache.storm.trident.planner
org.apache.storm.trident.planner.processor
org.apache.storm.trident.spout
org.apache.storm.trident.state
org.apache.storm.trident.state.map
org.apache.storm.trident.testing
org.apache.storm.trident.windowing

Classes in org.apache.storm.trident.operation used by org.apache.storm.cassandra.trident.state

Class and Description
BaseOperation Convenience implementation of the Operation interface.
EachOperation
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).

Classes in org.apache.storm.trident.operation used by org.apache.storm.elasticsearch.trident

Class and Description
BaseOperation Convenience implementation of the Operation interface.
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).

Classes in org.apache.storm.trident.operation used by org.apache.storm.eventhubs.trident

Class and Description
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).

Classes in org.apache.storm.trident.operation used by org.apache.storm.hbase.trident.state

Class and Description
BaseOperation Convenience implementation of the Operation interface.
EachOperation
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).

Classes in org.apache.storm.trident.operation used by org.apache.storm.hdfs.trident

Class and Description
BaseOperation Convenience implementation of the Operation interface.
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).

Classes in org.apache.storm.trident.operation used by org.apache.storm.hive.trident

Class and Description
BaseOperation Convenience implementation of the Operation interface.
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).

Classes in org.apache.storm.trident.operation used by org.apache.storm.jdbc.trident.state

Class and Description
BaseOperation Convenience implementation of the Operation interface.
EachOperation
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).

Classes in org.apache.storm.trident.operation used by org.apache.storm.jms.trident

Class and Description
BaseOperation Convenience implementation of the Operation interface.
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).

Classes in org.apache.storm.trident.operation used by org.apache.storm.kafka.spout.trident

Class and Description
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).

Classes in org.apache.storm.trident.operation used by org.apache.storm.kafka.trident

Class and Description
BaseOperation Convenience implementation of the Operation interface.
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).

Classes in org.apache.storm.trident.operation used by org.apache.storm.mongodb.trident

Class and Description
BaseFunction
BaseOperation Convenience implementation of the Operation interface.
EachOperation
Function A function takes in a set of input fields and emits zero or more tuples as output.
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).

Classes in org.apache.storm.trident.operation used by org.apache.storm.mongodb.trident.state

Class and Description
BaseOperation Convenience implementation of the Operation interface.
EachOperation
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).

Classes in org.apache.storm.trident.operation used by org.apache.storm.mqtt.trident

Class and Description
BaseFunction
BaseOperation Convenience implementation of the Operation interface.
EachOperation
Function A function takes in a set of input fields and emits zero or more tuples as output.
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
TridentOperationContext

Classes in org.apache.storm.trident.operation used by org.apache.storm.opentsdb

Class and Description
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).

Classes in org.apache.storm.trident.operation used by org.apache.storm.opentsdb.trident

Class and Description
BaseOperation Convenience implementation of the Operation interface.
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).

Classes in org.apache.storm.trident.operation used by org.apache.storm.redis.trident.state

Class and Description
BaseOperation Convenience implementation of the Operation interface.
EachOperation
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).

Classes in org.apache.storm.trident.operation used by org.apache.storm.rocketmq.trident.state

Class and Description
BaseOperation Convenience implementation of the Operation interface.
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).

Classes in org.apache.storm.trident.operation used by org.apache.storm.solr.trident

Class and Description
BaseOperation Convenience implementation of the Operation interface.
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).

Classes in org.apache.storm.trident.operation used by org.apache.storm.starter.spout

Class and Description
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).

Classes in org.apache.storm.trident.operation used by org.apache.storm.starter.trident

Class and Description
BaseFunction
BaseOperation Convenience implementation of the Operation interface.
CombinerAggregator
EachOperation
Function A function takes in a set of input fields and emits zero or more tuples as output.
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).

Classes in org.apache.storm.trident.operation used by org.apache.storm.trident

Class and Description
Aggregator
Assembly The Assembly interface provides a means to encapsulate logic applied to a Stream.
CombinerAggregator
Consumer Represents an operation that accepts a single input argument and returns no result.
DefaultResourceDeclarer Default implementation of resources declarer.
Filter Filters take in a tuple as input and decide whether or not to keep that tuple or not.
FlatMapFunction A one to many transformation function.
Function A function takes in a set of input fields and emits zero or more tuples as output.
GroupedMultiReducer
MapFunction A one-one transformation function.
MultiReducer
ReducerAggregator

Classes in org.apache.storm.trident.operation used by org.apache.storm.trident.drpc

Class and Description
MultiReducer
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
TridentMultiReducerContext

Classes in org.apache.storm.trident.operation used by org.apache.storm.trident.fluent

Class and Description
Aggregator
CombinerAggregator
Function A function takes in a set of input fields and emits zero or more tuples as output.
ReducerAggregator

Classes in org.apache.storm.trident.operation used by org.apache.storm.trident.operation

Class and Description
Aggregator
BaseOperation Convenience implementation of the Operation interface.
DefaultResourceDeclarer Default implementation of resources declarer.
EachOperation
Filter Filters take in a tuple as input and decide whether or not to keep that tuple or not.
FlatMapFunction A one to many transformation function.
Function A function takes in a set of input fields and emits zero or more tuples as output.
ITridentResource This interface is implemented by various Trident classes in order to gather and propogate resources that have been set on them.
MapFunction A one-one transformation function.
MultiReducer
Operation Parent interface for Trident Filters and Functions.
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
TridentMultiReducerContext
TridentOperationContext

Classes in org.apache.storm.trident.operation used by org.apache.storm.trident.operation.builtin

Class and Description
Aggregator
Assembly The Assembly interface provides a means to encapsulate logic applied to a Stream.
BaseAggregator
BaseFilter
BaseOperation Convenience implementation of the Operation interface.
CombinerAggregator
EachOperation
Filter Filters take in a tuple as input and decide whether or not to keep that tuple or not.
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
TridentOperationContext

Classes in org.apache.storm.trident.operation used by org.apache.storm.trident.operation.impl

Class and Description
Aggregator
BaseOperation Convenience implementation of the Operation interface.
CombinerAggregator
Consumer Represents an operation that accepts a single input argument and returns no result.
EachOperation
Filter Filters take in a tuple as input and decide whether or not to keep that tuple or not.
FlatMapFunction A one to many transformation function.
Function A function takes in a set of input fields and emits zero or more tuples as output.
GroupedMultiReducer
MapFunction A one-one transformation function.
MultiReducer
ReducerAggregator
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
TridentMultiReducerContext
TridentOperationContext

Classes in org.apache.storm.trident.operation used by org.apache.storm.trident.planner

Class and Description
DefaultResourceDeclarer Default implementation of resources declarer.
ITridentResource This interface is implemented by various Trident classes in order to gather and propogate resources that have been set on them.

Classes in org.apache.storm.trident.operation used by org.apache.storm.trident.planner.processor

Class and Description
Aggregator
Function A function takes in a set of input fields and emits zero or more tuples as output.
MultiReducer
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).

Classes in org.apache.storm.trident.operation used by org.apache.storm.trident.spout

Class and Description
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).

Classes in org.apache.storm.trident.operation used by org.apache.storm.trident.state

Class and Description
BaseOperation Convenience implementation of the Operation interface.
CombinerAggregator
EachOperation
Operation Parent interface for Trident Filters and Functions.
ReducerAggregator
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).

Classes in org.apache.storm.trident.operation used by org.apache.storm.trident.state.map

Class and Description
CombinerAggregator
ReducerAggregator
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
TridentOperationContext

Classes in org.apache.storm.trident.operation used by org.apache.storm.trident.testing

Class and Description
Aggregator
BaseAggregator
BaseFilter
BaseFunction
BaseOperation Convenience implementation of the Operation interface.
EachOperation
Function A function takes in a set of input fields and emits zero or more tuples as output.
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).

Classes in org.apache.storm.trident.operation used by org.apache.storm.trident.windowing

Class and Description
Aggregator
TridentCollector Interface for publishing tuples to a stream and reporting exceptions (to be displayed in Storm UI).
TridentOperationContext