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
Name | Description |
---|
executeMap | On itere sur toutes les arêtes et on applique la fonctions de Map.
|
executeReduce | Cette 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.
|
MapReduceTriplets | Chaque process de MPI_COMM_WORLD doit lancer cette fonction.
|
reduce | Reduction d'un tableau dans le Map des données final
|
toSend | |
Contained Classes
Contained Classes
Contained Structs
Contained Structs
Contained Aliases
Contained Aliases
Parameters
Name | Description |
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
);