Uses of Class
org.apache.storm.trident.operation.BaseOperation
Package
Description
ElasticSearch Trident example classes.
-
Uses of BaseOperation in org.apache.storm.elasticsearch.trident
-
Uses of BaseOperation in org.apache.storm.hdfs.trident
-
Uses of BaseOperation in org.apache.storm.hive.trident
-
Uses of BaseOperation in org.apache.storm.jdbc.trident.state
-
Uses of BaseOperation in org.apache.storm.jms.trident
-
Uses of BaseOperation in org.apache.storm.kafka.trident
-
Uses of BaseOperation in org.apache.storm.redis.trident
-
Uses of BaseOperation 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 BaseOperation in org.apache.storm.starter.trident
Modifier and TypeClassDescriptionstatic class
static class
-
Uses of BaseOperation in org.apache.storm.trident.operation
-
Uses of BaseOperation 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
class
-
Uses of BaseOperation in org.apache.storm.trident.operation.impl
Modifier and TypeClassDescriptionclass
class
class
-
Uses of BaseOperation in org.apache.storm.trident.state
Modifier and TypeClassDescriptionclass
BaseQueryFunction<S extends State,
T> class
BaseStateUpdater<S extends State>
-
Uses of BaseOperation in org.apache.storm.trident.testing
Modifier and TypeClassDescriptionclass
class
class
class
class