storm.trident.planner.processor
Class TridentContext

java.lang.Object
  storm.trident.planner.processor.TridentContext

public class TridentContext
extends java.lang.Object

Constructor Summary

TridentContext(Fields selfFields, java.util.List<TridentTuple.Factory> parentFactories, java.util.List<java.lang.String> parentStreams, java.util.List<TupleReceiver> receivers, java.lang.String outStreamId, int stateIndex, BatchOutputCollector collector)

Method Summary

BatchOutputCollector	getDelegateCollector()
java.lang.String	getOutStreamId()
java.util.List<java.lang.String>	getParentStreams()
java.util.List<TridentTuple.Factory>	getParentTupleFactories()
java.util.List<TupleReceiver>	getReceivers()
Fields	getSelfOutputFields()
int	getStateIndex()

Methods inherited from class java.lang.Object

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

Constructor Detail

TridentContext

public TridentContext(Fields selfFields,
                      java.util.List<TridentTuple.Factory> parentFactories,
                      java.util.List<java.lang.String> parentStreams,
                      java.util.List<TupleReceiver> receivers,
                      java.lang.String outStreamId,
                      int stateIndex,
                      BatchOutputCollector collector)

Method Detail

getParentTupleFactories

public java.util.List<TridentTuple.Factory> getParentTupleFactories()

getSelfOutputFields

public Fields getSelfOutputFields()

getParentStreams

public java.util.List<java.lang.String> getParentStreams()

getReceivers

public java.util.List<TupleReceiver> getReceivers()

getOutStreamId

public java.lang.String getOutStreamId()

getStateIndex

public int getStateIndex()

getDelegateCollector

public BatchOutputCollector getDelegateCollector()