| Package | Description | 
|---|---|
| org.apache.storm.streams.processors | 
| Modifier and Type | Class and 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>  | 
Copyright © 2019 The Apache Software Foundation. All rights reserved.