import com.univocity.parsers.common.processor.BeanProcessor; //导入依赖的package包/类
/**
 * Method to start parsing issues from the provided input stream.
 *
 * @param inputStream
 *            stream that contains uploaded BlackDuck scan result file data.
 * @param beanProcessor
 *            BeanProcessor implementation that is responsible for fetching vulnerabilities from the
 *            rows of the provided black duck result CSV file.
 * @throws ScanParsingException
 * @throws IOException
 *             If an I/O error occurs during CSV file processing.
 * @throws IllegalArgumentException
 *             if inputStream and / or beanProcessor are null.
 */
public void parseIssues(final InputStream inputStream, final BeanProcessor<BlackDuckIssue> beanProcessor) throws ScanParsingException, IOException {
    LOG.info("Parsing issues for Black Duck");
    if (inputStream == null) {
        throw new IllegalArgumentException("inputStream cannot be null");
    }
    if (beanProcessor == null) {
        throw new IllegalArgumentException("beanProcessor cannot be null");
    }
    final CsvParserSettings parserSettings = new CsvParserSettings();
    parserSettings.setRowProcessor(beanProcessor);
    parserSettings.setHeaderExtractionEnabled(true);
    try (final InputStreamCsvParser inputStreamCsvParser = new InputStreamCsvParser(parserSettings, inputStream)) {
        inputStreamCsvParser.parse();
    }
}
 

import com.univocity.parsers.common.processor.BeanProcessor; //导入依赖的package包/类
@Benchmark
public void mapCsv(Blackhole blackhole, CsvParam csvParam) throws IOException {
    CsvParserSettings settings = new CsvParserSettings();

    //turning off features enabled by default
    settings.setIgnoreLeadingWhitespaces(false);
    settings.setIgnoreTrailingWhitespaces(false);
    settings.setSkipEmptyLines(false);
    settings.setColumnReorderingEnabled(false);
    settings.setReadInputOnSeparateThread(false);

    settings.setRowProcessor(new BeanProcessor<City>(City.class) {
        @Override
        public void beanProcessed(City bean, ParsingContext context) {
            blackhole.consume(bean);
        }
    });

    com.univocity.parsers.csv.CsvParser parser = new com.univocity.parsers.csv.CsvParser(settings);
    try(Reader reader = csvParam.getReader()) {
        parser.parse(reader);
    }
}
 

import com.univocity.parsers.common.processor.BeanProcessor; //导入依赖的package包/类
public static void main(String[] args) throws IOException {
    CsvParam csvParam = new CsvParam();
    csvParam.setUp();

    CsvParserSettings settings = new CsvParserSettings();

    //turning off features enabled by default
    settings.setIgnoreLeadingWhitespaces(false);
    settings.setIgnoreTrailingWhitespaces(false);
    settings.setSkipEmptyLines(false);
    settings.setColumnReorderingEnabled(false);
    settings.setReadInputOnSeparateThread(false);

    settings.setProcessor(new BeanProcessor<City>(City.class) {
        @Override
        public void beanProcessed(City bean, ParsingContext context) {
            System.out.println(bean);
        }
    });

    com.univocity.parsers.csv.CsvParser parser = new com.univocity.parsers.csv.CsvParser(settings);
    try(Reader reader = csvParam.getReader()) {
        parser.parse(reader);
    }
}
 

import com.univocity.parsers.common.processor.BeanProcessor; //导入依赖的package包/类
@Benchmark
public void mapCsv(Blackhole blackhole) throws IOException {
    CsvParserSettings settings = new CsvParserSettings();

    //turning off features enabled by default
    settings.setIgnoreLeadingWhitespaces(false);
    settings.setIgnoreTrailingWhitespaces(false);
    settings.setSkipEmptyLines(false);
    settings.setColumnReorderingEnabled(false);

    settings.setRowProcessor(new BeanProcessor<City>(City.class) {
        @Override
        public void beanProcessed(City bean, ParsingContext context) {
            blackhole.consume(bean);
        }
    });

    com.univocity.parsers.csv.CsvParser parser = new com.univocity.parsers.csv.CsvParser(settings);
    try(Reader reader = CsvParam.getSingleThreadedReader(quotes, nbRows)) {
        parser.parse(reader);
    }
}
 

import com.univocity.parsers.common.processor.BeanProcessor; //导入依赖的package包/类
@Benchmark
public void testUnivocityCsvMapper(final Blackhole blackhole) throws Exception {
	BeanProcessor<SmallBenchmarkObject> rowProcessor = new BeanProcessor<SmallBenchmarkObject>(SmallBenchmarkObject.class) {

		@Override
		public void beanProcessed(SmallBenchmarkObject bean,
				ParsingContext context) {
			blackhole.consume(bean);
		}
		
	};

    CsvParserSettings parserSettings = new CsvParserSettings();
    parserSettings.setRowProcessor(rowProcessor);
    parserSettings.setHeaderExtractionEnabled(true);

    com.univocity.parsers.csv.CsvParser parser = new com.univocity.parsers.csv.CsvParser(parserSettings);

    parser.parse(reader);
}