Package org.apache.storm.trident.planner

Class SubtopologyBolt.InitialReceiver

java.lang.Object

org.apache.storm.trident.planner.SubtopologyBolt.InitialReceiver

Enclosing class:

SubtopologyBolt

protected static class SubtopologyBolt.InitialReceiver
extends Object

Constructor Summary

Constructors

Constructor	Description
InitialReceiver(String stream, Fields allFields)

Method Summary

Modifier and Type	Method	Description
void	addReceiver(TridentProcessor p)
TridentTuple.Factory	getOutputFactory()
void	receive(ProcessorContext context, Tuple tuple)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InitialReceiver

public InitialReceiver(String stream,
                       Fields allFields)

Method Detail

receive

public void receive(ProcessorContext context,
                    Tuple tuple)

addReceiver

public void addReceiver(TridentProcessor p)

getOutputFactory

public TridentTuple.Factory getOutputFactory()