stream.lookup

Class CsvDatabase

java.lang.Object

stream.lookup.AbstractDatabase

stream.lookup.CsvDatabase

All Implemented Interfaces:

LifeCycle, LookupService, Service

public class CsvDatabase
extends AbstractDatabase

An implementation of the AbstractDatabase lookup service, that reads data from a CSV file at initialization time.

Author:

Christian Bockermann

Field Summary

Fields

Modifier and Type	Field and Description
(package private) boolean	header
(package private) String[]	keys
(package private) String	separator

Fields inherited from class stream.lookup.AbstractDatabase

database, key, log, url

Constructor Summary

Constructors

Constructor and Description
CsvDatabase()

Method Summary

Methods

Modifier and Type	Method and Description
String[]	getKeys()
String	getSeparator()
boolean	isHeader()
protected void	populateDatabase(SourceURL url, Map<String,Data> database)
void	setHeader(boolean header)
void	setKeys(String[] keys)
void	setSeparator(String separator)

Methods inherited from class stream.lookup.AbstractDatabase

finish, getKey, getUrl, init, lookup, readDatabase, reset, setKey, setUrl

Methods inherited from class java.lang.Object

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

Field Detail

header

boolean header

keys

String[] keys

separator

String separator

Constructor Detail

CsvDatabase

public CsvDatabase()

Method Detail

populateDatabase

protected void populateDatabase(SourceURL url,
                    Map<String,Data> database)
                         throws Exception

Specified by:

populateDatabase in class AbstractDatabase

Throws:

Exception

See Also:

AbstractDatabase.populateDatabase(stream.io.SourceURL, java.util.Map)

isHeader

public boolean isHeader()

Returns:

the header

setHeader

@Parameter(description="Whether to use the first line as headers (keys/attribute names). ",
           required=false)
public void setHeader(boolean header)

Parameters:

header - the header to set

getKeys

public String[] getKeys()

Returns:

the keys

setKeys

@Parameter(description="The keys of the CSV file. If not specified, the first line of the CSV will be used as keys.",
           required=false)
public void setKeys(String[] keys)

Parameters:

keys - the keys to set

getSeparator

public String getSeparator()

Returns:

the separator

setSeparator

@Parameter(description="The separator string used for the CSV stream reading.",
           required=false)
public void setSeparator(String separator)

Parameters:

separator - the separator to set