Uso de un trabajo MapReduce de Advanced Transformer

  1. Cree una instancia de DataNormalizationFactory con su método estático getInstance().
  2. Proporcione los detalles de entrada y salida del trabajo Advanced Transformer mediante la creación de una instancia de AdvancedTransformerDetail que especifique el ProcessType. La instancia debe usar el tipo MRProcessType.
    1. Configure las reglas de Advanced Transformer mediante la creación de una instancia deAdvancedTransformerConfiguration. Dentro de esta instancia:
      Agregue una instancia de tipoAbstractAdvancedTransformerRules. Esta instanciaAbstractAdvancedTransformerRules debe definirse con el uso de una de estas clases: TableDataExtraction o RegularExpressionExtraction, que corresponde a la categoría de regla deseada de Advanced Transformer.
    2. Establezca los detalles de la ruta de los datos de referencia y el tipo de ubicación creando una instancia de ReferenceDataPath. Consulte Enum ReferenceDataPathLocation.
    3. Cree una instancia de AdvancedTransformerDetail, mediante el paso de una instancia de tipo JobConfig y la AdvancedTransformerConfiguration y las instanciasReferenceDataPath creadas con anterioridad como los argumentos para su constructor.
      El parámetro JobConfig debe ser una instancia de tipo MRJobConfig.
    4. Establezca los detalles del archivo de entrada mediante el campo inputPath de la instancia AdvancedTransformerDetail.
      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 de OrcFilePath con la ruta del archivo de entrada ORC como argumento.
    5. Establezca los detalles del archivo de salida mediante el campo outputPath de la instancia AdvancedTransformerDetail.
      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 de OrcFilePath con la ruta del archivo de salida ORC como argumento.
    6. Establezca el nombre del trabajo mediante el campo jobName de la instancia AdvancedTransformerDetail.
  3. Para crear un trabajo MapReduce, utilice la instancia anteriormente creada de DataNormalizationFactory para invocar el métodocreateJob(). Aquí, pase la instancia anterior de AdvancedTransformerDetail como un argumento.
    El método createJob() devuelve una List de instancias de ControlledJob.
  4. Ejecute el trabajo creado con el uso de una instancia de JobControl.
  5. Para mostrar que los contadores de informes publican una ejecución de trabajo MapReduce exitosa, use la instancia creada anteriormente DataNormalizationFactory para invocar su método getCounters(), mediante el paso de un trabajo creado como un argumento.