Class ProcessCsvLine<T>

java.lang.Object

com.opencsv.bean.concurrent.ProcessCsvLine<T>

Type Parameters:

T - The type of the bean being created

All Implemented Interfaces:

Runnable

public class ProcessCsvLine<T>
extends Object
implements Runnable

A class that encapsulates the job of creating a bean from a line of CSV input and making it possible to run those jobs in parallel.

Since:

4.0

Author:

Andrew Rucker Jones

Constructor Summary

Constructors

Constructor	Description
ProcessCsvLine(long lineNumber, MappingStrategy<? extends T> mapper, CsvToBeanFilter filter, List<BeanVerifier<T>> verifiers, String[] line, BlockingQueue<com.opencsv.bean.util.OrderedObject<T>> resultantBeanQueue, BlockingQueue<com.opencsv.bean.util.OrderedObject<CsvException>> thrownExceptionsQueue, SortedSet<Long> expectedRecords, CsvExceptionHandler exceptionHandler)	The only constructor for creating a bean out of a line of input.

Method Summary

Modifier and Type	Method	Description
void	run()

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ProcessCsvLine

public ProcessCsvLine(long lineNumber,
 MappingStrategy<? extends T> mapper,
 CsvToBeanFilter filter,
 List<BeanVerifier<T>> verifiers,
 String[] line,
 BlockingQueue<com.opencsv.bean.util.OrderedObject<T>> resultantBeanQueue,
 BlockingQueue<com.opencsv.bean.util.OrderedObject<CsvException>> thrownExceptionsQueue,
 SortedSet<Long> expectedRecords,
 CsvExceptionHandler exceptionHandler)

The only constructor for creating a bean out of a line of input.

Parameters:

lineNumber - Which record in the input file is being processed

mapper - The mapping strategy to be used

filter - A filter to remove beans from the running, if necessary. May be null.

verifiers - The list of verifiers to run on beans after creation

line - The line of input to be transformed into a bean

resultantBeanQueue - A queue in which to place the bean created

thrownExceptionsQueue - A queue in which to place a thrown exception, if one is thrown

expectedRecords - A list of outstanding record numbers so gaps in ordering due to filtered input or exceptions while converting can be detected.

exceptionHandler - The handler for exceptions thrown during record processing

Method Details

run

public void run()

Specified by:

run in interface Runnable