Uses of Interface
org.apache.storm.trident.operation.EachOperation
-
-
Uses of EachOperation in org.apache.storm.jdbc.trident.state
Classes in org.apache.storm.jdbc.trident.state that implement EachOperation Modifier and Type Class Description class
JdbcQuery
-
Uses of EachOperation in org.apache.storm.redis.trident
Classes in org.apache.storm.redis.trident that implement EachOperation Modifier and Type Class Description class
PrintFunction
-
Uses of EachOperation in org.apache.storm.redis.trident.state
Classes in org.apache.storm.redis.trident.state that implement EachOperation Modifier and Type Class Description class
AbstractRedisStateQuerier<T extends State>
AbstractRedisStateQuerier is base class of any RedisStateQuerier, which implements BaseQueryFunction.class
RedisClusterStateQuerier
BaseQueryFunction implementation for Redis Cluster environment.class
RedisStateQuerier
BaseQueryFunction implementation for single Redis environment. -
Uses of EachOperation in org.apache.storm.starter.trident
Classes in org.apache.storm.starter.trident that implement EachOperation Modifier and Type Class Description static class
TridentReach.ExpandList
static class
TridentWordCount.Split
-
Uses of EachOperation in org.apache.storm.trident.operation
Subinterfaces of EachOperation in org.apache.storm.trident.operation Modifier and Type Interface Description interface
Filter
Filters take in a tuple as input and decide whether or not to keep that tuple or not.interface
Function
A function takes in a set of input fields and emits zero or more tuples as output.Classes in org.apache.storm.trident.operation that implement EachOperation Modifier and Type Class Description class
BaseFilter
class
BaseFunction
-
Uses of EachOperation in org.apache.storm.trident.operation.builtin
Classes in org.apache.storm.trident.operation.builtin that implement EachOperation Modifier and Type Class Description 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`.class
MapGet
class
Negate
A `Filter` implementation that inverts another delegate `Filter`.class
SnapshotGet
class
TupleCollectionGet
-
Uses of EachOperation in org.apache.storm.trident.operation.impl
Classes in org.apache.storm.trident.operation.impl that implement EachOperation Modifier and Type Class Description class
CombinerAggregatorInitImpl
class
ConsumerExecutor
class
FilterExecutor
class
FlatMapFunctionExecutor
class
MapFunctionExecutor
class
TrueFilter
-
Uses of EachOperation in org.apache.storm.trident.state
Subinterfaces of EachOperation in org.apache.storm.trident.state Modifier and Type Interface Description interface
QueryFunction<S extends State,T>
Classes in org.apache.storm.trident.state that implement EachOperation Modifier and Type Class Description class
BaseQueryFunction<S extends State,T>
-
Uses of EachOperation in org.apache.storm.trident.testing
Classes in org.apache.storm.trident.testing that implement EachOperation Modifier and Type Class Description class
Split
class
StringLength
class
TrueFilter
class
TuplifyArgs
-