Package step.datapool.file

Class CSVReaderDataPool

java.lang.Object

step.datapool.DataSet<FileDataPool>

step.datapool.file.FileReaderDataPool

step.datapool.file.CSVReaderDataPool

public class CSVReaderDataPool
extends FileReaderDataPool

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	CSVReaderDataPool.CSVRowWrapper

Field Summary

Fields

Modifier and Type	Field	Description
protected java.lang.String	delimiter
protected java.util.concurrent.atomic.AtomicBoolean	hasChanges
protected java.util.Vector<java.lang.String>	headers
static org.slf4j.Logger	logger
protected java.io.File	tempFile
protected java.io.PrintWriter	tempFileWriter

Fields inherited from class step.datapool.DataSet

closing, configuration, context, isRowCommitEnabled

Constructor Summary

Constructors

Constructor	Description
CSVReaderDataPool(CSVDataPool configuration)

Method Summary

Modifier and Type	Method	Description
void	addRow(java.lang.Object row)
void	close()
void	doFirst_()
java.util.Vector<java.lang.String>	getHeaders(java.lang.String readOneLine)
void	init()
protected boolean	isWriteQueueSupportEnabled()
java.lang.Object	postProcess(java.lang.String line)
java.util.Vector<java.lang.String>	splitCSV(java.lang.String readOneLine)
void	writeRow(DataPoolRow row)

Methods inherited from class step.datapool.file.FileReaderDataPool

next_, readOneLine, reset

Methods inherited from class step.datapool.DataSet

enableRowCommit, next, save, setContext

Methods inherited from class java.lang.Object

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

Field Detail

logger

public static final org.slf4j.Logger logger

headers

protected java.util.Vector<java.lang.String> headers

delimiter

protected java.lang.String delimiter

hasChanges

protected java.util.concurrent.atomic.AtomicBoolean hasChanges

tempFile

protected java.io.File tempFile

tempFileWriter

protected java.io.PrintWriter tempFileWriter

Constructor Detail

CSVReaderDataPool

public CSVReaderDataPool(CSVDataPool configuration)

Method Detail

init

public void init()

Overrides:

init in class FileReaderDataPool

close

public void close()

Overrides:

close in class FileReaderDataPool

writeRow

public void writeRow(DataPoolRow row)
              throws java.io.IOException

Overrides:

writeRow in class DataSet<FileDataPool>

Throws:

java.io.IOException

isWriteQueueSupportEnabled

protected boolean isWriteQueueSupportEnabled()

Overrides:

isWriteQueueSupportEnabled in class DataSet<FileDataPool>

postProcess

public java.lang.Object postProcess(java.lang.String line)

Specified by:

postProcess in class FileReaderDataPool

getHeaders

public java.util.Vector<java.lang.String> getHeaders(java.lang.String readOneLine)

splitCSV

public java.util.Vector<java.lang.String> splitCSV(java.lang.String readOneLine)

doFirst_

public void doFirst_()

Specified by:

doFirst_ in class FileReaderDataPool

addRow

public void addRow(java.lang.Object row)

Specified by:

addRow in class DataSet<FileDataPool>