public class CSVDataSource extends Object implements DataSourceIF
Modifier and Type | Field and Description |
---|---|
protected String |
encoding |
protected int |
ignoreFirstLines |
protected RelationMapping |
mapping |
protected File |
path |
protected char |
quoteCharacter |
protected char |
separator |
Modifier and Type | Method and Description |
---|---|
void |
close()
INTERNAL: Closes the data source so that it can release any open
resources.
|
ChangelogReaderIF |
getChangelogReader(Changelog changelog,
String startOrder)
INTERNAL: Returns a changelog reader.
|
String |
getMaxOrderValue(Changelog changelog)
INTERNAL: Returns the maximum value of the order column for the
specified changelog.
|
TupleReaderIF |
getReader(String relation)
INTERNAL: Returns a tuple reader for the given relation.
|
Collection<Relation> |
getRelations()
INTERNAL: Returns the relations that the data source knows
of.
|
protected void |
setEncoding(String encoding) |
protected void |
setIgnoreFirstLines(int ignoreFirstLines) |
protected void |
setPath(String _path) |
protected void |
setQuoteCharacter(char quoteCharacter) |
protected void |
setSeparator(char separator) |
String |
toString() |
protected final RelationMapping mapping
protected File path
protected String encoding
protected char separator
protected char quoteCharacter
protected int ignoreFirstLines
protected void setPath(String _path)
protected void setEncoding(String encoding)
protected void setSeparator(char separator)
protected void setQuoteCharacter(char quoteCharacter)
protected void setIgnoreFirstLines(int ignoreFirstLines)
public Collection<Relation> getRelations()
DataSourceIF
getRelations
in interface DataSourceIF
public TupleReaderIF getReader(String relation)
DataSourceIF
getReader
in interface DataSourceIF
public ChangelogReaderIF getChangelogReader(Changelog changelog, String startOrder)
DataSourceIF
getChangelogReader
in interface DataSourceIF
public String getMaxOrderValue(Changelog changelog)
DataSourceIF
getMaxOrderValue
in interface DataSourceIF
public void close()
DataSourceIF
close
in interface DataSourceIF