Uses of Interface
org.apache.storm.streams.processors.Processor

Packages that use Processor

Package	Description
org.apache.storm.streams
org.apache.storm.streams.processors

Uses of Processor in org.apache.storm.streams

Methods in org.apache.storm.streams that return Processor

Modifier and Type	Method and Description
Processor<?>	ProcessorNode.getProcessor()

Constructors in org.apache.storm.streams with parameters of type Processor

Constructor and Description
ProcessorNode(Processor<?> processor, String outputStream, Fields outputFields)
ProcessorNode(Processor<?> processor, String outputStream, Fields outputFields, boolean preservesKey)

Uses of Processor in org.apache.storm.streams.processors

Classes in org.apache.storm.streams.processors that implement Processor

Modifier and Type	Class and Description
class	AggregateByKeyProcessor<K,V,A,R>
class	AggregateProcessor<T,A,R>
class	BranchProcessor<T>
class	CoGroupByKeyProcessor<K,V1,V2> co-group by key implementation
class	FilterProcessor<T>
class	FlatMapProcessor<T,R>
class	FlatMapValuesProcessor<K,V,R>
class	ForEachProcessor<T>
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	PeekProcessor<T>
class	ReduceByKeyProcessor<K,V>
class	ReduceProcessor<T>
class	StateQueryProcessor<K,V>
class	UpdateStateByKeyProcessor<K,V,R>