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	Description
TridentProcessor	ProcessorNode.processor

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

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

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

Constructor	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	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	Description
class	WindowTridentProcessor	TridentProcessor implementation for windowing operations on trident stream.