New-AzHdInsightOnAksFlinkJobObject
Criar um objeto como um parâmetro para enviar o trabalho do cluster
New-AzHdInsightOnAksFlinkJobObject
-Action <String>
-JobName <String>
[-JobJarDirectory <String>]
[-JarName <String>]
[-EntryClass <String>]
[-Arg <String>]
[-SavePointName <String>]
[-FlinkConfiguration <IFlinkJobPropertiesFlinkConfiguration>]
[<CommonParameters>]
Criar um objeto como um parâmetro para enviar o trabalho do cluster
$flinkJobProperties = New-AzHdInsightOnAksFlinkJobObject -Action "NEW" -JobName "job1" `
-JarName "JarName" -EntryClass "com.microsoft.hilo.flink.job.streaming.SleepJob" `
-JobJarDirectory "abfs://flinkjob@hilosa.dfs.core.windows.net/jars" `
-FlinkConfiguration @{parallelism=1}
Id Name SystemDataCreatedAt SystemDataCreatedBy SystemDataCreatedByType SystemDataLastModifiedAt SystemDataLastModifiedBy SystemDataLastModifiedByType Type
-- ---- ------------------- ------------------- ----------------------- ------------------------ ------------------------ ---------------------------- ----
Crie um objeto como um parâmetro para enviar o trabalho do cluster.
O nome de referência do segredo a ser usado em configurações de serviço.
Tipo: | String |
Cargo: | Named |
Valor padrão: | None |
Obrigatório: | True |
Aceitar a entrada de pipeline: | False |
Aceitar caracteres curinga: | False |
Uma propriedade de cadeia de caracteres que representa argumentos JVM adicionais para o trabalho Flink. Deve ser um valor separado por espaço.
Tipo: | String |
Cargo: | Named |
Valor padrão: | None |
Obrigatório: | False |
Aceitar a entrada de pipeline: | False |
Aceitar caracteres curinga: | False |
Uma propriedade de cadeia de caracteres que especifica a classe de entrada para o trabalho Flink.
Tipo: | String |
Cargo: | Named |
Valor padrão: | None |
Obrigatório: | False |
Aceitar a entrada de pipeline: | False |
Aceitar caracteres curinga: | False |
Propriedades adicionais usadas para configurar trabalhos do 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.
Tipo: | IFlinkJobPropertiesFlinkConfiguration |
Cargo: | Named |
Valor padrão: | None |
Obrigatório: | False |
Aceitar a entrada de pipeline: | False |
Aceitar caracteres curinga: | False |
Uma propriedade de cadeia de caracteres que representa o nome do JAR do trabalho
Tipo: | String |
Cargo: | Named |
Valor padrão: | None |
Obrigatório: | False |
Aceitar a entrada de pipeline: | False |
Aceitar caracteres curinga: | False |
Uma propriedade de cadeia de caracteres que especifica o diretório em que o JAR do trabalho está localizado.
Tipo: | String |
Cargo: | Named |
Valor padrão: | None |
Obrigatório: | False |
Aceitar a entrada de pipeline: | False |
Aceitar caracteres curinga: | False |
Nome do trabalho.
Tipo: | String |
Cargo: | Named |
Valor padrão: | None |
Obrigatório: | True |
Aceitar a entrada de pipeline: | False |
Aceitar caracteres curinga: | False |
Uma propriedade de cadeia de caracteres que representa o nome do ponto de salvamento para o trabalho Flink
Tipo: | String |
Cargo: | Named |
Valor padrão: | None |
Obrigatório: | False |
Aceitar a entrada de pipeline: | False |
Aceitar caracteres curinga: | False |