Adding "separator" to gradle hubRunFlow command arguments

Author: ssambasu

marklogic-data-hub/src/main/java/com/marklogic/hub/step/impl/WriteStepRunner.java

@@ -306,6 +306,15 @@ public RunStepResponse run() {
             if(fileLocations.get("outputURIReplacement") != null) {
                 this.outputURIReplacement = fileLocations.get("outputURIReplacement");
             }
+            if(fileLocations.get("separator") != null) {
+                if(! this.inputFileType.equalsIgnoreCase("csv")){
+                    throw new IllegalArgumentException("Invalid argument for file type " + inputFileType );
+                }
+                this.separator = fileLocations.get("separator").trim();
+                if (separator.equals("\\t")) {
+                    separator = "\t";
+                }
+            }
         }
         if(stepConfig.get("stopOnFailure") != null){
             this.withStopOnFailure(Boolean.parseBoolean(stepConfig.get("stopOnFailure").toString()));

ml-data-hub-plugin/src/main/groovy/com/marklogic/gradle/task/RunFlowTask.groovy

@@ -49,6 +49,9 @@ class RunFlowTask extends HubTask {
     @Input
     public String outputURIReplacement
 
+    @Input
+    public String separator
+
     @Input
     public Boolean showOptions
 
@@ -97,6 +100,11 @@ class RunFlowTask extends HubTask {
                 project.property("inputFileType") : null
         }
 
+        if (separator == null) {
+            separator = project.hasProperty("separator") ?
+                project.property("separator") : null
+        }
+
         if (outputURIReplacement == null) {
             outputURIReplacement = project.hasProperty("outputURIReplacement") ?
                 project.property("outputURIReplacement") : null
@@ -162,7 +170,7 @@ class RunFlowTask extends HubTask {
             stepConfig.put("stopOnFailure", failHard)
         }
 
-        if(inputFileType != null || inputFilePath != null || outputURIReplacement != null){
+        if(inputFileType != null || inputFilePath != null || outputURIReplacement != null || separator !=null){
             runFlowString.append("\n\tWith File Locations Settings:")
             Map<String, String> fileLocations = new HashMap<>()
             if(inputFileType != null) {
@@ -177,6 +185,14 @@ class RunFlowTask extends HubTask {
                 runFlowString.append("\n\t\tOutput URI Replacement:" + outputURIReplacement.toString())
                 fileLocations.put("outputURIReplacement", outputURIReplacement)
             }
+            if(separator != null) {
+                if(inputFileType != null && !inputFileType.equalsIgnoreCase("csv")) {
+                    throw new IllegalArgumentException("Invalid argument for file type " + inputFileType)
+                }
+                runFlowString.append("\n\t\tSeparator:" + separator.toString())
+                fileLocations.put("separator", separator)
+            }
+
             stepConfig.put("fileLocations", fileLocations)
         }
         if (showOptions) {