edu.iu.dsc.tws.comms.table

Class ArrowAllToAll

java.lang.Object

edu.iu.dsc.tws.comms.table.ArrowAllToAll

All Implemented Interfaces:

ReceiveCallback

public class ArrowAllToAll
extends java.lang.Object
implements ReceiveCallback

This class gets values as normal format and converts them into a row format before invoking the communication.

Constructor Summary

Constructors

Constructor and Description
ArrowAllToAll(Config cfg, IWorkerController controller, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> targets, LogicalPlan plan, int edgeId, ArrowCallback callback, Schema schema, RootAllocator allocator)

Method Summary

Modifier and Type	Method and Description
void	close()
void	finish()
void	finish(int source)
boolean	insert(Table table, int target)
boolean	isComplete() Check weather complete
void	onReceive(int source, ChannelBuffer buffer, int length)
void	onReceiveHeader(int source, boolean fin, int[] header, int length)
boolean	onSendComplete(int target, java.nio.ByteBuffer buffer, int length)

Methods inherited from class java.lang.Object

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

Constructor Detail

ArrowAllToAll

public ArrowAllToAll(Config cfg,
                     IWorkerController controller,
                     java.util.Set<java.lang.Integer> sources,
                     java.util.Set<java.lang.Integer> targets,
                     LogicalPlan plan,
                     int edgeId,
                     ArrowCallback callback,
                     Schema schema,
                     RootAllocator allocator)

Method Detail

insert

public boolean insert(Table table,
                      int target)

isComplete

public boolean isComplete()

Check weather complete

Returns:

true if operation is complete

finish

public void finish()

finish

public void finish(int source)

close

public void close()

onReceive

public void onReceive(int source,
                      ChannelBuffer buffer,
                      int length)

Specified by:

onReceive in interface ReceiveCallback

onReceiveHeader

public void onReceiveHeader(int source,
                            boolean fin,
                            int[] header,
                            int length)

Specified by:

onReceiveHeader in interface ReceiveCallback

onSendComplete

public boolean onSendComplete(int target,
                              java.nio.ByteBuffer buffer,
                              int length)

Specified by:

onSendComplete in interface ReceiveCallback