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.