com.senseidb.gateway.file
Class LinedJsonFileDataProvider

java.lang.Object
  proj.zoie.impl.indexing.StreamDataProvider<D>
      com.senseidb.gateway.file.LinedFileDataProvider<org.json.JSONObject>
          com.senseidb.gateway.file.LinedJsonFileDataProvider

All Implemented Interfaces:

DataSourceFilterable<String>, proj.zoie.api.DataProvider<org.json.JSONObject>, proj.zoie.mbean.DataProviderAdminMBean

public class LinedJsonFileDataProvider
extends LinedFileDataProvider<org.json.JSONObject>
implements DataSourceFilterable<String>

Field Summary

Fields inherited from class proj.zoie.impl.indexing.StreamDataProvider

_versionComparator

Constructor Summary

LinedJsonFileDataProvider(Comparator<String> versionComparator, File file, long startingOffset)

Method Summary

protected org.json.JSONObject	convertLine(String line)
void	setFilter(DataSourceFilter<String> filter)

Methods inherited from class com.senseidb.gateway.file.LinedFileDataProvider

next, reset, setStartingOffset, start, stop

Methods inherited from class proj.zoie.impl.indexing.StreamDataProvider

getBatchSize, getDataConsumer, getEventCount, getEventsPerMinute, getMaxEventsPerMinute, getRetryTime, getStatus, pause, resume, setBatchSize, setDataConsumer, setMaxEventsPerMinute, setRetryTime, syncWithVersion, syncWthVersion

Methods inherited from class java.lang.Object

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

Constructor Detail

LinedJsonFileDataProvider

public LinedJsonFileDataProvider(Comparator<String> versionComparator,
                                 File file,
                                 long startingOffset)

Method Detail

setFilter

public void setFilter(DataSourceFilter<String> filter)

Specified by:

setFilter in interface DataSourceFilterable<String>

convertLine

protected org.json.JSONObject convertLine(String line)
                                   throws IOException

Specified by:

convertLine in class LinedFileDataProvider<org.json.JSONObject>

Throws:

IOException