Class CSVInputAdapterSpec

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

public class CSVInputAdapterSpec extends Object
A spec for CSVAdapters.
  • Constructor Details

    • CSVInputAdapterSpec

      public CSVInputAdapterSpec(AdapterInputSource adapterInputSource, String eventTypeName)
      Ctor.
      Parameters:
      adapterInputSource - - the source for the CSV data
      eventTypeName - - 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

      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,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
    • 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

      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
    • getEventTypeName

      public String getEventTypeName()
      Returns:
      the eventTypeName
    • setEventTypeName

      public void setEventTypeName(String eventTypeName)
      Parameters:
      eventTypeName - the eventTypeName 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,Object> getPropertyTypes()
      Returns:
      the propertyTypes
    • isUsingTimeSpanEvents

      public boolean isUsingTimeSpanEvents()
      Returns the indicator whether EPEventServiceTimeControl.advanceTime(long) (false, the default) or EPEventServiceTimeControl.advanceTimeSpan(long) (true) are used for time advancing.
      Returns:
      indicator
    • setUsingTimeSpanEvents

      public void setUsingTimeSpanEvents(boolean usingTimeSpanEvents)
      Sets the indicator whether EPEventServiceTimeControl.advanceTime(long) (false, the default) or EPEventServiceTimeControl.advanceTimeSpan(long) (true) are used for time advancing.
      Parameters:
      usingTimeSpanEvents - indicator