Scala flatmap sauver à cassandra via étincelle dans la boucle

Question

J'ai bouclé avec Names{Real Test!, Real Test1!} et à l'intérieur il jours de lancement de boucle (ici comme l'exemple d'itération est 1 jour seulement), dans cette boucle quelques opérations avec des données, et ensuite je flatMap RDD (avec 2 lignes) à RDD avec 5 lignes. Et collect().foreach(println) il m'a donné ceci:

(Real Test!,2016-07-25,session_end,63) 
(Real Test!,2016-07-25,app_open,63) 

pour le prénom - et

(Real Test1!,2016-07-25,app_open,63) 
(Real Test1!,2016-07-25,app_install,0) 
(Real Test1!,2016-07-25,session_end,0) 

pour la deuxième. Quand j'essaye de saveToCassandra tous les 5 rangées dans la DB de boucle j'ai seulement les dernières rangées de flatMap. Pourquoi cela me sauve-t-il seulement la dernière rangée de flatMap, et comment je peux sauver TOUS les 5 rangées?

Answer 1

Si la clé primaire est (id, nom, date), il s'agit du comportement attendu car les données avec la même clé primaire remplacent les données existantes.