Package org.apache.batchee.csv
Class CommonsCsvReader
- java.lang.Object
-
- org.apache.batchee.extras.transaction.CountedReader
-
- org.apache.batchee.csv.CommonsCsvReader
-
- All Implemented Interfaces:
javax.batch.api.chunk.ItemReader
public class CommonsCsvReader extends CountedReader
-
-
Field Summary
-
Fields inherited from class org.apache.batchee.extras.transaction.CountedReader
items
-
-
Constructor Summary
Constructors Constructor Description CommonsCsvReader()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()protected ObjectdoRead()protected org.apache.commons.csv.CSVFormatnewFormat()protected ReadernewReader()voidopen(Serializable checkpoint)voidreadHeaders()voidsetAllowMissingColumnNames(String allowMissingColumnNames)voidsetCommentMarker(String commentMarker)voidsetDelimiter(String delimiter)voidsetEncoding(String encoding)voidsetEscapeCharacter(String escapeCharacter)voidsetFormat(String format)voidsetFormat(org.apache.commons.csv.CSVFormat.Predefined predefined)voidsetHeader(String header)voidsetHeaderComments(String headerComments)voidsetIgnoreEmptyLines(String ignoreEmptyLines)voidsetIgnoreSurroundingSpaces(String ignoreSurroundingSpaces)voidsetInput(String input)voidsetLocator(String locator)voidsetMapper(String mapper)voidsetMapping(String mapping)voidsetNullString(String nullString)voidsetQuoteCharacter(String quoteCharacter)voidsetQuoteMode(String quoteMode)voidsetReadHeaders(String readHeaders)voidsetRecordSeparator(String recordSeparator)voidsetSkipHeaderRecord(String skipHeaderRecord)-
Methods inherited from class org.apache.batchee.extras.transaction.CountedReader
checkpointInfo, incrementCount, incrementReaderCount, readItem
-
-
-
-
Method Detail
-
open
public void open(Serializable checkpoint) throws Exception
- Specified by:
openin interfacejavax.batch.api.chunk.ItemReader- Overrides:
openin classCountedReader- Throws:
Exception
-
doRead
protected Object doRead() throws Exception
- Specified by:
doReadin classCountedReader- Throws:
Exception
-
newReader
protected Reader newReader()
-
newFormat
protected org.apache.commons.csv.CSVFormat newFormat()
-
setFormat
public void setFormat(String format)
-
setFormat
public void setFormat(org.apache.commons.csv.CSVFormat.Predefined predefined)
-
setInput
public void setInput(String input)
-
setEncoding
public void setEncoding(String encoding)
-
setMapper
public void setMapper(String mapper)
-
setMapping
public void setMapping(String mapping)
-
setLocator
public void setLocator(String locator)
-
setAllowMissingColumnNames
public void setAllowMissingColumnNames(String allowMissingColumnNames)
-
setDelimiter
public void setDelimiter(String delimiter)
-
setQuoteCharacter
public void setQuoteCharacter(String quoteCharacter)
-
setQuoteMode
public void setQuoteMode(String quoteMode)
-
setCommentMarker
public void setCommentMarker(String commentMarker)
-
setEscapeCharacter
public void setEscapeCharacter(String escapeCharacter)
-
setIgnoreSurroundingSpaces
public void setIgnoreSurroundingSpaces(String ignoreSurroundingSpaces)
-
setIgnoreEmptyLines
public void setIgnoreEmptyLines(String ignoreEmptyLines)
-
setRecordSeparator
public void setRecordSeparator(String recordSeparator)
-
setNullString
public void setNullString(String nullString)
-
setHeaderComments
public void setHeaderComments(String headerComments)
-
setHeader
public void setHeader(String header)
-
setSkipHeaderRecord
public void setSkipHeaderRecord(String skipHeaderRecord)
-
setReadHeaders
public void setReadHeaders(String readHeaders)
-
readHeaders
public void readHeaders()
-
-