New-AzureHDInsightPigJobDefinition
Definuje novou úlohu Pig pro službu HDInsight.
Poznámka:
Rutiny, na které odkazuje tato dokumentace, slouží ke správě starších prostředků Azure, které používají rozhraní API Azure Service Manageru (ASM). Tento starší modul PowerShellu se nedoporučuje při vytváření nových prostředků, protože ASM je naplánované pro vyřazení z provozu. Další informace najdete v části Vyřazení Azure Service Manageru.
Modul Az PowerShell je doporučený modul PowerShellu pro správu prostředků Azure Resource Manageru (ARM) pomocí PowerShellu.
Syntax
New-AzureHDInsightPigJobDefinition
[-Arguments <String[]>]
[-File <String>]
[-Files <String[]>]
[-Query <String>]
[-StatusFolder <String>]
[-Profile <AzureSMProfile>]
[<CommonParameters>]
Description
Tato verze Azure PowerShell HDInsight je zastaralá. Tyto rutiny budou odebrány do 1. ledna 2017. Použijte novější verzi služby Azure PowerShell HDInsight.
Informace o tom, jak pomocí nové služby HDInsight vytvořit cluster, najdete v tématu Vytváření clusterů založených na Linuxu ve službě HDInsight pomocí Azure PowerShellu (https://azure.microsoft.com/en-us/documentation/articles/hdinsight-hadoop-create-linux-clusters-azure-powershell/). Informace o odesílání úloh pomocí Azure PowerShellu a dalších přístupů najdete v tématu Odesílání úloh Hadoop ve službě HDInsight (https://azure.microsoft.com/en-us/documentation/articles/hdinsight-submit-hadoop-jobs-programmatically/). Referenční informace o službě Azure PowerShell HDInsight najdete v tématu Rutiny Azure HDInsight.
New-AzureHDInsightPigJobDefinition definuje úlohu Pig pro službu Azure HDInsight.
Příklady
Příklad 1: Definování nové úlohy Pig
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
První příkaz deklaruje řetězcovou hodnotu a pak se uloží do proměnné $0.
Druhý příkaz vytvoří dotaz úlohy Pig a pak ho uloží do $QueryString proměnné.
Poslední příkaz vytvoří definici úlohy Pig, která používá dotaz v $QueryString, a pak uloží definici úlohy do proměnné $PigJobDefinition.
Parametry
-Arguments
Určuje pole argumentů pro úlohu Pig. Argumenty se předávají každému úkolu jako argumenty příkazového řádku.
Typ: | String[] |
Aliases: | Args |
Position: | Named |
výchozí hodnota: | None |
Vyžadováno: | False |
Accept pipeline input: | False |
Accept wildcard characters: | False |
-File
Určuje cestu k souboru, který obsahuje dotaz ke spuštění. Tento parametr můžete použít místo parametru Dotazu .
Typ: | String |
Aliases: | QueryFile |
Position: | Named |
výchozí hodnota: | None |
Vyžadováno: | False |
Accept pipeline input: | False |
Accept wildcard characters: | False |
-Files
Určuje kolekci souborů přidružených k úloze Pig.
Typ: | String[] |
Position: | Named |
výchozí hodnota: | None |
Vyžadováno: | False |
Accept pipeline input: | False |
Accept wildcard characters: | False |
-Profile
Určuje profil Azure, ze kterého se tato rutina čte. Pokud nezadáte profil, tato rutina načte z místního výchozího profilu.
Typ: | AzureSMProfile |
Position: | Named |
výchozí hodnota: | None |
Vyžadováno: | False |
Accept pipeline input: | False |
Accept wildcard characters: | False |
-Query
Určuje dotaz úlohy Pig.
Typ: | String |
Aliases: | QueryText |
Position: | Named |
výchozí hodnota: | None |
Vyžadováno: | False |
Accept pipeline input: | False |
Accept wildcard characters: | False |
-StatusFolder
Určuje umístění složky, která obsahuje standardní výstupy a výstupy chyb pro úlohu, včetně ukončovacího kódu a protokolů úkolů.
Typ: | String |
Position: | Named |
výchozí hodnota: | None |
Vyžadováno: | False |
Accept pipeline input: | False |
Accept wildcard characters: | False |