Partilhar via

FlinkJobProperties interface

  • Referência
Pacote:
@azure/arm-hdinsightcontainers

Propriedades da tarefa de flink.

Extends
ClusterJobProperties

Propriedades

action

Uma propriedade de cadeia que indica a ação a ser executada na tarefa Flink. Pode ter um dos seguintes valores de enumeração => NOVO, ATUALIZAR, STATELESS_UPDATE, PARAR, INICIAR, CANCELAR, GUARDARPOINT, LIST_SAVEPOINT ou ELIMINAR.
actionResult

Resultado da ação da tarefa. NOTA: esta propriedade não será serializada. Só pode ser preenchido pelo servidor.
args

Uma propriedade de cadeia que representa argumentos JVM adicionais para a tarefa Flink. Deve ser um valor separado por espaço.
entryClass

Uma propriedade de cadeia que especifica a classe de entrada para a tarefa Flink.
flinkConfiguration

Propriedades adicionais utilizadas para configurar tarefas de Flink. Permite que os utilizadores definam propriedades como paralelismo e jobSavePointDirectory. Aceita pares chave-valor adicionais como propriedades, em que as chaves são cadeias e os valores também são cadeias.
jarName

Uma propriedade de cadeia que representa o nome do JAR da tarefa.
jobId

ID exclusivo para identificar uma tarefa NOTA: esta propriedade não será serializada. Só pode ser preenchido pelo servidor.
jobJarDirectory

Uma propriedade de cadeia que especifica o diretório onde está localizado o JAR da tarefa.
jobName

Nome da tarefa
jobOutput

Saída da tarefa. NOTA: esta propriedade não será serializada. Só pode ser preenchido pelo servidor.
jobType

Discriminador polimórfico, que especifica os diferentes tipos que este objeto pode ser
lastSavePoint

O último ponto de gravação. NOTA: esta propriedade não será serializada. Só pode ser preenchido pelo servidor.
runId

Executar o ID da tarefa
savePointName

Uma propriedade de cadeia que representa o nome do ponto de gravação para a tarefa Flink
status

Estado da tarefa. NOTA: esta propriedade não será serializada. Só pode ser preenchido pelo servidor.

Detalhes de Propriedade

action

Uma propriedade de cadeia que indica a ação a ser executada na tarefa Flink. Pode ter um dos seguintes valores de enumeração => NOVO, ATUALIZAR, STATELESS_UPDATE, PARAR, INICIAR, CANCELAR, GUARDARPOINT, LIST_SAVEPOINT ou ELIMINAR.

action?: string

Valor de Propriedade

string

actionResult

Resultado da ação da tarefa. NOTA: esta propriedade não será serializada. Só pode ser preenchido pelo servidor.

actionResult?: string

Valor de Propriedade

string

args

Uma propriedade de cadeia que representa argumentos JVM adicionais para a tarefa Flink. Deve ser um valor separado por espaço.

args?: string

Valor de Propriedade

string

entryClass

Uma propriedade de cadeia que especifica a classe de entrada para a tarefa Flink.

entryClass?: string

Valor de Propriedade

string

flinkConfiguration

Propriedades adicionais utilizadas para configurar tarefas de Flink. Permite que os utilizadores definam propriedades como paralelismo e jobSavePointDirectory. Aceita pares chave-valor adicionais como propriedades, em que as chaves são cadeias e os valores também são cadeias.

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

Valor de Propriedade

{[propertyName: string]: string}

jarName

Uma propriedade de cadeia que representa o nome do JAR da tarefa.

jarName?: string

Valor de Propriedade

string

jobId

ID exclusivo para identificar uma tarefa NOTA: esta propriedade não será serializada. Só pode ser preenchido pelo servidor.

jobId?: string

Valor de Propriedade

string

jobJarDirectory

Uma propriedade de cadeia que especifica o diretório onde está localizado o JAR da tarefa.

jobJarDirectory?: string

Valor de Propriedade

string

jobName

Nome da tarefa

jobName?: string

Valor de Propriedade

string

jobOutput

Saída da tarefa. NOTA: esta propriedade não será serializada. Só pode ser preenchido pelo servidor.

jobOutput?: string

Valor de Propriedade

string

jobType

Discriminador polimórfico, que especifica os diferentes tipos que este objeto pode ser

jobType: "FlinkJob"

Valor de Propriedade

"FlinkJob"

lastSavePoint

O último ponto de gravação. NOTA: esta propriedade não será serializada. Só pode ser preenchido pelo servidor.

lastSavePoint?: string

Valor de Propriedade

string

runId

Executar o ID da tarefa

runId?: string

Valor de Propriedade

string

savePointName

Uma propriedade de cadeia que representa o nome do ponto de gravação para a tarefa Flink

savePointName?: string

Valor de Propriedade

string

status

Estado da tarefa. NOTA: esta propriedade não será serializada. Só pode ser preenchido pelo servidor.

status?: string

Valor de Propriedade

string