Uses of Interface
org.apache.storm.streams.processors.BatchProcessor
-
Packages that use BatchProcessor Package Description org.apache.storm.streams.processors -
-
Uses of BatchProcessor in org.apache.storm.streams.processors
Classes in org.apache.storm.streams.processors that implement BatchProcessor Modifier and Type Class Description class
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
ReduceProcessor<T>
-