net.esper.adapter.csv
Class CSVInputAdapterSpec

java.lang.Object
  net.esper.adapter.csv.CSVInputAdapterSpec

public class CSVInputAdapterSpec
extends Object

A spec for CSVAdapters.

Constructor Summary

CSVInputAdapterSpec(AdapterInputSource adapterInputSource, String eventTypeAlias)
Ctor.

Method Summary

AdapterInputSource	getAdapterInputSource()
Integer	getEventsPerSec()
String	getEventTypeAlias()
String[]	getPropertyOrder()
Map<String,Class>	getPropertyTypes()
String	getTimestampColumn()
boolean	isLooping()
boolean	isUsingEngineThread()
void	setAdapterInputSource(AdapterInputSource adapterInputSource)
void	setEventsPerSec(int eventsPerSec) Sets the number of events per seconds.
void	setEventTypeAlias(String eventTypeAlias)
void	setLooping(boolean looping)
void	setPropertyOrder(String[] propertyOrder)
void	setPropertyTypes(Map<String,Class> propertyTypes) Set the propertyTypes value
void	setTimestampColumn(String timestampColumn) Set the timestamp column name.
void	setUsingEngineThread(boolean usingEngineThread) Set to true to use the engine timer thread for the work, or false to use the current thread.

Methods inherited from class java.lang.Object

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

Constructor Detail

CSVInputAdapterSpec

public CSVInputAdapterSpec(AdapterInputSource adapterInputSource,
                           String eventTypeAlias)

Ctor.

Parameters:

adapterInputSource - - the source for the CSV data

eventTypeAlias - - the alias for the event type created from the CSV data

Method Detail

setEventsPerSec

public void setEventsPerSec(int eventsPerSec)

Sets the number of events per seconds.

Parameters:

eventsPerSec - number of events to send per second

setPropertyOrder

public void setPropertyOrder(String[] propertyOrder)

Parameters:

propertyOrder - - the property order of the properties in the CSV file

setLooping

public void setLooping(boolean looping)

Parameters:

looping - - the isLooping value to set

setPropertyTypes

public void setPropertyTypes(Map<String,Class> propertyTypes)

Set the propertyTypes value

Parameters:

propertyTypes - - a mapping between the names and types of the properties in the CSV file; this will also be the form of the Map event created from the data

setUsingEngineThread

public void setUsingEngineThread(boolean usingEngineThread)

Set to true to use the engine timer thread for the work, or false to use the current thread.

Parameters:

usingEngineThread - true for timer thread

isUsingEngineThread

public boolean isUsingEngineThread()

Returns:

the usingEngineThread

setTimestampColumn

public void setTimestampColumn(String timestampColumn)

Set the timestamp column name.

Parameters:

timestampColumn - - the name of the column to use for timestamps

getTimestampColumn

public String getTimestampColumn()

Returns:

the timestampColumn

getAdapterInputSource

public AdapterInputSource getAdapterInputSource()

Returns:

the adapterInputSource

setAdapterInputSource

public void setAdapterInputSource(AdapterInputSource adapterInputSource)

Parameters:

adapterInputSource - the adapterInputSource to set

getEventTypeAlias

public String getEventTypeAlias()

Returns:

the eventTypeAlias

setEventTypeAlias

public void setEventTypeAlias(String eventTypeAlias)

Parameters:

eventTypeAlias - the eventTypeAlias to set

getEventsPerSec

public Integer getEventsPerSec()

Returns:

the eventsPerSec

isLooping

public boolean isLooping()

Returns:

the looping

getPropertyOrder

public String[] getPropertyOrder()

Returns:

the propertyOrder

getPropertyTypes

public Map<String,Class> getPropertyTypes()

Returns:

the propertyTypes