com.senseidb.indexing
Class DefaultStreamingIndexingManager

java.lang.Object
  com.senseidb.indexing.DefaultStreamingIndexingManager

All Implemented Interfaces:

SenseiIndexingManager<org.json.JSONObject>

public class DefaultStreamingIndexingManager
extends Object
implements SenseiIndexingManager<org.json.JSONObject>

Field Summary

static String

CONFIG_PREFIX

Constructor Summary

DefaultStreamingIndexingManager(SenseiSchema schema, org.apache.commons.configuration.Configuration senseiConfig, SenseiPluginRegistry pluginRegistry, SenseiGateway<?> gateway, ShardingStrategy shardingStrategy)

Method Summary

proj.zoie.api.DataProvider<org.json.JSONObject>	getDataProvider()
void	initialize(Map<Integer,proj.zoie.api.Zoie<com.browseengine.bobo.api.BoboIndexReader,org.json.JSONObject>> zoieSystemMap)
void	shutdown()
void	start()
void	syncWithVersion(long timeToWait, String version)
void	updateOldestSinceKey(String sinceKey)

Methods inherited from class java.lang.Object

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

Field Detail

CONFIG_PREFIX

public static final String CONFIG_PREFIX

See Also:

Constant Field Values

Constructor Detail

DefaultStreamingIndexingManager

public DefaultStreamingIndexingManager(SenseiSchema schema,
                                       org.apache.commons.configuration.Configuration senseiConfig,
                                       SenseiPluginRegistry pluginRegistry,
                                       SenseiGateway<?> gateway,
                                       ShardingStrategy shardingStrategy)

Method Detail

updateOldestSinceKey

public void updateOldestSinceKey(String sinceKey)

initialize

public void initialize(Map<Integer,proj.zoie.api.Zoie<com.browseengine.bobo.api.BoboIndexReader,org.json.JSONObject>> zoieSystemMap)
                throws Exception

Specified by:

initialize in interface SenseiIndexingManager<org.json.JSONObject>

Throws:

Exception

getDataProvider

public proj.zoie.api.DataProvider<org.json.JSONObject> getDataProvider()

Specified by:

getDataProvider in interface SenseiIndexingManager<org.json.JSONObject>

shutdown

public void shutdown()

Specified by:

shutdown in interface SenseiIndexingManager<org.json.JSONObject>

start

public void start()
           throws Exception

Specified by:

start in interface SenseiIndexingManager<org.json.JSONObject>

Throws:

Exception

syncWithVersion

public void syncWithVersion(long timeToWait,
                            String version)
                     throws proj.zoie.api.ZoieException

Specified by:

syncWithVersion in interface SenseiIndexingManager<org.json.JSONObject>

Throws:

proj.zoie.api.ZoieException