FlinkJobProperties interface

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

Propriedades do trabalho flink.

Extends
ClusterJobProperties

Propriedades

action

Uma propriedade de cadeia de caracteres que indica a ação a ser executada no trabalho Flink. Ele pode ter um dos seguintes valores de enumeração => NEW, UPDATE, STATELESS_UPDATE, STOP, START, CANCEL, SAVEPOINT, LIST_SAVEPOINT ou DELETE.
actionResult

Resultado da ação do trabalho. OBSERVAÇÃO: essa propriedade não será serializada. Ele só pode ser preenchido pelo servidor.
args

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

Uma propriedade de cadeia de caracteres que especifica a classe de entrada para o trabalho Flink.
flinkConfiguration

Propriedades adicionais usadas para configurar trabalhos Flink. Ele permite que os usuários definam propriedades como paralelismo e jobSavePointDirectory. Ele aceita pares chave-valor adicionais como propriedades, em que as chaves são cadeias de caracteres e os valores também são cadeias de caracteres.
jarName

Uma propriedade de cadeia de caracteres que representa o nome do JAR do trabalho.
jobId

ID exclusiva para identificar um trabalho OBSERVAÇÃO: essa propriedade não será serializada. Ele só pode ser preenchido pelo servidor.
jobJarDirectory

Uma propriedade de cadeia de caracteres que especifica o diretório em que o JAR do trabalho está localizado.
jobName

Nome do trabalho
jobOutput

Saída do trabalho. OBSERVAÇÃO: essa propriedade não será serializada. Ele 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 salvamento. OBSERVAÇÃO: essa propriedade não será serializada. Ele só pode ser preenchido pelo servidor.
runId

ID de execução do trabalho
savePointName

Uma propriedade de cadeia de caracteres que representa o nome do ponto de salvamento para o trabalho Flink
status

Status do trabalho. OBSERVAÇÃO: essa propriedade não será serializada. Ele só pode ser preenchido pelo servidor.

Detalhes da propriedade

action

Uma propriedade de cadeia de caracteres que indica a ação a ser executada no trabalho Flink. Ele pode ter um dos seguintes valores de enumeração => NEW, UPDATE, STATELESS_UPDATE, STOP, START, CANCEL, SAVEPOINT, LIST_SAVEPOINT ou DELETE.

action?: string

Valor da propriedade

string

actionResult

Resultado da ação do trabalho. OBSERVAÇÃO: essa propriedade não será serializada. Ele só pode ser preenchido pelo servidor.

actionResult?: string

Valor da propriedade

string

args

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

args?: string

Valor da propriedade

string

entryClass

Uma propriedade de cadeia de caracteres que especifica a classe de entrada para o trabalho Flink.

entryClass?: string

Valor da propriedade

string

flinkConfiguration

Propriedades adicionais usadas para configurar trabalhos Flink. Ele permite que os usuários definam propriedades como paralelismo e jobSavePointDirectory. Ele aceita pares chave-valor adicionais como propriedades, em que as chaves são cadeias de caracteres e os valores também são cadeias de caracteres.

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

Valor da propriedade

{[propertyName: string]: string}

jarName

Uma propriedade de cadeia de caracteres que representa o nome do JAR do trabalho.

jarName?: string

Valor da propriedade

string

jobId

ID exclusiva para identificar um trabalho OBSERVAÇÃO: essa propriedade não será serializada. Ele só pode ser preenchido pelo servidor.

jobId?: string

Valor da propriedade

string

jobJarDirectory

Uma propriedade de cadeia de caracteres que especifica o diretório em que o JAR do trabalho está localizado.

jobJarDirectory?: string

Valor da propriedade

string

jobName

Nome do trabalho

jobName?: string

Valor da propriedade

string

jobOutput

Saída do trabalho. OBSERVAÇÃO: essa propriedade não será serializada. Ele só pode ser preenchido pelo servidor.

jobOutput?: string

Valor da propriedade

string

jobType

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

jobType: "FlinkJob"

Valor da propriedade

"FlinkJob"

lastSavePoint

O último ponto de salvamento. OBSERVAÇÃO: essa propriedade não será serializada. Ele só pode ser preenchido pelo servidor.

lastSavePoint?: string

Valor da propriedade

string

runId

ID de execução do trabalho

runId?: string

Valor da propriedade

string

savePointName

Uma propriedade de cadeia de caracteres que representa o nome do ponto de salvamento para o trabalho Flink

savePointName?: string

Valor da propriedade

string

status

Status do trabalho. OBSERVAÇÃO: essa propriedade não será serializada. Ele só pode ser preenchido pelo servidor.

status?: string

Valor da propriedade

string