Uses of Interface
org.apache.storm.trident.operation.Operation
Package
Description
ElasticSearch Trident example classes.
-
Uses of Operation in org.apache.storm.elasticsearch.trident
-
Uses of Operation in org.apache.storm.hdfs.trident
-
Uses of Operation in org.apache.storm.hive.trident
-
Uses of Operation in org.apache.storm.jdbc.trident.state
-
Uses of Operation in org.apache.storm.jms.trident
-
Uses of Operation in org.apache.storm.kafka.trident
-
Uses of Operation in org.apache.storm.redis.trident
-
Uses of Operation in org.apache.storm.redis.trident.state
Modifier and TypeClassDescriptionclass
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
BaseQueryFunction implementation for Redis Cluster environment.class
BaseStateUpdater implementation for Redis Cluster environment.class
BaseQueryFunction implementation for single Redis environment.class
BaseStateUpdater implementation for single Redis environment. -
Uses of Operation in org.apache.storm.starter.trident
Modifier and TypeClassDescriptionstatic class
static class
-
Uses of Operation in org.apache.storm.trident.operation
Modifier and TypeInterfaceDescriptioninterface
Aggregator<T>
interface
interface
Filters take in a tuple as input and decide whether or not to keep that tuple or not.interface
A function takes in a set of input fields and emits zero or more tuples as output.interface
A one to many transformation function which is aware of Operation (lifecycle of the Trident component).interface
A one-one transformation function which is aware of Operation (lifecycle of the Trident component).Modifier and TypeClassDescriptionclass
class
class
class
Convenience implementation of theOperation
interface. -
Uses of Operation in org.apache.storm.trident.operation.builtin
Modifier and TypeClassDescriptionclass
AbstractAggregator
for comparing two values in a stream.class
Filter for debugging purposes.class
class
Simple `Filter` implementation that filters out any tuples that have fields with a value of `null`.static class
static class
class
class
This aggregator computes the maximum of aggregated tuples in a stream.class
This aggregator computes the maximum of aggregated tuples in a stream.class
This aggregator computes the minimum of aggregated tuples in a stream.class
This aggregator computes the minimum of aggregated tuples in a stream.class
A `Filter` implementation that inverts another delegate `Filter`.class
class
-
Uses of Operation in org.apache.storm.trident.operation.impl
Modifier and TypeClassDescriptionclass
class
class
class
class
class
class
class
class
class
class
class
class
-
Uses of Operation in org.apache.storm.trident.state
Modifier and TypeInterfaceDescriptioninterface
QueryFunction<S extends State,
T> interface
StateUpdater<S extends State>
Modifier and TypeClassDescriptionclass
BaseQueryFunction<S extends State,
T> class
BaseStateUpdater<S extends State>
-
Uses of Operation in org.apache.storm.trident.state.map
Modifier and TypeClassDescriptionclass
class
-
Uses of Operation in org.apache.storm.trident.testing
Modifier and TypeClassDescriptionclass
class
class
class
class
-
Uses of Operation in org.apache.storm.trident.windowing
Modifier and TypeClassDescriptionclass
StateUpdater<WindowState>
instance which removes successfully emitted triggers from store.