Utilisation d’un job Validate Address MapReduce
Avertissement : Avant de créer et d'exécuter le premier job Validate Address, assurez-vous que le service Acushare est en cours d'exécution. Pour connaître les étapes, reportez-vous à la section Arrêt du service acushare.
-
Créez une instance de
UAMAddressingFactory
à l'aide de sa méthode statiquegetInstance()
. -
Fournissez les détails d'entrée et de sortie du job Validate Address en créant une instance de
UAMAddressingDetail
définissantProcessType
. L’instance doit utiliser le type MRProcessType. Pour ce faire, les étapes sont les suivantes :-
Pour configurer les paramètres d’entrée du job, créez une instance de
UniversalAddressValidateInputConfiguration
.Définissez les valeurs des différents champs requis de cette instance en utilisant les énumérations Énumération PreferredCity, Énumération CasingType, Énumération CityNameFormat, Énumération OutputCountryFormat, Énumération StandardAddressFormat, Énumération StandardAddressPMBLine, Énumération StreetMatchingStrictness, Énumération FirmMatchingStrictness, Énumération DirectionalMatchingStrictness, Énumération DualAddressLogic et Énumération DPVSuccessStatusCondition, le cas échéant.Important : Pour lancer Validate Address en mode certifié CASS, définissez les champsoutputReport3553
,outputCASSDetail
etoutputReportSummary
de cette instance sur true. Le contenu des rapports CASS est valide uniquement lorsque le job est exécuté en mode certifié CASS. Sinon, des PDF de rapports vierges sont générés. -
Définissez les détails du chemin d'accès aux données de référence en créant une instance de
LocalReferenceDataPath
. -
Pour configurer les différents paramètres d’exécution du job, créez une instance de
UAMUSAddressingEngineConfiguration
en transmettant l'instanceLocalReferenceDataPath
précédemment créée, le chemin d’accès à l’exécution COBOL et le chemin d'accès au répertoire de modules sous forme de valeursString
comme arguments à son constructeur.Une fois l'instanceUAMUSAddressingEngineConfiguration
créée, définissez les valeurs de ses différents champs requis. -
Pour configurer les paramètres JVM, créez une instance de
UniversalAddressGeneralConfiguration
.Utiliser les énumérations Énumération DPVFileType, Énumération DPVMemoryModel, Énumération LacsLinkMemoryModel et Énumération SuiteLinkMemoryModel. -
Créez une instance de
UAMAddressingDetail
en transmettant une instance de typeJobConfig
et les instancesUAMUSAddressingEngineConfiguration
,UniversalAddressGeneralConfiguration
etUniversalAddressValidateInputConfiguration
créées précédemment comme arguments à son constructeur.Le paramètreJobConfig
doit être une instance de type MRJobConfig.- Définissez les détails du fichier d'entrée à l'aide du champ
inputPath
de l'instanceUAMAddressingDetail
.Pour un fichier d'entrée texte, créez une instance de
FilePath
avec les détails pertinents du fichier d'entrée en appelant le constructeur approprié. Pour un fichier d'entrée ORC, créez une instance deOrcFilePath
avec le chemin d’accès au fichier d'entrée ORC comme argument. - Définissez les détails du fichier de sortie à l'aide du champ
outputPath
de l'instanceUAMAddressingDetail
.Pour un fichier de sortie texte, créez une instance de
FilePath
avec les détails pertinents du fichier de sortie en appelant le constructeur approprié. Pour un fichier de sortie ORC, créez une instance deOrcFilePath
avec le chemin d’accès au fichier de sortie ORC comme argument. - Définissez le nom du job à l'aide du champ
jobName
de l'instanceUAMAddressingDetail
. - Définissez l'indicateur
compressOutput
de l'instanceUAMAddressingDetail
sur true pour compresser la sortie du job.
- Définissez les détails du fichier d'entrée à l'aide du champ
-
Pour configurer les paramètres d’entrée du job, créez une instance de
-
Pour créer un job MapReduce, utilisez l'instance de
UAMAddressingFactory
précédemment créée pour appeler sa méthodecreateJob()
. Dans ce cas, transmettez l'instance ci-dessus deUAMAddressingDetail
comme argument.La méthodecreateJob()
renvoie uneList
d'instances deControlledJob
. -
Exécutez le job créé à l’aide d’une instance de
JobControl
. -
Pour afficher les compteurs de reporting suite à l'exécution correcte d'un job, utilisez l'instance précédemment créée
UAMAddressingFactory
pour appeler sa méthodegetCounters()
, en transmettant le job créé comme argument.UneMap
de compteurs est reçue. -
Pour générer les rapports CASS après l’exécution réussie d'un job, utilisez l’instance précédemment créée de
UAMAddressingFactory
pour appeler la méthodegenerateCASSReport()
. Vous pouvez appeler l'une des versions surchargées de la méthodegenerateCASSReport()
.Suivant la signature de la méthodegenerateCASSReport()
utilisée, transmettez comme arguments laMap
des compteurs de rapport dérivés à l’étape précédente, lejobName
, lepath
où le rapport CASS généré doit être enregistré et lereportType
requis à créer.Lepath
doit pointer vers l'emplacement du cluster ou du client, suivant que le job SDK est exécuté dans un environnement de cluster ou sur votre poste client, respectivement.Remarque : Si lepath
n’est pas spécifié, le nouveau rapport CASS est placé dans le répertoire de travail en cours.Les valeurs du paramètre
reportType
doivent provenir de Énumération UAMCASSReportType. Vous pouvez spécifier un ou plusieurs types de rapport dans ce paramètre.