Delen via


New-AzureRmHDInsightStreamingMapReduceJobDefinition

Hiermee maakt u een Streaming MapReduce-taakobject.

Waarschuwing

De AzureRM PowerShell-module is vanaf 29 februari 2024 officieel afgeschaft. Gebruikers wordt aangeraden om van AzureRM naar de Az PowerShell-module te migreren om ondersteuning en updates te garanderen.

Hoewel de AzureRM-module nog steeds kan functioneren, wordt deze niet meer onderhouden of ondersteund, waardoor het gebruik naar eigen goeddunken en risico van de gebruiker blijft bestaan. Raadpleeg onze migratiebronnen voor hulp bij de overgang naar de Az-module.

Syntaxis

New-AzureRmHDInsightStreamingMapReduceJobDefinition
   [-Arguments <String[]>]
   [-File <String>]
   [-Files <String[]>]
   [-StatusFolder <String>]
   [-CommandEnvironment <Hashtable>]
   [-Defines <Hashtable>]
   -InputPath <String>
   [-Mapper <String>]
   [-OutputPath <String>]
   [-Reducer <String>]
   [-DefaultProfile <IAzureContextContainer>]
   [<CommonParameters>]

Description

De cmdlet New-AzureRmHDInsightStreamingMapReduceJobDefinition definieert een Streaming MapReduce-taakobject voor gebruik met een Azure HDInsight-cluster.

Voorbeelden

Voorbeeld 1: Een Streaming MapReduce-taakdefinitie maken

PS C:\># Cluster info
PS C:\>$clusterName = "your-hadoop-001"
PS C:\>$clusterCreds = Get-Credential

# Streaming MapReduce job details
PS C:\>$statusFolder = "tempStatusFolder/"
PS C:\>$query = "SHOW TABLES"

PS C:\>New-AzureRmHDInsightStreamingMapReduceJobDefinition -StatusFolder $statusFolder `
            -Query $query `
        | Start-AzureRmHDInsightJob `
            -ClusterName $clusterName `
            -ClusterCredential $clusterCreds

Met deze opdracht maakt u een Streaming MapReduce-taakdefinitie.

Parameters

-Arguments

Hiermee geeft u een matrix van argumenten voor de taak. De argumenten worden doorgegeven als opdrachtregelargumenten aan elke taak.

Type:String[]
Position:Named
Default value:None
Vereist:False
Pijplijninvoer accepteren:False
Jokertekens accepteren:False

-CommandEnvironment

Hiermee geeft u een matrix van opdrachtregelomgevingsvariabelen die moeten worden ingesteld wanneer een taak wordt uitgevoerd op werkknooppunten.

Type:Hashtable
Position:Named
Default value:None
Vereist:False
Pijplijninvoer accepteren:False
Jokertekens accepteren:False

-DefaultProfile

De referenties, het account, de tenant en het abonnement dat wordt gebruikt voor communicatie met Azure

Type:IAzureContextContainer
Aliassen:AzureRmContext, AzureCredential
Position:Named
Default value:None
Vereist:False
Pijplijninvoer accepteren:False
Jokertekens accepteren:False

-Defines

Hiermee geeft u Hadoop-configuratiewaarden op die moeten worden ingesteld voor wanneer de taak wordt uitgevoerd.

Type:Hashtable
Position:Named
Default value:None
Vereist:False
Pijplijninvoer accepteren:False
Jokertekens accepteren:False

-File

Hiermee geeft u het pad naar een bestand dat een query bevat die moet worden uitgevoerd. U kunt deze parameter gebruiken in plaats van de queryparameter .

Type:String
Position:Named
Default value:None
Vereist:False
Pijplijninvoer accepteren:False
Jokertekens accepteren:False

-Files

Hiermee geeft u een verzameling bestanden op die zijn gekoppeld aan een Hive-taak.

Type:String[]
Position:Named
Default value:None
Vereist:False
Pijplijninvoer accepteren:False
Jokertekens accepteren:False

-InputPath

Hiermee geeft u het pad naar de invoerbestanden.

Type:String
Position:Named
Default value:None
Vereist:True
Pijplijninvoer accepteren:False
Jokertekens accepteren:False

-Mapper

Hiermee geeft u een Mapper-bestandsnaam.

Type:String
Position:Named
Default value:None
Vereist:False
Pijplijninvoer accepteren:False
Jokertekens accepteren:False

-OutputPath

Hiermee geeft u het pad voor de taakuitvoer.

Type:String
Position:Named
Default value:None
Vereist:False
Pijplijninvoer accepteren:False
Jokertekens accepteren:False

-Reducer

Hiermee geeft u een Reducer-bestandsnaam.

Type:String
Position:Named
Default value:None
Vereist:False
Pijplijninvoer accepteren:False
Jokertekens accepteren:False

-StatusFolder

Hiermee geeft u de locatie op van de map die standaarduitvoer en foutuitvoer voor een taak bevat.

Type:String
Position:Named
Default value:None
Vereist:False
Pijplijninvoer accepteren:False
Jokertekens accepteren:False

Invoerwaarden

None

Uitvoerwaarden

AzureHDInsightStreamingMapReduceJobDefinition