edu.iu.harp.collective

Class RegroupCollective

java.lang.Object

edu.iu.harp.collective.RegroupCollective

public class RegroupCollective
extends java.lang.Object

Regroup Collective communication

Field Summary

Fields

Modifier and Type	Field and Description
protected static Logger	LOG

Constructor Summary

Constructors

Constructor and Description
RegroupCollective()

Method Summary

Modifier and Type	Method and Description
static <P extends Simple,PF extends PartitionFunction<P>,PT extends Partitioner> boolean	aggregate(java.lang.String contextName, java.lang.String operationName, Table<P> table, PT partitioner, PF function, DataMap dataMap, Workers workers)
static <P extends Simple,PF extends PartitionFunction<P>> boolean	applyPartitionFunction(Table<P> table, PF function) Apply the function the each partition in the Table
static void	main(java.lang.String[] args)
static <P extends Simple,PF extends PartitionFunction<P>,PT extends Partitioner> boolean	regroupAggregate(java.lang.String contextName, java.lang.String operationName, Table<P> table, PT partitioner, PF function, DataMap dataMap, Workers workers)
static <P extends Simple> boolean	regroupCombine(java.lang.String contextName, java.lang.String operationName, Table<P> table, Partitioner partitioner, DataMap dataMap, Workers workers) The regroup communication operation

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final Logger LOG

Constructor Detail

RegroupCollective

public RegroupCollective()

Method Detail

main

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

Throws:

java.lang.Exception

regroupCombine

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

The regroup communication operation

Parameters:

contextName - the name of the context

operationName - the name of the operation

table - the Table

partitioner - the Partitioner

dataMap - the DataMap

workers - the Workers

Returns:

true if succeeded, false otherwise

applyPartitionFunction

public static <P extends Simple,PF extends PartitionFunction<P>> boolean applyPartitionFunction(Table<P> table,
                                                                                                PF function)

Apply the function the each partition in the Table

Parameters:

table - the Table

function - the function to be applied

Returns:

true if succeeded, false otherwise

regroupAggregate

public static <P extends Simple,PF extends PartitionFunction<P>,PT extends Partitioner> boolean regroupAggregate(java.lang.String contextName,
                                                                                                                 java.lang.String operationName,
                                                                                                                 Table<P> table,
                                                                                                                 PT partitioner,
                                                                                                                 PF function,
                                                                                                                 DataMap dataMap,
                                                                                                                 Workers workers)

aggregate

public static <P extends Simple,PF extends PartitionFunction<P>,PT extends Partitioner> boolean aggregate(java.lang.String contextName,
                                                                                                          java.lang.String operationName,
                                                                                                          Table<P> table,
                                                                                                          PT partitioner,
                                                                                                          PF function,
                                                                                                          DataMap dataMap,
                                                                                                          Workers workers)