Uses of Class
org.apache.storm.messaging.TaskMessage
-
Packages that use TaskMessage Package Description org.apache.storm.messaging org.apache.storm.messaging.netty org.apache.storm.utils -
-
Uses of TaskMessage in org.apache.storm.messaging
Methods in org.apache.storm.messaging with parameters of type TaskMessage Modifier and Type Method Description protected voidDeserializingConnectionCallback. updateMetrics(int sourceTaskId, TaskMessage message)Update serialized byte counts for each message.Method parameters in org.apache.storm.messaging with type arguments of type TaskMessage Modifier and Type Method Description voidDeserializingConnectionCallback. recv(List<TaskMessage> batch)voidIConnectionCallback. recv(List<TaskMessage> batch)A batch of new messages have arrived to be processed.voidIConnection. send(Iterator<TaskMessage> msgs)send batch messages. -
Uses of TaskMessage in org.apache.storm.messaging.netty
Methods in org.apache.storm.messaging.netty with parameters of type TaskMessage Modifier and Type Method Description org.apache.storm.messaging.netty.MessageBatchMessageBuffer. add(TaskMessage msg)Method parameters in org.apache.storm.messaging.netty with type arguments of type TaskMessage Modifier and Type Method Description voidClient. send(Iterator<TaskMessage> msgs)Enqueue task messages to be sent to the remote destination (cf. -
Uses of TaskMessage in org.apache.storm.utils
Methods in org.apache.storm.utils with parameters of type TaskMessage Modifier and Type Method Description voidTransferDrainer. add(TaskMessage taskMsg)
-