Uses of Class
org.apache.storm.messaging.TaskMessage
Packages that use TaskMessage
Package
Description
-
Uses of TaskMessage in org.apache.storm.messaging
Methods in org.apache.storm.messaging with parameters of type TaskMessageModifier and TypeMethodDescriptionprotected 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 TaskMessageModifier and TypeMethodDescriptionvoidDeserializingConnectionCallback.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 TaskMessageModifier and TypeMethodDescriptionorg.apache.storm.messaging.netty.MessageBatchMessageBuffer.add(TaskMessage msg) Method parameters in org.apache.storm.messaging.netty with type arguments of type TaskMessageModifier and TypeMethodDescriptionvoidClient.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