public class TransferDrainer extends Object
TransferDrainer()
void
add(HashMap<Integer,ArrayList<TaskMessage>> taskTupleSetMap)
clear()
send(HashMap<Integer,String> taskToNode, HashMap<String,IConnection> connections)
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public TransferDrainer()
public void add(HashMap<Integer,ArrayList<TaskMessage>> taskTupleSetMap)
public void send(HashMap<Integer,String> taskToNode, HashMap<String,IConnection> connections)
public void clear()
Copyright © 2015. All rights reserved.