Template MapReduceTriplets

Applique une fonction de map à tous les triplet!(sommet, arêtes), qui retourne un iterateur. Puis applique une fonctions de réduction grouper par id de l'iterateur.

template MapReduceTriplets(Fun...) ;

Contained Functions

Contained Functions

NameDescription
executeMapOn itere sur toutes les arêtes et on applique la fonctions de Map.
executeReduceCette fonction est lente mais elle marche TODO, Voir comment faire en sorte que les partitions ne communique qu'avec celle avec qui elle sont en lien.
MapReduceTripletsChaque process de MPI_COMM_WORLD doit lancer cette fonction.
reduceReduction d'un tableau dans le Map des données final
toSend

Contained Classes

Contained Classes

NameDescription
Proto

Contained Structs

Contained Structs

NameDescription
KV

Contained Aliases

Contained Aliases

NameDescription
MapFun
Msg
ReduceFun

Parameters

NameDescription
Fun une fonction de map, et une fonction de réduction

Example

// DistGraph!(VertexD, EdgeD) grp = ...;

// Récupère les degré sortant des sommets d'un graphe.
auto degree = grp.MapReduceTriplets! (
     (EdgeTriplet!(VertexD, EdgeD) ed) => Iterator (ed.src.id, 1),
     (int a, int b) => a + b
);