Class ProcessCsvBean<T>

java.lang.Object

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

Type Parameters:

T - The type of the bean to be processed

All Implemented Interfaces:

Runnable

public class ProcessCsvBean<T>
extends Object
implements Runnable

A class for converting one bean into its string representation for writing to an output.

Since:

4.0

Author:

Andrew Rucker Jones

Constructor Summary

Constructors

Constructor	Description
ProcessCsvBean(long lineNumber, MappingStrategy<T> mappingStrategy, T bean, BlockingQueue<com.opencsv.bean.util.OrderedObject<String[]>> resultantLineQueue, BlockingQueue<com.opencsv.bean.util.OrderedObject<CsvException>> thrownExceptionsQueue, SortedSet<Long> expectedRecords, CsvExceptionHandler exceptionHandler)	The only constructor for creating a line of CSV output out of a bean.

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

ProcessCsvBean

public ProcessCsvBean(long lineNumber,
 MappingStrategy<T> mappingStrategy,
 T bean,
 BlockingQueue<com.opencsv.bean.util.OrderedObject<String[]>> resultantLineQueue,
 BlockingQueue<com.opencsv.bean.util.OrderedObject<CsvException>> thrownExceptionsQueue,
 SortedSet<Long> expectedRecords,
 CsvExceptionHandler exceptionHandler)

The only constructor for creating a line of CSV output out of a bean.

Parameters:

lineNumber - Which record in the output file is being processed

mappingStrategy - The mapping strategy to be used

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

resultantLineQueue - A queue in which to place the line 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