| Package | Description |
|---|---|
| backtype.storm.messaging | |
| backtype.storm.messaging.netty | |
| backtype.storm.utils |
| Modifier and Type | Method and Description |
|---|---|
Iterator<TaskMessage> |
IConnection.recv(int flags,
int clientId)
receive a batch message iterator (consists taskId and payload)
|
| Modifier and Type | Method and Description |
|---|---|
void |
IConnection.send(Iterator<TaskMessage> msgs)
send batch messages
|
| Modifier and Type | Method and Description |
|---|---|
Iterator<TaskMessage> |
Client.recv(int flags,
int clientId)
Receiving messages is not supported by a client.
|
| 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(HashMap<Integer,ArrayList<TaskMessage>> taskTupleSetMap) |
Copyright © 2015. All rights reserved.