Uso de un trabajo MapReduce de Open Name Parser
-
Cree una instancia de
UniversalNameFactory
con su método estáticogetInstance()
. -
Proporcione los detalles de entrada y salida del trabajo Open Name Parser mediante la creación de una instancia de
OpenNameParserDetail
que especifique elProcessType
. La instancia debe usar el tipo MRProcessType.-
Configure las reglas de Open Name Parser mediante la creación de una instancia de
OpenNameParserConfiguration
. -
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. -
Cree una instancia de
OpenNameParserDetail
, mediante el paso de una instancia de tipoJobConfig
y laOpenNameParserConfiguration
y las instanciasReferenceDataPath
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 instanciaOpenNameParserDetail
.Para un archivo de entrada de texto, cree una instancia deFilePath
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 instanciaOpenNameParserDetail
.Para un archivo de salida de texto, cree una instancia deFilePath
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 instanciaOpenNameParserDetail
.
-
Configure las reglas de Open Name Parser mediante la creación de una instancia de
-
Para crear un trabajo MapReduce, utilice la instancia anteriormente creada de
UniversalNameFactory
para invocar el métodocreateJob()
. Aquí, pase la instancia anterior deOpenNameParserDetail
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 MapReduce exitosa, use la instancia creada anteriormente
UniversalNameFactory
para invocar su métodogetCounters()
, mediante el paso de un trabajo creado como un argumento.