Uses of Class
org.apache.storm.trident.operation.BaseOperation
-
-
Uses of BaseOperation in org.apache.storm.hdfs.trident
Subclasses of BaseOperation in org.apache.storm.hdfs.trident Modifier and Type Class Description class
HdfsUpdater
-
Uses of BaseOperation in org.apache.storm.hive.trident
Subclasses of BaseOperation in org.apache.storm.hive.trident Modifier and Type Class Description class
HiveUpdater
Deprecated, for removal: This API element is subject to removal in a future version. -
Uses of BaseOperation in org.apache.storm.jdbc.trident.state
Subclasses of BaseOperation in org.apache.storm.jdbc.trident.state Modifier and Type Class Description class
JdbcQuery
class
JdbcUpdater
-
Uses of BaseOperation in org.apache.storm.jms.trident
Subclasses of BaseOperation in org.apache.storm.jms.trident Modifier and Type Class Description class
JmsUpdater
-
Uses of BaseOperation in org.apache.storm.kafka.trident
Subclasses of BaseOperation in org.apache.storm.kafka.trident Modifier and Type Class Description class
TridentKafkaStateUpdater<K,V>
-
Uses of BaseOperation in org.apache.storm.redis.trident
Subclasses of BaseOperation in org.apache.storm.redis.trident Modifier and Type Class Description class
PrintFunction
-
Uses of BaseOperation in org.apache.storm.redis.trident.state
Subclasses of BaseOperation in org.apache.storm.redis.trident.state Modifier and Type Class 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 BaseOperation in org.apache.storm.starter.trident
Subclasses of BaseOperation in org.apache.storm.starter.trident Modifier and Type Class Description static class
TridentReach.ExpandList
static class
TridentWordCount.Split
-
Uses of BaseOperation in org.apache.storm.trident.operation
Subclasses of BaseOperation in org.apache.storm.trident.operation Modifier and Type Class Description class
BaseAggregator<T>
class
BaseFilter
class
BaseFunction
-
Uses of BaseOperation in org.apache.storm.trident.operation.builtin
Subclasses of BaseOperation in org.apache.storm.trident.operation.builtin Modifier and Type Class Description class
ComparisonAggregator<T>
AbstractAggregator
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
SnapshotGet
class
TupleCollectionGet
-
Uses of BaseOperation in org.apache.storm.trident.operation.impl
Subclasses of BaseOperation in org.apache.storm.trident.operation.impl Modifier and Type Class Description class
ConsumerExecutor
class
FlatMapFunctionExecutor
class
MapFunctionExecutor
-
Uses of BaseOperation in org.apache.storm.trident.state
Subclasses of BaseOperation in org.apache.storm.trident.state Modifier and Type Class Description class
BaseQueryFunction<S extends State,T>
class
BaseStateUpdater<S extends State>
-
Uses of BaseOperation in org.apache.storm.trident.testing
Subclasses of BaseOperation in org.apache.storm.trident.testing Modifier and Type Class Description class
CountAsAggregator
class
Split
class
StringLength
class
TrueFilter
class
TuplifyArgs
-