Dela via

New-AzHDInsightStreamingMapReduceJobDefinition

  • Referens
Modul:
Az.HDInsight

Skapar ett MapReduce-jobbobjekt för direktuppspelning.

Syntax

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

Description

Cmdleten New-AzHDInsightStreamingMapReduceJobDefinition definierar ett MapReduce-jobbobjekt för direktuppspelning för användning med ett Azure HDInsight-kluster.

Exempel

Exempel 1: Skapa en mapreduce-jobbdefinition för direktuppspelning

# Cluster info
$clusterName = "your-hadoop-001"
$clusterCreds = Get-Credential

# Streaming MapReduce job details
$statusFolder = "tempStatusFolder/"
$query = "SHOW TABLES"

New-AzHDInsightStreamingMapReduceJobDefinition -StatusFolder $statusFolder -File $query `
        | Start-AzHDInsightJob `
            -ClusterName $clusterName `
            -ClusterCredential $clusterCreds

Det här kommandot skapar en MapReduce-jobbdefinition för direktuppspelning.

Parametrar

-Arguments

Anger en matris med argument för jobbet. Argumenten skickas som kommandoradsargument till varje uppgift.

Typ:String[]
Position:Named
standardvärde:None
Obligatorisk:False
Accept pipeline input:False
Accept wildcard characters:False

-CommandEnvironment

Anger en matris med kommandoradsmiljövariabler som ska anges när ett jobb körs på arbetsnoder.

Typ:Hashtable
Position:Named
standardvärde:None
Obligatorisk:False
Accept pipeline input:False
Accept wildcard characters:False

-DefaultProfile

Autentiseringsuppgifter, konto, klientorganisation och prenumeration som används för kommunikation med Azure

Typ:IAzureContextContainer
Aliases:AzContext, AzureRmContext, AzureCredential
Position:Named
standardvärde:None
Obligatorisk:False
Accept pipeline input:False
Accept wildcard characters:False

-Defines

Anger hadoop-konfigurationsvärden som ska anges för när jobbet körs.

Typ:Hashtable
Position:Named
standardvärde:None
Obligatorisk:False
Accept pipeline input:False
Accept wildcard characters:False

-File

Anger sökvägen till en fil som innehåller en fråga som ska köras. Du kan använda den här parametern i stället för frågeparametern.

Typ:String
Position:Named
standardvärde:None
Obligatorisk:False
Accept pipeline input:False
Accept wildcard characters:False

-Files

Anger en samling filer som är associerade med ett Hive-jobb.

Typ:String[]
Position:Named
standardvärde:None
Obligatorisk:False
Accept pipeline input:False
Accept wildcard characters:False

-InputPath

Anger sökvägen till indatafilerna.

Typ:String
Position:Named
standardvärde:None
Obligatorisk:True
Accept pipeline input:False
Accept wildcard characters:False

-Mapper

Anger ett Mapper-filnamn.

Typ:String
Position:Named
standardvärde:None
Obligatorisk:False
Accept pipeline input:False
Accept wildcard characters:False

-OutputPath

Anger sökvägen för jobbutdata.

Typ:String
Position:Named
standardvärde:None
Obligatorisk:False
Accept pipeline input:False
Accept wildcard characters:False

-Reducer

Anger ett Reducer-filnamn.

Typ:String
Position:Named
standardvärde:None
Obligatorisk:False
Accept pipeline input:False
Accept wildcard characters:False

-StatusFolder

Anger platsen för mappen som innehåller standardutdata och felutdata för ett jobb.

Typ:String
Position:Named
standardvärde:None
Obligatorisk:False
Accept pipeline input:False
Accept wildcard characters:False

Indata

None

Utdata

AzureHDInsightStreamingMapReduceJobDefinition