New-AzureHDInsightStreamingMapReduceJobDefinition
Hiermee definieert u een nieuwe MapReduce-taak voor streaming.
Notitie
De cmdlets waarnaar in deze documentatie wordt verwezen, zijn bedoeld voor het beheren van verouderde Azure-resources die gebruikmaken van ASM-API's (Azure Service Manager). Deze verouderde PowerShell-module wordt niet aanbevolen bij het maken van nieuwe resources, omdat ASM is gepland voor buitengebruikstelling. Zie Buitengebruikstelling van Azure Service Manager voor meer informatie.
De Az PowerShell-module is de aanbevolen PowerShell-module voor het beheren van ARM-resources (Azure Resource Manager) met PowerShell.
Syntaxis
New-AzureHDInsightStreamingMapReduceJobDefinition
[-Arguments <String[]>]
[-CmdEnv <String[]>]
[-Combiner <String>]
[-Defines <Hashtable>]
[-Files <String[]>]
[-InputPath <String>]
[-JobName <String>]
[-Mapper <String>]
[-OutputPath <String>]
[-Reducer <String>]
[-StatusFolder <String>]
[-Profile <AzureSMProfile>]
[<CommonParameters>] Description
Deze versie van Azure PowerShell HDInsight is afgeschaft. Deze cmdlets worden verwijderd op 1 januari 2017. Gebruik de nieuwere versie van Azure PowerShell HDInsight.
Zie Op Linux gebaseerde clusters maken in HDInsight met behulp van Azure PowerShell (https://azure.microsoft.com/en-us/documentation/articles/hdinsight-hadoop-create-linux-clusters-azure-powershell/) voor informatie over het gebruik van de nieuwe HDInsight om een cluster te maken. Zie Hadoop-taken verzenden in HDInsight (https://azure.microsoft.com/en-us/documentation/articles/hdinsight-submit-hadoop-jobs-programmatically/) voor meer informatie over het verzenden van taken met behulp van Azure PowerShell en andere benaderingen. Zie Azure HDInsight-cmdlets voor naslaginformatie over Azure PowerShell HDInsight.
De cmdlet New-AzureHDInsightStreamingMapReduceJobDefinition definieert een nieuw taakdefinitieobject dat de parameters van een Hadoop-streamingtaak vertegenwoordigt.
Voorbeelden
Voorbeeld 1: Een streaming MapReduce-taakdefinitie maken
PS C:\>$StreamingWordCount = New-AzureHDInsightStreamingMapReduceJobDefinition -Files "/Example/Apps/WordCount.exe", "/Example/Apps/Cat.exe" -InputPath "/Example/Data/Gutenberg/Davinci.txt" -OutputPath "/Example/Data/StreamingOutput/WordCount.txt" -Mapper "Cat.exe" -Reducer "WordCount.exe"Met deze opdracht maakt u de opgegeven mapReduce-taakdefinitie voor streaming en slaat deze vervolgens op in de $StreamingWordCount variabele.
Parameters
-Arguments
Hiermee geeft u een matrix van argumenten voor een Hadoop-taak. De argumenten worden doorgegeven als opdrachtregelargumenten aan elke taak.
| Type: | String[] |
| Aliassen: | Args |
| Position: | Named |
| Default value: | None |
| Vereist: | False |
| Pijplijninvoer accepteren: | False |
| Jokertekens accepteren: | False |
-CmdEnv
Hiermee geeft u een matrix van opdrachtregelomgevingsvariabelen die moeten worden ingesteld wanneer een taak wordt uitgevoerd op gegevensknooppunten.
| Type: | String[] |
| Position: | Named |
| Default value: | None |
| Vereist: | False |
| Pijplijninvoer accepteren: | False |
| Jokertekens accepteren: | False |
-Combiner
Hiermee geeft u een combinatiebestandsnaam.
| Type: | String |
| Position: | Named |
| Default value: | None |
| Vereist: | False |
| Pijplijninvoer accepteren: | False |
| Jokertekens accepteren: | False |
-Defines
Hiermee geeft u Hadoop-configuratiewaarden op die moeten worden ingesteld wanneer de taak wordt uitgevoerd.
| Type: | Hashtable |
| Aliassen: | Params |
| Position: | Named |
| Default value: | None |
| Vereist: | False |
| Pijplijninvoer accepteren: | False |
| Jokertekens accepteren: | False |
-Files
Hiermee geeft u een matrix van bestanden die vereist zijn voor een taak.
| Type: | String[] |
| Position: | Named |
| Default value: | None |
| Vereist: | False |
| Pijplijninvoer accepteren: | False |
| Jokertekens accepteren: | False |
-InputPath
Hiermee geeft u het WASB-pad naar de invoerbestanden.
| Type: | String |
| Aliassen: | Input |
| Position: | Named |
| Default value: | None |
| Vereist: | False |
| Pijplijninvoer accepteren: | False |
| Jokertekens accepteren: | False |
-JobName
Hiermee geeft u de naam van de nieuwe MapReduce-taakdefinitie. Deze parameter is optioneel.
| Type: | String |
| Aliassen: | Name |
| Position: | Named |
| Default value: | None |
| Vereist: | False |
| 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 WASB-pad voor de taakuitvoer.
| Type: | String |
| Aliassen: | Output |
| Position: | Named |
| Default value: | None |
| Vereist: | False |
| Pijplijninvoer accepteren: | False |
| Jokertekens accepteren: | False |
-Profile
Hiermee geeft u het Azure-profiel op waaruit deze cmdlet wordt gelezen. Als u geen profiel opgeeft, leest deze cmdlet uit het lokale standaardprofiel.
| Type: | AzureSMProfile |
| 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 map die de standaarduitvoer en foutuitvoer voor de taak bevat, inclusief de afsluitcode en taaklogboeken.
| Type: | String |
| Position: | Named |
| Default value: | None |
| Vereist: | False |
| Pijplijninvoer accepteren: | False |
| Jokertekens accepteren: | False |