Uses of Interface
org.apache.storm.streams.processors.BatchProcessor
Packages that use BatchProcessor
-
Uses of BatchProcessor in org.apache.storm.streams.processors
Classes in org.apache.storm.streams.processors that implement BatchProcessorModifier and TypeClassDescriptionclassAggregateByKeyProcessor<K,V, A, R> classAggregateProcessor<T,A, R> classCoGroupByKeyProcessor<K,V1, V2> co-group by key implementation.classJoinProcessor<K,R, V1, V2> Provides equi-join implementation based on simple hash-join.classMergeAggregateByKeyProcessor<K,V, A, R> classMergeAggregateProcessor<T,A, R> classReduceByKeyProcessor<K,V> class