com.senseidb.gateway.file
Class LinedFileDataProviderBuilder

java.lang.Object
  com.senseidb.plugin.AbstractSenseiPlugin
      com.senseidb.gateway.SenseiGateway<String>
          com.senseidb.gateway.file.LinedFileDataProviderBuilder

All Implemented Interfaces:

SenseiPlugin

public class LinedFileDataProviderBuilder
extends SenseiGateway<String>

Field Summary

Fields inherited from class com.senseidb.gateway.SenseiGateway

DEFAULT_VERSION_COMPARATOR

Fields inherited from class com.senseidb.plugin.AbstractSenseiPlugin

config, pluginRegistry

Constructor Summary

LinedFileDataProviderBuilder()

Method Summary

proj.zoie.impl.indexing.StreamDataProvider<org.json.JSONObject>	buildDataProvider(DataSourceFilter<String> dataFilter, String oldSinceKey, ShardingStrategy shardingStrategy, Set<Integer> partitions)
Comparator<String>	getVersionComparator()

Methods inherited from class com.senseidb.gateway.SenseiGateway

buildDataProvider, getDataSourceFilter

Methods inherited from class com.senseidb.plugin.AbstractSenseiPlugin

init, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

LinedFileDataProviderBuilder

public LinedFileDataProviderBuilder()

Method Detail

buildDataProvider

public proj.zoie.impl.indexing.StreamDataProvider<org.json.JSONObject> buildDataProvider(DataSourceFilter<String> dataFilter,
                                                                                         String oldSinceKey,
                                                                                         ShardingStrategy shardingStrategy,
                                                                                         Set<Integer> partitions)
                                                                                  throws Exception

Specified by:

buildDataProvider in class SenseiGateway<String>

Throws:

Exception

getVersionComparator

public Comparator<String> getVersionComparator()

Specified by:

getVersionComparator in class SenseiGateway<String>