Package com.espertech.esperio.csv
Class CSVInputAdapterSpec
java.lang.Object
com.espertech.esperio.csv.CSVInputAdapterSpec
A spec for CSVAdapters.
-
Constructor Summary
ConstructorDescriptionCSVInputAdapterSpec
(AdapterInputSource adapterInputSource, String eventTypeName) Ctor. -
Method Summary
Modifier and TypeMethodDescriptionString[]
boolean
boolean
boolean
boolean
Returns the indicator whetherEPEventServiceTimeControl.advanceTime(long)
(false, the default) orEPEventServiceTimeControl.advanceTimeSpan(long)
(true) are used for time advancing.void
setAdapterInputSource
(AdapterInputSource adapterInputSource) void
setEventsPerSec
(int eventsPerSec) Sets the number of events per seconds.void
setEventTypeName
(String eventTypeName) void
setLooping
(boolean looping) void
setPropertyOrder
(String[] propertyOrder) void
setPropertyTypes
(Map<String, Object> propertyTypes) Set the propertyTypes valuevoid
setTimestampColumn
(String timestampColumn) Set the timestamp column name.void
setUsingExternalTimer
(boolean usingExternalTimer) Set to true to use esper's external timer mechanism instead of internal timingvoid
setUsingRuntimeThread
(boolean usingRuntimeThread) Set to true to use the runtime timer thread for the work, or false to use the current thread.void
setUsingTimeSpanEvents
(boolean usingTimeSpanEvents) Sets the indicator whetherEPEventServiceTimeControl.advanceTime(long)
(false, the default) orEPEventServiceTimeControl.advanceTimeSpan(long)
(true) are used for time advancing.
-
Constructor Details
-
CSVInputAdapterSpec
Ctor.- Parameters:
adapterInputSource
- - the source for the CSV dataeventTypeName
- - the name for the event type created from the CSV data
-
-
Method Details
-
setEventsPerSec
public void setEventsPerSec(int eventsPerSec) Sets the number of events per seconds.- Parameters:
eventsPerSec
- number of events to send per second
-
setPropertyOrder
- 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
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
-
setUsingRuntimeThread
public void setUsingRuntimeThread(boolean usingRuntimeThread) Set to true to use the runtime timer thread for the work, or false to use the current thread.- Parameters:
usingRuntimeThread
- true for timer thread
-
isUsingRuntimeThread
public boolean isUsingRuntimeThread()- Returns:
- the usingRuntimeThread
-
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
Set the timestamp column name.- Parameters:
timestampColumn
- - the name of the column to use for timestamps
-
getTimestampColumn
- Returns:
- the timestampColumn
-
getAdapterInputSource
- Returns:
- the adapterInputSource
-
setAdapterInputSource
- Parameters:
adapterInputSource
- the adapterInputSource to set
-
getEventTypeName
- Returns:
- the eventTypeName
-
setEventTypeName
- Parameters:
eventTypeName
- the eventTypeName to set
-
getEventsPerSec
- Returns:
- the eventsPerSec
-
isLooping
public boolean isLooping()- Returns:
- the looping
-
getPropertyOrder
- Returns:
- the propertyOrder
-
getPropertyTypes
- Returns:
- the propertyTypes
-
isUsingTimeSpanEvents
public boolean isUsingTimeSpanEvents()Returns the indicator whetherEPEventServiceTimeControl.advanceTime(long)
(false, the default) orEPEventServiceTimeControl.advanceTimeSpan(long)
(true) are used for time advancing.- Returns:
- indicator
-
setUsingTimeSpanEvents
public void setUsingTimeSpanEvents(boolean usingTimeSpanEvents) Sets the indicator whetherEPEventServiceTimeControl.advanceTime(long)
(false, the default) orEPEventServiceTimeControl.advanceTimeSpan(long)
(true) are used for time advancing.- Parameters:
usingTimeSpanEvents
- indicator
-