Package | Description |
---|---|
org.apache.storm.messaging | |
org.apache.storm.messaging.netty | |
org.apache.storm.utils |
Modifier and Type | Method and Description |
---|---|
protected void |
DeserializingConnectionCallback.updateMetrics(int sourceTaskId,
TaskMessage message)
Update serialized byte counts for each message.
|
Modifier and Type | Method and Description |
---|---|
void |
DeserializingConnectionCallback.recv(List<TaskMessage> batch) |
void |
IConnectionCallback.recv(List<TaskMessage> batch)
A batch of new messages have arrived to be processed.
|
void |
IConnection.send(Iterator<TaskMessage> msgs)
send batch messages.
|
Modifier and Type | Method and Description |
---|---|
org.apache.storm.messaging.netty.MessageBatch |
MessageBuffer.add(TaskMessage msg) |
Modifier and Type | Method and Description |
---|---|
void |
Client.send(Iterator<TaskMessage> msgs)
Enqueue task messages to be sent to the remote destination (cf.
|
Modifier and Type | Method and Description |
---|---|
void |
TransferDrainer.add(TaskMessage taskMsg) |
Copyright © 2020 The Apache Software Foundation. All rights reserved.