com.espertech.esperio.csv
Class CSVInputAdapterSpec

java.lang.Object
  com.espertech.esperio.csv.CSVInputAdapterSpec

public class CSVInputAdapterSpec
extends java.lang.Object

A spec for CSVAdapters.

Constructor Summary

CSVInputAdapterSpec(AdapterInputSource adapterInputSource, java.lang.String eventTypeName)
Ctor.

Method Summary

AdapterInputSource	getAdapterInputSource()
java.lang.Integer	getEventsPerSec()
java.lang.String	geteventTypeName()
java.lang.String[]	getPropertyOrder()
java.util.Map<java.lang.String,java.lang.Object>	getPropertyTypes()
java.lang.String	getTimestampColumn()
boolean	isLooping()
boolean	isUsingEngineThread()
boolean	isUsingExternalTimer()
boolean	isUsingTimeSpanEvents() Returns the indicator whether CurrentTimeEvent (false, the default) or CurrentTimeSpanEvent (true) are used for time advancing.
void	setAdapterInputSource(AdapterInputSource adapterInputSource)
void	setEventsPerSec(int eventsPerSec) Sets the number of events per seconds.
void	seteventTypeName(java.lang.String eventTypeName)
void	setLooping(boolean looping)
void	setPropertyOrder(java.lang.String[] propertyOrder)
void	setPropertyTypes(java.util.Map<java.lang.String,java.lang.Object> propertyTypes) Set the propertyTypes value
void	setTimestampColumn(java.lang.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.
void	setUsingExternalTimer(boolean usingExternalTimer) Set to true to use esper's external timer mechanism instead of internal timing
void	setUsingTimeSpanEvents(boolean usingTimeSpanEvents) Sets the indicator whether CurrentTimeEvent (false, the default) or CurrentTimeSpanEvent (true) are used for time advancing.

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,
                           java.lang.String eventTypeName)

Ctor.

Parameters:

adapterInputSource - - the source for the CSV data

eventTypeName - - the name 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(java.lang.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(java.util.Map<java.lang.String,java.lang.Object> 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

setUsingExternalTimer

public void setUsingExternalTimer(boolean usingExternalTimer)

Set to true to use esper's external timer mechanism instead of internal timing

Parameters:

usingExternalTimer - true for external timer

isUsingExternalTimer

public boolean isUsingExternalTimer()

Returns:

true for using external timer

setTimestampColumn

public void setTimestampColumn(java.lang.String timestampColumn)

Set the timestamp column name.

Parameters:

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

getTimestampColumn

public java.lang.String getTimestampColumn()

Returns:

the timestampColumn

getAdapterInputSource

public AdapterInputSource getAdapterInputSource()

Returns:

the adapterInputSource

setAdapterInputSource

public void setAdapterInputSource(AdapterInputSource adapterInputSource)

Parameters:

adapterInputSource - the adapterInputSource to set

geteventTypeName

public java.lang.String geteventTypeName()

Returns:

the eventTypeName

seteventTypeName

public void seteventTypeName(java.lang.String eventTypeName)

Parameters:

eventTypeName - the eventTypeName to set

getEventsPerSec

public java.lang.Integer getEventsPerSec()

Returns:

the eventsPerSec

isLooping

public boolean isLooping()

Returns:

the looping

getPropertyOrder

public java.lang.String[] getPropertyOrder()

Returns:

the propertyOrder

getPropertyTypes

public java.util.Map<java.lang.String,java.lang.Object> getPropertyTypes()

Returns:

the propertyTypes

isUsingTimeSpanEvents

public boolean isUsingTimeSpanEvents()

Returns the indicator whether CurrentTimeEvent (false, the default) or CurrentTimeSpanEvent (true) are used for time advancing.

Returns:

indicator

setUsingTimeSpanEvents

public void setUsingTimeSpanEvents(boolean usingTimeSpanEvents)

Sets the indicator whether CurrentTimeEvent (false, the default) or CurrentTimeSpanEvent (true) are used for time advancing.

Parameters:

usingTimeSpanEvents - new value