Merge branch 'dev' of https://github.com/pattipaka/azure-powershell.git

Author: pattipaka

src/ResourceManager/HDInsight/Commands.HDInsight/JobCommands/NewAzureHDInsightMapReduceJobDefinitionCommand.cs

@@ -31,10 +31,10 @@ public class NewAzureHDInsightMapReduceJobDefinitionCommand : HDInsightCmdletBas
 
         #region Input Parameter Definitions
 
-        [Parameter(HelpMessage = "The hive arguments for the jobDetails.")]
+        [Parameter(HelpMessage = "The arguments for the jobDetails.")]
         public string[] Arguments { get; set; }
 
-        [Parameter(HelpMessage = "The files for the jobDetails.")]
+        [Parameter(HelpMessage = "List of files to be copied to the cluster.")]
         public string[] Files { get; set; }
 
         [Parameter(HelpMessage = "The output location to use for the job.")]

src/ResourceManager/HDInsight/Commands.HDInsight/JobCommands/NewAzureHDInsightStreamingMapReduceJobDefinitionCommand.cs

@@ -31,16 +31,19 @@ public class NewAzureHDInsightStreamingMapReduceJobDefinitionCommand : HDInsight
 
         #region Input Parameter Definitions
 
-        [Parameter(HelpMessage = "The hive arguments for the jobDetails.")]
+        [Parameter(HelpMessage = "The arguments for the jobDetails.")]
         public string[] Arguments { get; set; }
 
-        [Parameter(HelpMessage = "The file for the jobDetails.")]
+        [Parameter(HelpMessage = "Local file to be made available to tasks")]
         public string File
         {
             get { return job.File; }
             set { job.File = value; } 
         }
 
+        [Parameter(HelpMessage = "List of files to be copied to the cluster.")]
+        public string[] Files { get; set; }
+
         [Parameter(HelpMessage = "The output location to use for the job.")]
         public string StatusFolder
         {
@@ -88,6 +91,7 @@ public string Reducer
         public NewAzureHDInsightStreamingMapReduceJobDefinitionCommand()
         {
             Arguments = new string[] {};
+            Files = new string[] { };
             CommandEnvironment = new Hashtable();
             Defines = new Hashtable();
             job = new AzureHDInsightStreamingMapReduceJobDefinition();
@@ -112,6 +116,11 @@ public override void ExecuteCmdlet()
                 job.Defines.Add(define.Key, define.Value.ToString());
             }
 
+            foreach (var file in Files)
+            {
+                job.Files.Add(file);
+            }
+
             WriteObject(job);
         }
     }

src/ResourceManager/HDInsight/Commands.HDInsight/Models/Job/AzureHDInsightJobDefinition.cs

@@ -36,7 +36,7 @@ protected AzureHDInsightJobDefinition()
         public IList<string> Arguments { get; private set; }
 
         /// <summary>
-        /// Gets the resources for the jobDetails.
+        /// Gets the files to be copied to the cluster
         /// </summary>
         public IList<string> Files { get; private set; }
 

src/ResourceManager/HDInsight/Commands.HDInsight/Models/Job/AzureHDInsightStreamingMapReduceJobDefinition.cs

@@ -42,7 +42,7 @@ public class AzureHDInsightStreamingMapReduceJobDefinition : AzureHDInsightJobDe
         public string Reducer { get; set; }
 
         /// <summary>
-        /// Gets or sets an HDFS file to add to the distributed cache.	
+        /// Gets or sets a file to add to the distributed cache.	
         /// </summary>
         public string File { get; set; }
 

src/ResourceManager/HDInsight/Commands.HDInsight/Models/Job/AzureHdInsightJobManagementClient.cs

@@ -92,6 +92,7 @@ public virtual JobSubmissionResponse SubmitStreamingJob(
                 Mapper = streamingJobDef.Mapper,
                 Reducer = streamingJobDef.Reducer,
                 File = streamingJobDef.File,
+                Files = streamingJobDef.Files,
                 Defines = streamingJobDef.Defines,
                 CmdEnv = streamingJobDef.CommandEnvironment,
                 Arguments = streamingJobDef.Arguments,