Uses of Interface
org.apache.storm.trident.planner.TridentProcessor

Packages that use TridentProcessor

Package	Description
org.apache.storm.trident.planner
org.apache.storm.trident.planner.processor
org.apache.storm.trident.windowing

Uses of TridentProcessor in org.apache.storm.trident.planner

Fields in org.apache.storm.trident.planner declared as TridentProcessor

Modifier and Type	Field and Description
TridentProcessor	ProcessorNode.processor

Methods in org.apache.storm.trident.planner with parameters of type TridentProcessor

Modifier and Type	Method and Description
void	SubtopologyBolt.InitialReceiver.addReceiver(TridentProcessor p)

Constructors in org.apache.storm.trident.planner with parameters of type TridentProcessor

Constructor and Description
ProcessorNode(String streamId, String name, Fields allOutputFields, Fields selfOutFields, TridentProcessor processor)

Uses of TridentProcessor in org.apache.storm.trident.planner.processor

Classes in org.apache.storm.trident.planner.processor that implement TridentProcessor

Modifier and Type	Class and Description
class	AggregateProcessor
class	EachProcessor
class	MapProcessor Processor for executing Stream.map(MapFunction) and Stream.flatMap(FlatMapFunction) functions.
class	MultiReducerProcessor
class	PartitionPersistProcessor
class	ProjectedProcessor
class	StateQueryProcessor

Uses of TridentProcessor in org.apache.storm.trident.windowing

Classes in org.apache.storm.trident.windowing that implement TridentProcessor

Modifier and Type	Class and Description
class	WindowTridentProcessor TridentProcessor implementation for windowing operations on trident stream.