New-AzHDInsightStreamingMapReduceJobDefinition
Создает объект задания Streaming MapReduce.
Синтаксис
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>]
Описание
Командлет New-AzHDInsightStreamingMapReduceJobDefinition определяет объект задания Streaming MapReduce для использования с кластером Azure HDInsight.
Примеры
Пример 1. Создание определения задания Stream MapReduce
# 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
Эта команда создает определение задания Stream MapReduce.
Параметры
-Arguments
Задает массив аргументов для задания. Аргументы передаются в качестве аргументов командной строки в каждую задачу.
Тип: | String[] |
Position: | Named |
Default value: | None |
Обязательно: | False |
Принять входные данные конвейера: | False |
Принять подстановочные знаки: | False |
-CommandEnvironment
Задает массив переменных среды командной строки, заданных при выполнении задания на рабочих узлах.
Тип: | Hashtable |
Position: | Named |
Default value: | None |
Обязательно: | False |
Принять входные данные конвейера: | False |
Принять подстановочные знаки: | False |
-DefaultProfile
Учетные данные, учетная запись, клиент и подписка, используемые для обмена данными с Azure
Тип: | IAzureContextContainer |
Aliases: | AzContext, AzureRmContext, AzureCredential |
Position: | Named |
Default value: | None |
Обязательно: | False |
Принять входные данные конвейера: | False |
Принять подстановочные знаки: | False |
-Defines
Указывает значения конфигурации Hadoop, заданные при выполнении задания.
Тип: | Hashtable |
Position: | Named |
Default value: | None |
Обязательно: | False |
Принять входные данные конвейера: | False |
Принять подстановочные знаки: | False |
-File
Указывает путь к файлу, содержаму запрос для выполнения. Этот параметр можно использовать вместо параметра Query .
Тип: | String |
Position: | Named |
Default value: | None |
Обязательно: | False |
Принять входные данные конвейера: | False |
Принять подстановочные знаки: | False |
-Files
Указывает коллекцию файлов, связанных с заданием Hive.
Тип: | String[] |
Position: | Named |
Default value: | None |
Обязательно: | False |
Принять входные данные конвейера: | False |
Принять подстановочные знаки: | False |
-InputPath
Указывает путь к входным файлам.
Тип: | String |
Position: | Named |
Default value: | None |
Обязательно: | True |
Принять входные данные конвейера: | False |
Принять подстановочные знаки: | False |
-Mapper
Указывает имя файла Mapper.
Тип: | String |
Position: | Named |
Default value: | None |
Обязательно: | False |
Принять входные данные конвейера: | False |
Принять подстановочные знаки: | False |
-OutputPath
Указывает путь для выходных данных задания.
Тип: | String |
Position: | Named |
Default value: | None |
Обязательно: | False |
Принять входные данные конвейера: | False |
Принять подстановочные знаки: | False |
-Reducer
Указывает имя файла Reducer.
Тип: | String |
Position: | Named |
Default value: | None |
Обязательно: | False |
Принять входные данные конвейера: | False |
Принять подстановочные знаки: | False |
-StatusFolder
Указывает расположение папки, содержащей стандартные выходные данные и выходные данные ошибок для задания.
Тип: | String |
Position: | Named |
Default value: | None |
Обязательно: | False |
Принять входные данные конвейера: | False |
Принять подстановочные знаки: | False |
Входные данные
None
Выходные данные
AzureHDInsightStreamingMapReduceJobDefinition