Uso de un trabajo MapReduce de Validate Address
Atención: Before creating and running the first Validate Address job, ensure the Acushare service is running. Para obtener información sobre los pasos, consulte Running Acushare Service.
-
Cree una instancia de
UAMAddressingFactory
con su método estáticogetInstance()
. -
Proporcione los detalles de entrada y salida del trabajo Validate Address Global mediante la creación de una instancia de
UAMAddressingDetail
que especifique elProcessType
. La instancia debe usar el tipo MRProcessType. Para lograrlo, los pasos son:-
To configure the input settings for the job, create an instance of
UniversalAddressValidateInputConfiguration
.Set the values of the various required fields of this instance, using the enums Enum PreferredCity, Enum CasingType, Enum CityNameFormat, EnumOutputCountryFormat, Enum StandardAddressFormat, Enum StandardAddressPMBLine, Enum StreetMatchingStrictness, Enum FirmMatchingStrictness, Enum DirectionalMatchingStrictness, Enum DualAddressLogic, and Enum DPVSuccessStatusCondition where applicable.Importante: Para ejecutar Validate Address en el modo CASS Certified, establezca los camposoutputReport3553
,outputCASSDetail
youtputReportSummary
de esta instancia como true. Los informes CASS poseen contenido que solo es válido cuando el trabajo se ejecuta en el modo CASS Certified. Además, se generan PDF de informes en blanco. -
Establezca los detalles de la ruta de los datos de referencia creando una instancia de
LocalReferenceDataPath
. -
To configure the various job run settings, create an instance of
UAMUSAddressingEngineConfiguration
by passing theLocalReferenceDataPath
instance created above, and the COBOL Runtime path and modules directory path asString
values, as arguments to its constructor.Once theUAMUSAddressingEngineConfiguration
instance is created, set the values for its various required fields. -
To configure JVM settings, create an instance of
UniversalAddressGeneralConfiguration
.Use the enums Enum DPVFileType, Enum DPVMemoryModel, Enum LacsLinkMemoryModel, and Enum SuiteLinkMemoryModel. -
Cree una instancia de
UAMAddressingDetail
, mediante el paso de una instancia de tipoJobConfig
y laUAMUSAddressingEngineConfiguration
,UniversalAddressGeneralConfiguration
y las instanciasUniversalAddressGeneralConfiguration
creadas con anterioridad como los argumentos para su constructor.El parámetroJobConfig
debe ser una instancia de tipo MRJobConfig.- Establezca los detalles del archivo de entrada mediante el campo
inputPath
de la instanciaUAMAddressingDetail
.Para un archivo de entrada de texto, cree una instancia de
FilePath
con los detalles relevantes del archivo de entrada mediante la invocación del constructor apropiado. Para un archivo de entrada ORC, cree una instancia deOrcFilePath
con la ruta del archivo de entrada ORC como argumento. - Establezca los detalles del archivo de salida mediante el campo
outputPath
de la instanciaUAMAddressingDetail
.Para un archivo de salida de texto, cree una instancia de
FilePath
con los detalles relevantes del archivo de salida mediante la invocación del constructor apropiado. Para un archivo de salida ORC, cree una instancia deOrcFilePath
con la ruta del archivo de salida ORC como argumento. - Establezca el nombre del trabajo mediante el campo
jobName
de la instanciaUAMAddressingDetail
. - Establezca la bandera
compressOutput
de la instanciaUAMAddressingDetail
en verdadero para comprimir la salida del trabajo.
- Establezca los detalles del archivo de entrada mediante el campo
-
To configure the input settings for the job, create an instance of
-
Para crear un trabajo MapReduce, utilice la instancia anteriormente creada de
UAMAddressingFactory
para invocar el métodocreateJob()
. Aquí, pase la instancia anterior deUAMAddressingDetail
como un argumento.El métodocreateJob()
devuelve unaList
de instancias deControlledJob
. -
Ejecute el trabajo creado con el uso de una instancia de
JobControl
. -
Para mostrar que los contadores de informes publican una ejecución de trabajo exitosa, use la instancia creada anteriormente de
UAMAddressingFactory
para invocar su métodogetCounters()
, pasando el trabajo creado como un argumento.Se recibe unMap
de contadores. -
Para generar informes CASS después de una ejecución de trabajo exitosa, use la instancia previamente creada de
UAMAddressingFactory
para invocar el métodogenerateCASSReport()
. Puede invocar cualquiera de las versiones sobrecargadas del métodogenerateCASSReport()
.Según qué firma de métodogenerateCASSReport()
se emplee, pase como argumentos el mapa (Map
) de contadores de informes derivados del paso anterior, el nombre de trabajo (jobName
), la ruta (path
) donde se debe almacenar el informe CASS generado y el tipo de informe (reportType
) requerido que se va a crear.La ruta (path
) debe estar en la ubicación del clúster o cliente según si el trabajo SDK se ejecuta en un entorno de clúster o en el equipo del cliente, respectivamente.Nota: Si no se especifica la ruta (path
), el nuevo informe CASS se alojará en el directorio de trabajo actual.El parámetro
reportType
debe tener valores provenientes de Enum UAMCASSReportType. Puede especificar uno o más tipos de informe en este parámetro.