edu.iu.harp.collective

Class LocalGlobalSyncCollective

java.lang.Object

edu.iu.harp.collective.LocalGlobalSyncCollective

public class LocalGlobalSyncCollective
extends java.lang.Object

Local-Global synchronization Collective communication

Constructor Summary

Constructors

Constructor and Description
LocalGlobalSyncCollective()

Method Summary

Modifier and Type	Method and Description
static void	main(java.lang.String[] args)
static <P extends Simple> boolean	pull(java.lang.String contextName, java.lang.String operationName, Table<P> localTable, Table<P> globalTable, boolean useBcast, DataMap dataMap, Workers workers) The pull communication operation.
static <P extends Simple> boolean	pullGlobalToLocal(java.lang.String contextName, java.lang.String operationName, Table<P> localTable, Table<P> globalTable, boolean useBcast, DataMap dataMap, Workers workers) The pull communication operation.
static <P extends Simple,PT extends Partitioner> boolean	push(java.lang.String contextName, java.lang.String operationName, Table<P> localTable, Table<P> globalTable, PT partitioner, DataMap dataMap, Workers workers) The push communication operation.
static <P extends Simple,PT extends Partitioner> boolean	pushLocalToGlobal(java.lang.String contextName, java.lang.String operationName, Table<P> localTable, Table<P> globalTable, PT partitioner, DataMap dataMap, Workers workers) The push communication operation.
static <P extends Simple> boolean	rotate(java.lang.String contextName, java.lang.String operationName, Table<P> globalTable, Int2IntMap rotateMap, DataMap dataMap, Workers workers)

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalGlobalSyncCollective

public LocalGlobalSyncCollective()

Method Detail

main

public static void main(java.lang.String[] args)
                 throws java.lang.Exception

Throws:

java.lang.Exception

pull

public static <P extends Simple> boolean pull(java.lang.String contextName,
                                              java.lang.String operationName,
                                              Table<P> localTable,
                                              Table<P> globalTable,
                                              boolean useBcast,
                                              DataMap dataMap,
                                              Workers workers)

The pull communication operation. Pull the global data to local

Parameters:

contextName - the name of the context

operationName - the name of the operation

localTable - the local Table

globalTable - the global Table

useBcast - use broadcast or not

dataMap - the DataMap

workers - the Workers

Returns:

true if succeeded, false otherwise

push

public static <P extends Simple,PT extends Partitioner> boolean push(java.lang.String contextName,
                                                                     java.lang.String operationName,
                                                                     Table<P> localTable,
                                                                     Table<P> globalTable,
                                                                     PT partitioner,
                                                                     DataMap dataMap,
                                                                     Workers workers)

The push communication operation. Push the local data to global

Parameters:

contextName - the name of the context

operationName - the name of the operation

localTable - the local Table

globalTable - the global Table

partitioner - the Partitioner

dataMap - the DataMap

workers - the Workers

Returns:

true if succeeded, false otherwise

pushLocalToGlobal

public static <P extends Simple,PT extends Partitioner> boolean pushLocalToGlobal(java.lang.String contextName,
                                                                                  java.lang.String operationName,
                                                                                  Table<P> localTable,
                                                                                  Table<P> globalTable,
                                                                                  PT partitioner,
                                                                                  DataMap dataMap,
                                                                                  Workers workers)

The push communication operation. Push the local data to global

Parameters:

contextName - the name of the context

operationName - the name of the operation

localTable - the local Table

globalTable - the global Table

partitioner - the Partitioner

dataMap - the DataMap

workers - the Workers

Returns:

true if succeeded, false otherwise

pullGlobalToLocal

public static <P extends Simple> boolean pullGlobalToLocal(java.lang.String contextName,
                                                           java.lang.String operationName,
                                                           Table<P> localTable,
                                                           Table<P> globalTable,
                                                           boolean useBcast,
                                                           DataMap dataMap,
                                                           Workers workers)

The pull communication operation. Pull the global data to local

Parameters:

contextName - the name of the context

operationName - the name of the operation

localTable - the local Table

globalTable - the global Table

useBcast - use broadcast or not

dataMap - the DataMap

workers - the Workers

Returns:

true if succeeded, false otherwise

rotate

public static <P extends Simple> boolean rotate(java.lang.String contextName,
                                                java.lang.String operationName,
                                                Table<P> globalTable,
                                                Int2IntMap rotateMap,
                                                DataMap dataMap,
                                                Workers workers)

Parameters:

contextName - the name of the context

operationName - the name of the operation

globalTable - the global Table

rotateMap - the map indicating the order of rotation

dataMap - the DataMap

workers - the Workers

Returns:

true if succeeded, false otherwise