storm.trident.planner

Class SubtopologyBolt.InitialReceiver

java.lang.Object

storm.trident.planner.SubtopologyBolt.InitialReceiver

Enclosing class:

SubtopologyBolt

protected class SubtopologyBolt.InitialReceiver
extends Object

Constructor Summary

Constructors

Constructor and Description
SubtopologyBolt.InitialReceiver(String stream, Fields allFields)

Method Summary

Methods

Modifier and Type	Method and 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

SubtopologyBolt.InitialReceiver

public SubtopologyBolt.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()