Accéder au contenu principal Passer au contenu complémentaire

Fusionner et supprimer une branche Iceberg

La troisième étape de ce scénario consiste à fusionner la branche dans la table Iceberg et, cela fait, à supprimer la branche.

Pourquoi et quand exécuter cette tâche

Les sous-Jobs Merge branch et Drop branch sont utilisés pour cette tâche.

Procédure

  1. Dans la vue Basic settings du tIcebergMerge nommé Merge branch, configurez les paramètres comme suit :
    Vue Basic settings du tIcebergMerge.
    1. Dans la liste déroulante Connection, sélectionnez le composant de connexion à utiliser. Dans cet exemple, c'est le tIcebergConnection_1.
    2. Dans la liste déroulante Source type, sélectionnez la manière dont vous souhaitez que les données effectuent l'action de fusion. Dans cet exemple, sélectionnez Table.
    3. Dans le paramètre Source table name, saisissez le nom de la table Iceberg de laquelle vous souhaitez obtenir des données. Dans cet exemple, la table provient de la branche default.marketing_toclean.branch_cleaned_data.
    4. Dans le paramètre Source alias, saisissez un alias à utiliser pour la table source. Dans cet exemple, l'alias est cleaned.
    5. Dans le paramètre Target table name, saisissez le nom de la table Iceberg dans laquelle vous souhaitez effectuer la fusion. Dans cet exemple, la table est marketing_toclean.
    6. Dans le paramètre Target alias, saisissez un alias à utiliser pour la table cible. Dans cet exemple, l'alias est toclean.
    7. Dans le paramètre Merge on, saisissez l'expression booléenne à utiliser pour effectuer une jointure sur les tables sources et cibles. Dans cet exemple, l'expression est cleaned.customer_id=toclean.customer_id, ce qui vous permet de fusionner les données de customer_id depuis la branche cleaned_data dans la table marketing_toclean.
    8. Cochez la case When matched update pour exécuter l'instruction WHEN MATCHED THEN UPDATE SET et saisissez l'expression booléenne pour la clause dans Set clauses list. Dans cet exemple, l'expression est membership_type=M.memberhsip_type, ce qui vous permet d'effectuer une fusion sur les données membership_type.
    9. Laissez les autres paramètres tels qu'ils sont.
  2. Exécutez le sous-Job Merge branch en cliquant sur le bouton Run dans l'onglet Run.
    Les données provenant de la branche cleaned_data sont fusionnées dans la table marketing_toclean.
  3. Dans la vue Basic settings du tIcebergTable nommé Drop branch, configurez les paramètres comme suit :
    Vue Basic settings du tIcebergTable.
    1. Dans la liste déroulante Property Type, sélectionnez l'emplacement où stocker les données. Dans cet exemple, le stockage est ponctuel, Built-In.
    2. Dans la liste déroulante Connection, sélectionnez le composant de connexion à utiliser. Dans cet exemple, c'est le tIcebergConnection_1.
    3. Dans le champ Table name, saisissez le nom de la table de laquelle supprimer une branche. Dans cet exemple, la table est marketing_toclean.
    4. Dans la liste Action on table, sélectionnez Alter et, dans la liste Alter table action, sélectionnez Drop branch pour supprimer une branche.
    5. Dans le champ Branch, saisissez le nom de la branche à supprimer. Dans cet exemple, la branche se nomme cleaned_data.
  4. Exécutez le sous-Job Drop branch en cliquant sur le bouton Run dans l'onglet Run.
    La branche cleaned_data est supprimée.

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.

Laissez vos commentaires ici