File tree Expand file tree Collapse file tree 1 file changed +2
-8
lines changed
marklogic-data-hub/src/main/java/com/marklogic/hub/step/impl Expand file tree Collapse file tree 1 file changed +2
-8
lines changed Original file line number Diff line number Diff line change @@ -282,12 +282,6 @@ public RunStepResponse run() {
282282 inputFilePath = (String )fileLocation .get ("inputFilePath" );
283283 inputFileType = (String )fileLocation .get ("inputFileType" );
284284 outputURIReplacement = (String )fileLocation .get ("outputURIReplacement" );
285- if (inputFileType .equalsIgnoreCase ("csv" ) && fileLocation .get ("separator" ) != null ) {
286- separator =((String ) fileLocation .get ("separator" )).trim ();
287- if (separator .equals ("\\ t" )) {
288- separator = "\t " ;
289- }
290- }
291285
292286 if (stepConfig .get ("batchSize" ) != null ){
293287 this .batchSize = Integer .parseInt (stepConfig .get ("batchSize" ).toString ());
@@ -310,8 +304,8 @@ public RunStepResponse run() {
310304 if (! this .inputFileType .equalsIgnoreCase ("csv" )){
311305 throw new IllegalArgumentException ("Invalid argument for file type " + inputFileType + ". When specifying a separator, the file type must be 'csv'" );
312306 }
313- this .separator = fileLocations .get ("separator" ).trim ();
314- if (separator .equals ("\\ t" )) {
307+ this .separator = (( String ) fileLocation .get ("separator" ) ).trim ();
308+ if (separator .equalsIgnoreCase ("\\ t" )) {
315309 separator = "\t " ;
316310 }
317311 }
You can’t perform that action at this time.
0 commit comments