Package org.apache.storm.utils

Class TransferDrainer

java.lang.Object

org.apache.storm.utils.TransferDrainer

public class TransferDrainer
extends Object

Constructor Summary

Constructors

Constructor	Description
TransferDrainer()

Method Summary

Modifier and Type	Method	Description
void	add(TaskMessage taskMsg)
void	clear()
void	send(Map<Integer,NodeInfo> taskToNode, Map<NodeInfo,IConnection> connections)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TransferDrainer

public TransferDrainer()

Method Details

add

public void add(TaskMessage taskMsg)

send

public void send(Map<Integer,NodeInfo> taskToNode,
 Map<NodeInfo,IConnection> connections)

clear

public void clear()