_consumer.row(rowList.toArray());
Object[] row = rowList.toArray(); for(int col = 0; col < row.length; col++) { row[col] = row[col].equals(CsvDataSetWriter.NULL) ? null : row[col]; } _consumer.row(row);
    private void produceFromFile(File theDataFile) throws DataSetException, CsvParserException {        try {            CsvParser parser = new CsvParserImpl();            List readData = parser.parse(theDataFile);            List readColumns = ((List) readData.get(0));            Column[] columns = new Column[readColumns.size()];            for (int i = 0; i < readColumns.size(); i++) {                columns[i] = new Column((String) readColumns.get(i), DataType.UNKNOWN);            }            String tableName = theDataFile.getName().substring(0, theDataFile.getName().indexOf(".csv"));            ITableMetaData metaData = new DefaultTableMetaData(tableName, columns);            _consumer.startTable(metaData);            for (int i = 1 ; i < readData.size(); i++) {                List rowList = (List)readData.get(i);                _consumer.row(rowList.toArray());            }            _consumer.endTable();        } catch (PipelineException e) {            throw new DataSetException(e);        } catch (IllegalInputCharacterException e) {            throw new DataSetException(e);        } catch (IOException e) {            throw new DataSetException(e);        }    }