FlinkJobProfile interface
Especificações de trabalho para clusters flink no modo de implantação de aplicativo. A especificação é imutável mesmo que as propriedades do trabalho sejam alteradas chamando a API RunJob. Use a API ListJob para obter as informações de trabalho mais recentes.
Propriedades
args | Uma propriedade de cadeia de caracteres que representa argumentos JVM adicionais para o trabalho Flink. Deve ser um valor separado por espaço. |
entry |
Uma propriedade de cadeia de caracteres que especifica a classe de entrada para o trabalho Flink. Se não for especificado, o ponto de entrada será detectado automaticamente do pacote jar do trabalho flink. |
jar |
Uma propriedade de cadeia de caracteres que representa o nome do JAR do trabalho. |
job |
Uma propriedade de cadeia de caracteres que especifica o diretório em que o JAR do trabalho está localizado. |
save |
Uma propriedade de cadeia de caracteres que representa o nome do ponto de salvamento para o trabalho Flink |
upgrade |
Uma propriedade de cadeia de caracteres que indica o modo de atualização a ser executado no trabalho Flink. Ele pode ter um dos seguintes valores de enumeração => STATELESS_UPDATE, UPDATE LAST_STATE_UPDATE. |
Detalhes da propriedade
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. Se não for especificado, o ponto de entrada será detectado automaticamente do pacote jar do trabalho flink.
entryClass?: string
Valor da propriedade
string
jarName
Uma propriedade de cadeia de caracteres que representa o nome do JAR do trabalho.
jarName: 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
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
upgradeMode
Uma propriedade de cadeia de caracteres que indica o modo de atualização a ser executado no trabalho Flink. Ele pode ter um dos seguintes valores de enumeração => STATELESS_UPDATE, UPDATE LAST_STATE_UPDATE.
upgradeMode: string
Valor da propriedade
string
Azure SDK for JavaScript