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

Field Summary

Fields

Modifier and Type	Field	Description
private final CsvExceptionHandler	exceptionHandler
private final SortedSet<Long>	expectedRecords
private final CsvToBeanFilter	filter
private final String[]	line
private final long	lineNumber
private final MappingStrategy<? extends T>	mapper
private final BlockingQueue<OrderedObject<T>>	resultantBeanQueue
private final BlockingQueue<OrderedObject<CsvException>>	thrownExceptionsQueue
private final List<BeanVerifier<T>>	verifiers

Constructor Summary

Constructors

Constructor	Description
ProcessCsvLine(long lineNumber, MappingStrategy<? extends T> mapper, CsvToBeanFilter filter, List<BeanVerifier<T>> verifiers, String[] line, BlockingQueue<OrderedObject<T>> resultantBeanQueue, BlockingQueue<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
private T	processLine()	Creates a single object from a line from the CSV file.
void	run()

Methods inherited from class Object

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

Field Details

lineNumber

private final long lineNumber

mapper

private final MappingStrategy<? extends T> mapper

filter

private final CsvToBeanFilter filter

verifiers

private final List<BeanVerifier<T>> verifiers

line

private final String[] line

resultantBeanQueue

private final BlockingQueue<OrderedObject<T>> resultantBeanQueue

thrownExceptionsQueue

private final BlockingQueue<OrderedObject<CsvException>> thrownExceptionsQueue

expectedRecords

private final SortedSet<Long> expectedRecords

exceptionHandler

private final CsvExceptionHandler exceptionHandler

Constructor Details

ProcessCsvLine

public ProcessCsvLine(long lineNumber,
 MappingStrategy<? extends T> mapper,
 CsvToBeanFilter filter,
 List<BeanVerifier<T>> verifiers,
 String[] line,
 BlockingQueue<OrderedObject<T>> resultantBeanQueue,
 BlockingQueue<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

processLine

private T processLine()
               throws CsvBeanIntrospectionException,
CsvBadConverterException,
CsvFieldAssignmentException,
CsvChainedException

Creates a single object from a line from the CSV file.

Returns:

Object containing the values.

Throws:

CsvBeanIntrospectionException - Thrown on error creating bean.

CsvBadConverterException - If a custom converter cannot be initialized properly

CsvFieldAssignmentException - A more specific subclass of this exception is thrown for any problem decoding and assigning a field of the input to a bean field

CsvChainedException - If multiple exceptions are thrown for the same input line