1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
# 1. Histogramme
mapper (ligne):
renvoie (ville, int(log(pop)))
reducer (paires):
pour chaque paire:
res[clé1] += 1
# 2. LastFM
## top decouvertes
mapper ligne renvoie (User, 1)
reducer1 prend [(User1, 1), (User2, 1), (User1, 1), ...] renvoie [(User1, nbUser1), (User2, nbUser2), ...]
reducer2 prend out reducer1 renvoie (key, max(Values))
## top ecoutes
mapper ligne renvoie (Artiste, 1)
reducer1 prend [(Artiste1, 1), (Artiste2, 1), (Artiste1, 1), ...] renvoie [(Artiste1, nbArtiste1), (Artiste2, nbArtiste2), ...]
reducer2 prend out reducer1 renvoie (key, max(Values))
|
