New-AzHdInsightOnAksFlinkJobObject

Criar um objeto como um parâmetro para enviar o trabalho do cluster

Sintaxe

PowerShell
New-AzHdInsightOnAksFlinkJobObject
   -Action <String>
   -JobName <String>
   [-JobJarDirectory <String>]
   [-JarName <String>]
   [-EntryClass <String>]
   [-Arg <String>]
   [-SavePointName <String>]
   [-FlinkConfiguration <IFlinkJobPropertiesFlinkConfiguration>]
   [<CommonParameters>]

Description

Criar um objeto como um parâmetro para enviar o trabalho do cluster

Exemplos

Exemplo 1: criar um objeto como um parâmetro para enviar trabalho de cluster.

PowerShell
$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.

Parâmetros

-Action

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

-Arg

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

-EntryClass

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

-FlinkConfiguration

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

-JarName

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

-JobJarDirectory

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

-JobName

Nome do trabalho.

Tipo:String
Cargo:Named
Valor padrão:None
Obrigatório:True
Aceitar a entrada de pipeline:False
Aceitar caracteres curinga:False

-SavePointName

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

Saídas

IClusterJob