Uses of Interface
org.apache.storm.streams.processors.Processor
-
Uses of Processor in org.apache.storm.streams
ModifierConstructorDescriptionProcessorNode
(Processor<?> processor, String outputStream, Fields outputFields) ProcessorNode
(Processor<?> processor, String outputStream, Fields outputFields, boolean preservesKey) -
Uses of Processor in org.apache.storm.streams.processors
Modifier and TypeClassDescriptionclass
AggregateByKeyProcessor<K,
V, A, R> class
AggregateProcessor<T,
A, R> class
class
CoGroupByKeyProcessor<K,
V1, V2> co-group by key implementation.class
class
FlatMapProcessor<T,
R> class
FlatMapValuesProcessor<K,
V, R> class
class
JoinProcessor<K,
R, V1, V2> Provides equi-join implementation based on simple hash-join.class
MapProcessor<T,
R> class
MapValuesProcessor<K,
V, R> class
MergeAggregateByKeyProcessor<K,
V, A, R> class
MergeAggregateProcessor<T,
A, R> class
class
ReduceByKeyProcessor<K,
V> class
class
StateQueryProcessor<K,
V> class
UpdateStateByKeyProcessor<K,
V, R>