com.senseidb.gateway
Class SenseiGateway<V>

java.lang.Object
  com.senseidb.plugin.AbstractSenseiPlugin
      com.senseidb.gateway.SenseiGateway<V>

All Implemented Interfaces:

SenseiPlugin

Direct Known Subclasses:

LinedFileDataProviderBuilder

public abstract class SenseiGateway<V>
extends AbstractSenseiPlugin

Field Summary

static Comparator<String>

DEFAULT_VERSION_COMPARATOR

Fields inherited from class com.senseidb.plugin.AbstractSenseiPlugin

config, pluginRegistry

Constructor Summary

SenseiGateway()

Method Summary

abstract proj.zoie.impl.indexing.StreamDataProvider<org.json.JSONObject>	buildDataProvider(DataSourceFilter<V> dataFilter, String oldSinceKey, ShardingStrategy shardingStrategy, Set<Integer> partitions)
proj.zoie.impl.indexing.StreamDataProvider<org.json.JSONObject>	buildDataProvider(SenseiSchema senseiSchema, String oldSinceKey, SenseiPluginRegistry pluginRegistry, ShardingStrategy shardingStrategy, Set<Integer> partitions)
DataSourceFilter<V>	getDataSourceFilter(SenseiSchema senseiSchema, SenseiPluginRegistry pluginRegistry)
abstract Comparator<String>	getVersionComparator()

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

Field Detail

DEFAULT_VERSION_COMPARATOR

public static Comparator<String> DEFAULT_VERSION_COMPARATOR

Constructor Detail

SenseiGateway

public SenseiGateway()

Method Detail

getDataSourceFilter

public final DataSourceFilter<V> getDataSourceFilter(SenseiSchema senseiSchema,
                                                     SenseiPluginRegistry pluginRegistry)

buildDataProvider

public final proj.zoie.impl.indexing.StreamDataProvider<org.json.JSONObject> buildDataProvider(SenseiSchema senseiSchema,
                                                                                               String oldSinceKey,
                                                                                               SenseiPluginRegistry pluginRegistry,
                                                                                               ShardingStrategy shardingStrategy,
                                                                                               Set<Integer> partitions)
                                                                                        throws Exception

Throws:

Exception

buildDataProvider

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

Throws:

Exception

getVersionComparator

public abstract Comparator<String> getVersionComparator()