backtype.storm.utils

Class TransferDrainer

java.lang.Object

backtype.storm.utils.TransferDrainer

public class TransferDrainer
extends Object

Constructor Summary

Constructors

Constructor and Description
TransferDrainer()

Method Summary

Methods

Modifier and Type	Method and Description
void	add(HashMap<Integer,ArrayList<TaskMessage>> taskTupleSetMap)
void	clear()
void	send(HashMap<Integer,String> taskToNode, HashMap<String,IConnection> connections)

Methods inherited from class java.lang.Object

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

Constructor Detail

TransferDrainer

public TransferDrainer()

Method Detail

add

public void add(HashMap<Integer,ArrayList<TaskMessage>> taskTupleSetMap)

send

public void send(HashMap<Integer,String> taskToNode,
        HashMap<String,IConnection> connections)

clear

public void clear()