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
All Methods Instance Methods Concrete Methods 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
-
-
-
-
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 classFileReaderDataPool
-
close
public void close()
- Overrides:
close
in classFileReaderDataPool
-
writeRow
public void writeRow(DataPoolRow row) throws java.io.IOException
- Overrides:
writeRow
in classDataSet<FileDataPool>
- Throws:
java.io.IOException
-
isWriteQueueSupportEnabled
protected boolean isWriteQueueSupportEnabled()
- Overrides:
isWriteQueueSupportEnabled
in classDataSet<FileDataPool>
-
postProcess
public java.lang.Object postProcess(java.lang.String line)
- Specified by:
postProcess
in classFileReaderDataPool
-
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 classFileReaderDataPool
-
addRow
public void addRow(java.lang.Object row)
- Specified by:
addRow
in classDataSet<FileDataPool>
-
-