Compartir a través de


FlinkJobProperties interface

Propiedades del trabajo de flink.

Extends

Propiedades

action

Propiedad de cadena que indica la acción que se va a realizar en el trabajo de Flink. Puede tener uno de los siguientes valores de enumeración => NEW, UPDATE, STATELESS_UPDATE, STOP, START, CANCEL, SAVEPOINT, LIST_SAVEPOINT o DELETE.

actionResult

Resultado de la acción del trabajo. NOTA: Esta propiedad no se serializará. Solo el servidor puede rellenarlo.

args

Propiedad de cadena que representa argumentos JVM adicionales para el trabajo de Flink. Debe ser un valor separado por espacios.

entryClass

Propiedad de cadena que especifica la clase de entrada para el trabajo de Flink.

flinkConfiguration

Propiedades adicionales usadas para configurar trabajos de Flink. Permite a los usuarios establecer propiedades como paralelismo y jobSavePointDirectory. Acepta pares clave-valor adicionales como propiedades, donde las claves son cadenas y los valores también son cadenas.

jarName

Propiedad de cadena que representa el nombre del archivo JAR del trabajo.

jobId

Identificador único para identificar un trabajo NOTA: Esta propiedad no se serializará. Solo el servidor puede rellenarlo.

jobJarDirectory

Propiedad de cadena que especifica el directorio donde se encuentra el archivo JAR del trabajo.

jobName

Nombre del trabajo

jobOutput

Salida del trabajo. NOTA: Esta propiedad no se serializará. Solo el servidor puede rellenarlo.

jobType

Discriminador polimórfico, que especifica los diferentes tipos que puede ser este objeto

lastSavePoint

Último punto de retorno. NOTA: Esta propiedad no se serializará. Solo el servidor puede rellenarlo.

runId

Identificador de ejecución del trabajo

savePointName

Propiedad de cadena que representa el nombre del punto de retorno para el trabajo de Flink.

status

Estado del trabajo. NOTA: Esta propiedad no se serializará. Solo el servidor puede rellenarlo.

Detalles de las propiedades

action

Propiedad de cadena que indica la acción que se va a realizar en el trabajo de Flink. Puede tener uno de los siguientes valores de enumeración => NEW, UPDATE, STATELESS_UPDATE, STOP, START, CANCEL, SAVEPOINT, LIST_SAVEPOINT o DELETE.

action?: string

Valor de propiedad

string

actionResult

Resultado de la acción del trabajo. NOTA: Esta propiedad no se serializará. Solo el servidor puede rellenarlo.

actionResult?: string

Valor de propiedad

string

args

Propiedad de cadena que representa argumentos JVM adicionales para el trabajo de Flink. Debe ser un valor separado por espacios.

args?: string

Valor de propiedad

string

entryClass

Propiedad de cadena que especifica la clase de entrada para el trabajo de Flink.

entryClass?: string

Valor de propiedad

string

flinkConfiguration

Propiedades adicionales usadas para configurar trabajos de Flink. Permite a los usuarios establecer propiedades como paralelismo y jobSavePointDirectory. Acepta pares clave-valor adicionales como propiedades, donde las claves son cadenas y los valores también son cadenas.

flinkConfiguration?: {[propertyName: string]: string}

Valor de propiedad

{[propertyName: string]: string}

jarName

Propiedad de cadena que representa el nombre del archivo JAR del trabajo.

jarName?: string

Valor de propiedad

string

jobId

Identificador único para identificar un trabajo NOTA: Esta propiedad no se serializará. Solo el servidor puede rellenarlo.

jobId?: string

Valor de propiedad

string

jobJarDirectory

Propiedad de cadena que especifica el directorio donde se encuentra el archivo JAR del trabajo.

jobJarDirectory?: string

Valor de propiedad

string

jobName

Nombre del trabajo

jobName?: string

Valor de propiedad

string

jobOutput

Salida del trabajo. NOTA: Esta propiedad no se serializará. Solo el servidor puede rellenarlo.

jobOutput?: string

Valor de propiedad

string

jobType

Discriminador polimórfico, que especifica los diferentes tipos que puede ser este objeto

jobType: "FlinkJob"

Valor de propiedad

"FlinkJob"

lastSavePoint

Último punto de retorno. NOTA: Esta propiedad no se serializará. Solo el servidor puede rellenarlo.

lastSavePoint?: string

Valor de propiedad

string

runId

Identificador de ejecución del trabajo

runId?: string

Valor de propiedad

string

savePointName

Propiedad de cadena que representa el nombre del punto de retorno para el trabajo de Flink.

savePointName?: string

Valor de propiedad

string

status

Estado del trabajo. NOTA: Esta propiedad no se serializará. Solo el servidor puede rellenarlo.

status?: string

Valor de propiedad

string