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 |
---|---|
backtype.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(HashMap<String,ArrayList<TaskMessage>> workerTupleSetMap) |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.