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 class
TopologyContext
A `TopologyContext` is given to bolts and spouts in their `prepare()` and `open()` methods, respectively.class
WorkerTopologyContext
class
WorkerUserContext
-
Uses of GeneralTopologyContext in org.apache.storm.tuple
Methods in org.apache.storm.tuple that return GeneralTopologyContext Modifier and Type Method Description GeneralTopologyContext
Tuple. getContext()
Gets the topology context associated with the tuple.GeneralTopologyContext
TupleImpl. getContext()
Methods in org.apache.storm.tuple with parameters of type GeneralTopologyContext Modifier and Type Method Description static AddressedTuple
AddressedTuple. 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)
-