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.druid.trident
org.apache.storm.elasticsearch.trident
org.apache.storm.eventhubs.samples
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.state
org.apache.storm.mqtt.trident
org.apache.storm.opentsdb
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.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
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).

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

Class and Description
BaseOperation Convenience implementation of the Operation interface.
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).

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

Class and Description
BaseOperation Convenience implementation of the Operation interface.
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).

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

Class and Description
BaseFilter
BaseOperation Convenience implementation of the Operation interface.
EachOperation
Filter Filters take in a tuple as input and decide whether or not to keep that tuple or not.
Operation Parent interface for Trident Filters and Functions.

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
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).

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

Class and Description
BaseOperation Convenience implementation of the Operation interface.
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).

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

Class and Description
BaseOperation Convenience implementation of the Operation interface.
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).

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
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).

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

Class and Description
BaseOperation Convenience implementation of the Operation interface.
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).

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.
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).

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.
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).

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.
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).
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.
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).

Classes in org.apache.storm.trident.operation used by org.apache.storm.redis.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.
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).

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
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).

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

Class and Description
BaseOperation Convenience implementation of the Operation interface.
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).

Classes in org.apache.storm.trident.operation used by org.apache.storm.sql.runtime.datasource.socket.trident

Class and Description
BaseOperation Convenience implementation of the Operation interface.
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).

Classes in org.apache.storm.trident.operation used by org.apache.storm.sql.runtime.trident.functions

Class and Description
BaseFilter
BaseFunction
BaseOperation Convenience implementation of the Operation interface.
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.
MapFunction A one-one transformation function
Operation Parent interface for Trident Filters and Functions.
OperationAwareFlatMapFunction A one to many transformation function which is aware of Operation (lifecycle of the Trident component)
OperationAwareMapFunction A one-one transformation function which is aware of Operation (lifecycle of the Trident component)
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.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.
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).

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
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
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.
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).
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
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).
TridentMultiReducerContext
TridentOperationContext

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

Class and Description
DefaultResourceDeclarer
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
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).
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.
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).

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

Class and Description
Aggregator
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).
TridentOperationContext