Class TridentContext
- java.lang.Object
-
- org.apache.storm.trident.planner.processor.TridentContext
-
public class TridentContext extends Object
-
-
Constructor Summary
Constructors Constructor Description TridentContext(Fields selfFields, List<TridentTuple.Factory> parentFactories, List<String> parentStreams, List<TupleReceiver> receivers, String outStreamId, int stateIndex, BatchOutputCollector collector)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description BatchOutputCollectorgetDelegateCollector()StringgetOutStreamId()List<String>getParentStreams()List<TridentTuple.Factory>getParentTupleFactories()List<TupleReceiver>getReceivers()FieldsgetSelfOutputFields()intgetStateIndex()
-
-
-
Constructor Detail
-
TridentContext
public TridentContext(Fields selfFields, List<TridentTuple.Factory> parentFactories, List<String> parentStreams, List<TupleReceiver> receivers, String outStreamId, int stateIndex, BatchOutputCollector collector)
-
-
Method Detail
-
getParentTupleFactories
public List<TridentTuple.Factory> getParentTupleFactories()
-
getSelfOutputFields
public Fields getSelfOutputFields()
-
getReceivers
public List<TupleReceiver> getReceivers()
-
getOutStreamId
public String getOutStreamId()
-
getStateIndex
public int getStateIndex()
-
getDelegateCollector
public BatchOutputCollector getDelegateCollector()
-
-