// Path: src/main/java/com/cloudera/sa/hcu/io/utils/LocalFileUtils.java
// public class LocalFileUtils
// {
// 
// 
// 	public static File[] createFileArray(String[] filePathArray)
// 	{
// 		ArrayList<File> fileList = new ArrayList<File>();
// 		File[] tempFileArray;
// 		
// 		for (String filePath: filePathArray)
// 		{
// 			File origFile = new File(filePath);
// 			
// 			if (origFile.isDirectory())
// 			{
// 				tempFileArray = origFile.listFiles();
// 				
// 				for (File file: tempFileArray)
// 				{
// 					fileList.add(file);
// 				}
// 			}else
// 			{
// 				fileList.add(origFile);
// 			}
// 		}
// 		
// 		return fileList.toArray(new File[0]);
// 	}
// 	
// 	public static String[] createStringArrayOfFiles(String[] filePathArray)
// 	{
// 		ArrayList<String> filePathList = new ArrayList<String>();
// 		File[] tempFileArray;
// 		
// 		for (String filePath: filePathArray)
// 		{
// 			File origFile = new File(filePath);
// 			
// 			if (origFile.isDirectory())
// 			{
// 				tempFileArray = origFile.listFiles();
// 				
// 				for (File file: tempFileArray)
// 				{
// 					filePathList.add(file.getAbsolutePath());
// 				}
// 			}else
// 			{
// 				filePathList.add(origFile.getAbsolutePath());
// 			}
// 		}
// 		
// 		return filePathList.toArray(new String[0]);
// 	}
// 
// 
// }


import java.io.IOException;
import java.util.Properties;
import com.cloudera.sa.hcu.io.utils.LocalFileUtils;
import au.com.bytecode.opencsv.CSVReader;
package com.cloudera.sa.hcu.io.put.local.reader;




public class CsvReader extends LocalOneOrMoreFileColumnReader
{

	CSVReader csvReader;
	
	public CsvReader(Properties prop) throws Exception
	{
		super(prop);
	}
	
	protected void loadFile(String[] filePathArray) throws IOException
	{
// Path: src/main/java/com/cloudera/sa/hcu/io/utils/LocalFileUtils.java
// public class LocalFileUtils
// {
// 
// 
// 	public static File[] createFileArray(String[] filePathArray)
// 	{
// 		ArrayList<File> fileList = new ArrayList<File>();
// 		File[] tempFileArray;
// 		
// 		for (String filePath: filePathArray)
// 		{
// 			File origFile = new File(filePath);
// 			
// 			if (origFile.isDirectory())
// 			{
// 				tempFileArray = origFile.listFiles();
// 				
// 				for (File file: tempFileArray)
// 				{
// 					fileList.add(file);
// 				}
// 			}else
// 			{
// 				fileList.add(origFile);
// 			}
// 		}
// 		
// 		return fileList.toArray(new File[0]);
// 	}
// 	
// 	public static String[] createStringArrayOfFiles(String[] filePathArray)
// 	{
// 		ArrayList<String> filePathList = new ArrayList<String>();
// 		File[] tempFileArray;
// 		
// 		for (String filePath: filePathArray)
// 		{
// 			File origFile = new File(filePath);
// 			
// 			if (origFile.isDirectory())
// 			{
// 				tempFileArray = origFile.listFiles();
// 				
// 				for (File file: tempFileArray)
// 				{
// 					filePathList.add(file.getAbsolutePath());
// 				}
// 			}else
// 			{
// 				filePathList.add(origFile.getAbsolutePath());
// 			}
// 		}
// 		
// 		return filePathList.toArray(new String[0]);
// 	}
// 
// 
// }


// Path: src/main/java/com/cloudera/sa/hcu/io/put/local/reader/CsvReader.java
import java.io.IOException;
import java.util.Properties;
import com.cloudera.sa.hcu.io.utils.LocalFileUtils;
import au.com.bytecode.opencsv.CSVReader;

package com.cloudera.sa.hcu.io.put.local.reader;




public class CsvReader extends LocalOneOrMoreFileColumnReader
{

	CSVReader csvReader;
	
	public CsvReader(Properties prop) throws Exception
	{
		super(prop);
	}
	
	protected void loadFile(String[] filePathArray) throws IOException
	{
		fileArray = LocalFileUtils.createFileArray(filePathArray);