Anular ubicaciones de archivos de flujo de procesos

Cuando ejecuta un flujo de procesos utilizando el comando process flow execute en la Utilidad de administración, puede especificar que el flujo de proceso deba utilizar archivos de entrada y salida diferentes que los especificados en el trabajo. Para hacer esto, utilice el argumento --o:

--o "JobName|StageName=File"

Donde:

JobName

El nombre de un trabajo al que se hace referencia en el flujo de proceso.

StageName

El nombre de una etapa Read from File o Write to File en el trabajo como se muestra en el rótulo de etapa en el icono de etapa en el flujo de datos. Por ejemplo, si la etapa de entrada tiene el rótulo "Read From File", debe especificar:

"Job1|Read From File=file:C:/inputfile.txt"

Si la etapa de entrada tiene el rótulo "Illinois Customers" debe especificar:

"Job1|Illinois Customers=file:C:/inputfile.txt"

Archivo

El protocolo y la ruta completa al archivo. El servidor HDFS debe estar definido como recurso en Management Console. El protocolo debe ser una de las siguientes opciones:

file:

Si el archivo está en la misma máquina que el servidor Spectrum Technology Platform, comience la ruta con el protocolo "file:". Por ejemplo, en Windows especifique file:C:/myfile.txt y en Unix o Linux especifique file:/testfiles/myfile.txt.

Nota: Si el cliente y el servidor se ejecutan en la misma máquina, puede utilizar el protocolo "file:" o el protocolo "esclient:", pero, probablemente, el rendimiento sea mejor si utiliza el protocolo "file:".

esclient:

Si el archivo está en la misma máquina que Process Flow Executor, comience la ruta con el protocolo "esclient:". Por ejemplo, en Windows especifique esclient:C:/myfile.txt y en Unix o Linux especifique esclient:/testfiles/myfile.txt.

Nota: Si el equipo que ejecuta el ejecutor de flujo de proceso no puede resolver el nombre de host del servidor Spectrum Technology Platform, es posible que se genere el "Error al acceder al archivo". Para resolver este problema, abra este archivo en el servidor: SpectrumLocation/server/app/conf/spectrum-container.properties. Configure la propiedad spectrum.runtime.hostname en la dirección IP del servidor.

ftp:

Para utilizar un servidor de archivos definido en Management Console, utilice el siguiente formato:ftp:NameOfFileServer/PathToFile. Por ejemplo, ftp://FS/testfiles/myfile.txt donde FS es un recurso del servidor de archivos definido en Management Console.

El siguiente ejemplo ilustra cómo anular ubicaciones de archivos con el uso del argumento --o:

--o "Job1|Read from File=file:C:/myfile_input.txt" "Job1|Write to File=file:C:/myfile_output.txt"