Megosztás a következőn keresztül:

New-AzureHDInsightPigJobDefinition

  • Referencia
Modul:
Azure

Definiál egy új Pig-feladatot egy HDInsight-szolgáltatáshoz.

Feljegyzés

A jelen dokumentációban hivatkozott parancsmagok az Azure Service Manager (ASM) API-kat használó örökölt Azure-erőforrások kezelésére szolgálnak. Ez az örökölt PowerShell-modul nem ajánlott új erőforrások létrehozásakor, mivel az ASM a kivonásra van ütemezve. További információkért lásd az Azure Service Manager kivonását.

Az Az PowerShell-modul az ajánlott PowerShell-modul az Azure Resource Manager-erőforrások PowerShell-lel való kezeléséhez.

Syntax

New-AzureHDInsightPigJobDefinition
   [-Arguments <String[]>]
   [-File <String>]
   [-Files <String[]>]
   [-Query <String>]
   [-StatusFolder <String>]
   [-Profile <AzureSMProfile>]
   [<CommonParameters>]

Description

Az Azure PowerShell HDInsight ezen verziója elavult. Ezek a parancsmagok 2017. január 1-jei törlésre kerülnek. Használja az Azure PowerShell HDInsight újabb verzióját.

Az új HDInsight fürt létrehozásához való használatával kapcsolatos információkért lásd: Linux-alapú fürtök létrehozása a HDInsightban az Azure PowerShell (https://azure.microsoft.com/en-us/documentation/articles/hdinsight-hadoop-create-linux-clusters-azure-powershell/) használatával. A feladatok Azure PowerShell-lel és más módszerekkel történő elküldésével kapcsolatos információkért lásd : Hadoop-feladatok beküldése a HDInsightban (https://azure.microsoft.com/en-us/documentation/articles/hdinsight-submit-hadoop-jobs-programmatically/). Az Azure PowerShell HDInsightról további információt az Azure HDInsight-parancsmagok című témakörben talál.

A New-AzureHDInsightPigJobDefinition egy Pig-feladatot határoz meg egy Azure HDInsight-szolgáltatáshoz.

Példák

1. példa: Új Pig-feladat definiálása

PS C:\>$0 = '$0';
PS C:\> $QueryString =  "LOGS = LOAD 'wasb:///example/data/sample.log';" + "LEVELS = foreach LOGS generate REGEX_EXTRACT($0, '(TRACE|DEBUG|INFO|WARN|ERROR|FATAL)', 1) as LOGLEVEL;" + "FILTEREDLEVELS = FILTER LEVELS by LOGLEVEL is not null;" + "GROUPEDLEVELS = GROUP FILTEREDLEVELS by LOGLEVEL;" + "FREQUENCIES = foreach GROUPEDLEVELS generate group as LOGLEVEL, COUNT(FILTEREDLEVELS.LOGLEVEL) as COUNT;" + "RESULT = order FREQUENCIES by COUNT desc;" + "DUMP RESULT;"
PS C:\> $PigJobDefinition = New-AzureHDInsightPigJobDefinition -Query $QueryString

Az első parancs sztringértéket deklarál, majd a $0 változóban tárolja.

A második parancs létrehoz egy Pig-feladat lekérdezést, majd a $QueryString változóban tárolja.

Az utolsó parancs létrehoz egy Pig-feladatdefiníciót, amely a lekérdezést $QueryString használja, majd a feladatdefiníciót a $PigJobDefinition változóban tárolja.

Paraméterek

-Arguments

Egy Pig-feladat argumentumainak tömbje. Az argumentumokat a rendszer parancssori argumentumként továbbítja az egyes tevékenységeknek.

Típus:String[]
Aliasok:Args
Position:Named
Alapértelmezett érték:None
Kötelező:False
Folyamatbemenet elfogadása:False
Helyettesítő karakterek elfogadása:False

-File

Megadja a futtatni kívánt lekérdezést tartalmazó fájl elérési útját. Ezt a paramétert a Lekérdezés paraméter helyett használhatja.

Típus:String
Aliasok:QueryFile
Position:Named
Alapértelmezett érték:None
Kötelező:False
Folyamatbemenet elfogadása:False
Helyettesítő karakterek elfogadása:False

-Files

A Pig-feladathoz társított fájlok gyűjteményét adja meg.

Típus:String[]
Position:Named
Alapértelmezett érték:None
Kötelező:False
Folyamatbemenet elfogadása:False
Helyettesítő karakterek elfogadása:False

-Profile

Azt az Azure-profilt adja meg, amelyből a parancsmag beolvassa. Ha nem ad meg profilt, ez a parancsmag a helyi alapértelmezett profilból olvas be.

Típus:AzureSMProfile
Position:Named
Alapértelmezett érték:None
Kötelező:False
Folyamatbemenet elfogadása:False
Helyettesítő karakterek elfogadása:False

-Query

Egy Pig-feladat lekérdezését adja meg.

Típus:String
Aliasok:QueryText
Position:Named
Alapértelmezett érték:None
Kötelező:False
Folyamatbemenet elfogadása:False
Helyettesítő karakterek elfogadása:False

-StatusFolder

Megadja annak a mappának a helyét, amely szabványos kimeneteket és hibakimeneteket tartalmaz egy feladathoz, beleértve a kilépési kódot és a tevékenységnaplókat.

Típus:String
Position:Named
Alapértelmezett érték:None
Kötelező:False
Folyamatbemenet elfogadása:False
Helyettesítő karakterek elfogadása:False