Ecrire un stream

Version imprimable

Ecrire un stream

J'ai un problème à faire un stream.

J'extrait des données à partir d'un csv :
Code:

1 2 3 4 5 6 7 8 9 10 public Stream<T> importFichier(File file, Class<T> pojo) throws JsonProcessingException, IOException{ CsvMapper mapper = new CsvMapper(); SchemaConfiguration<T> schema = new SchemaConfiguration<T>(); BufferedInputStream bis = new BufferedInputStream(new FileInputStream(file)); MappingIterator<T> it = mapper.readerFor(pojo).with(schema.schemaDefinition(pojo)).readValues(bis); Stream<T> streamImport = StreamSupport.stream(Spliterators.spliteratorUnknownSize(it, Spliterator.SIZED), true); return streamImport; }
Ensuite pour que le résultat de l'import colle à mon modèle de données j'ai écrit un converter (je n'ai pas le loisir de modifier le modèle de donnée).
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 public List<ClasseModele> PojoConverter() throws JsonProcessingException, IOException{ Stream<Pojo> pojoListe = initImportCsv(); List<ClasseModele> prReferentielListe = null; for (Pojo pojo : pojoListe.distinct().collect(Collectors.toList())) { ClasseModele cm = new ClasseModele(); cm.setProp1(pojo.getProp1); cm.setProp2(pojo.getProp2); prReferentielListe.add(prReferentiel); } return prReferentielListe; }
J'aimerai diminué la compléxité en me débarassant du forEach. Pour cela je voudrais mettre le code suivant dans une méthode et un faire un stream
Code:

1 2 3 4 ClasseModele cm = new ClasseModele(); cm.setProp1(pojo.getProp1); cm.setProp2(pojo.getProp2);
Ainsi je pourrais mapper ce stream dans mon PojoConverter.

Seulement j'ai du mal écrire cette fameuse méthode...

Si vous avez des suggestions je suis preneur.

Je vous remercie d'avance

26/09/2017, 20h06
thelvin

Hello,

"réduire la complexité" ?

"faire un stream" ?

Mais tu parles de quoi, enfin ?

Parle avec des mots simples, et montre-nous ce que tu veux vraiment, au lieu d'essayer de faire des phrases et de décrire ce que tu pourrais tout simplement montrer.

Vu que ton code ne compile pas, je suppose que tu veux obtenir un collection de ClasseModele à partir de ton Stream et que t'aimerais éviter la boucle.

Il faut créer une méthode pour convertir un Pojo en ClasseModele
Code:

1 2 3 4 5 6 private ClasseModele fromPojo(Pojo pojo){ ClasseModele cm = new ClasseModele(); cm.setProp1(pojo.getProp1()); cm.setProp2(pojo.getProp2()); return cm; }
ensuite tu utilise le mapping
Code:

1 2 3 public List<ClasseModele> PojoConverter() throws JsonProcessingException, IOException{ return initImportCsv().distinct().map(this::fromPojo).collect(Collectors.toList()); }

Désolé si je n'ai pas été assez clair. Voilà un code un peu réécrit :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
 
public List<ClasseModele> PojoConverter() throws JsonProcessingException, IOException{
	Stream<Pojo> pojoListe = initImportCsv();
	List<ClasseModele> classeModele = null;
	for (Pojo pojo : pojoListe.distinct().collect(Collectors.toList())) {
                convertToClasseModele();
        }
return prReferentielListe;
}
 
private ClasseModele convertToClasseModele(){
        ClasseModele cm = new ClasseModele();
        cm.setProp1(pojo.getProp1);
	cm.setProp2(pojo.getProp2);
        return cm;
}

Je veux remplacer ça :

Code:

1
2
3
4
 
for (Pojo pojo : pojoListe.distinct().collect(Collectors.toList())) {
         convertToClasseModele()
}

par quelque chose comme ça :

Code:

1
2
 
classeModele.stream().map().collect(Collectors.toList())

L'ennui c'est que je ne suis pas sûr de ce que je peux mettre dans le map(). Est-ce quelque chose comme ça ça suffit ?

Code:

1
2
 
map(x -> {return convertToClasseModele()});

EDIT : je viens de me rendre compte que ça correspond au post précédent ...

27/09/2017, 14h41
thelvin

Ben c'est à dire qu'il faudrait lui mettre un paramètre "pojo" à ta méthode convertToClasseModele(). Mais sinon ouais, c'est exactement ça.

Soit dit en passant tchize_ avait bien compris que c'était à ça que tu pensais, et sa proposition marche très bien.

Tu peux faire :

Code:

classeModele.stream().map(x -> {return convertToClasseModele(x); }).collect(Collectors.toList())

qui peut être simplifié en :

Code:

classeModele.stream().map(x -> convertToClasseModele(x)).collect(Collectors.toList())

qui peut aussi être simplifié en :

Code:

classeModele.stream().map(this::convertToClasseModele).collect(Collectors.toList())

Finalement, je pense que j'ai trouvé

Code:

1
2
3
4
 
public List<ClasseModele> PojoConverter() throws JsonProcessingException, IOException{
        return initImportCsv().distinct().map(conversion -> convertToClasseModele()).collect(Collectors.toList());
}

27/09/2017, 15h25
thelvin

Vu que tu ne fais rien du tout avec la variable "conversion", et que tu ne passes aucun paramètre à la méthode "convertToClasseModele()", je serais très surpris que cela donne les résultats attendus.

Justement je viens rajouter un argument à ma fonction ^^
Code:

1 2 3 4 5 public List<ClasseModele> PojoConverter() throws JsonProcessingException, IOException{ Pojo pojo = new Pojo(); return initImportCsv().distinct().map(conversion -> convertToClasseModele(pojo)).collect(Collectors.toList()); }
Ensuite pour la variable converion j'y travaille.

Comme j'ai ce que je voulais je vais mettre le sujet en résolu.

Merci pour votre aide.