Dans la perspective Integration du Studio, créez un Job Spark Batch vide depuis le nœud Job Designs de la vue Repository.
Pour plus d'informations concernant la création d'un Job Spark Streaming, consultez le Guide de prise en main de Talend Big Data .
Dans l'espace de modélisation, saisissez le nom du composant à utiliser et sélectionnez ce composant dans la liste qui apparaît. Dans ce scénario, les composants utilisés sont les suivants : tHDFSConfiguration, tMongoDBConfiguration, tFixedFlowInput, tMongoDBOutput, tMongoDBLookupInput, tMap et tLogRow.
Les composants tFixedFlowInput sont utilisés pour charger les données relatives aux films dans le flux de données. Dans un scénario réel, vous pouvez utiliser d'autres composants, comme le tFileInputDelimited pour créer un processus sophistiqué afin de préparer vos données à traiter.
Reliez le tFixedFlowInput au tMap à l'aide d'un lien Row > Main.
Le flux principal du tMap est ainsi créé. Les informations des films sont envoyées via ce flux.
Reliez le tMongoDBLookupInput au tMap à l'aide d'un lien Row > Main.
Le flux de référence (lookup) vers le tMap est ainsi créé. Les informations des cinéastes de films sont transmises via ce flux.
Reliez le tMap au tMongoDBOutput à l'aide d'un lien Row > Main et nommez ce lien dans la boîte de dialogue qui s'ouvre. Par exemple, nommez-le out1.
Répétez l'opération pour relier le tMap au tLogRow et nommez ce lien reject.
Laissez les composants tHDFSConfiguration et tMongoDBConfiguration sans lien.
Cette page vous a-t-elle aidé ?
Si vous rencontrez des problèmes sur cette page ou dans son contenu – une faute de frappe, une étape manquante ou une erreur technique – faites-le-nous savoir.
