Liez les composants pour construire le flux de données.
Procédure
- Dans la perspective Integration du Studio, créez un Job Spark Batch vide, depuis le nœud Job Designs de la vue Repository.
-
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 sont tHDFSConfiguration (appelé emr_hdfs), tS3Configuration, tFixedFlowInput, tAggregateRow et tFileOutputParquet.
Le composant tFixedFlowInput est utilisé pour charger les données d'exemple dans le flux de données. En pratique, utilisez le composant d'entrée spécifique au format des données ou le système source à utiliser au lieu du tFixedFlowInput.
- Reliez le tFixedFlowInput, le tAggregateRow et le tFileOutputParquet à l'aide de liens Row > Main.
- Laissez les composants tHDFSConfiguration et tS3Configuration seuls, sans connexion.