Uses of Class
org.apache.storm.task.GeneralTopologyContext
-
Packages that use GeneralTopologyContext Package Description org.apache.storm.messaging org.apache.storm.serialization org.apache.storm.task org.apache.storm.tuple -
-
Uses of GeneralTopologyContext in org.apache.storm.messaging
Constructors in org.apache.storm.messaging with parameters of type GeneralTopologyContext Constructor Description DeserializingConnectionCallback(Map<String,Object> conf, GeneralTopologyContext context, WorkerState.ILocalTransferCallback callback) -
Uses of GeneralTopologyContext in org.apache.storm.serialization
Constructors in org.apache.storm.serialization with parameters of type GeneralTopologyContext Constructor Description KryoTupleDeserializer(Map<String,Object> conf, GeneralTopologyContext context)KryoTupleSerializer(Map<String,Object> conf, GeneralTopologyContext context) -
Uses of GeneralTopologyContext in org.apache.storm.task
Subclasses of GeneralTopologyContext in org.apache.storm.task Modifier and Type Class Description classTopologyContextA `TopologyContext` is given to bolts and spouts in their `prepare()` and `open()` methods, respectively.classWorkerTopologyContextclassWorkerUserContext -
Uses of GeneralTopologyContext in org.apache.storm.tuple
Methods in org.apache.storm.tuple that return GeneralTopologyContext Modifier and Type Method Description GeneralTopologyContextTuple. getContext()Gets the topology context associated with the tuple.GeneralTopologyContextTupleImpl. getContext()Methods in org.apache.storm.tuple with parameters of type GeneralTopologyContext Modifier and Type Method Description static AddressedTupleAddressedTuple. createFlushTuple(GeneralTopologyContext workerTopologyContext)Constructors in org.apache.storm.tuple with parameters of type GeneralTopologyContext Constructor Description TupleImpl(GeneralTopologyContext context, List<Object> values, String srcComponent, int taskId, String streamId)TupleImpl(GeneralTopologyContext context, List<Object> values, String srcComponent, int taskId, String streamId, MessageId id)
-