Uses of Interface
org.apache.storm.streams.processors.BatchProcessor
-
Uses of BatchProcessor in org.apache.storm.streams.processors
Modifier and TypeClassDescriptionclass
AggregateByKeyProcessor<K,
V, A, R> class
AggregateProcessor<T,
A, R> class
CoGroupByKeyProcessor<K,
V1, V2> co-group by key implementation.class
JoinProcessor<K,
R, V1, V2> Provides equi-join implementation based on simple hash-join.class
MergeAggregateByKeyProcessor<K,
V, A, R> class
MergeAggregateProcessor<T,
A, R> class
ReduceByKeyProcessor<K,
V> class