de.ipcon.db.fulltext.compass

Class MyTISMIndexEntitiesUpdater

java.lang.Object

de.ipcon.db.fulltext.compass.MyTISMIndexEntitiesUpdater

public class MyTISMIndexEntitiesUpdater
extends java.lang.Object

Encapsules the actual loading of BOs from MyTISM and indexing them with Compass.

Constructor Summary

Constructors

Constructor and Description
MyTISMIndexEntitiesUpdater(DBManLocalI _dbm, org.compass.gps.device.support.parallel.IndexEntity[] _entities, long _startAtBTId, int _fetchSize)
MyTISMIndexEntitiesUpdater(DBManLocalI _dbm, org.compass.gps.device.support.parallel.IndexEntity[] _entities, long _startAtBTId, int _fetchSize, IndexingListenerI _indexingListener)
MyTISMIndexEntitiesUpdater(DBManLocalI _dbm, org.compass.gps.device.support.parallel.IndexEntity[] _entities, long _startAtBTId, int _fetchSize, IndexingListenerI _indexingListener, boolean _indexDeletedBOs)

Method Summary

Modifier and Type	Method and Description
void	close()
DBManLocalI	getDbm()
SchemaVsIndexDiff	getDiff()
org.compass.gps.device.support.parallel.IndexEntity[]	getEntities()
org.compass.gps.device.support.parallel.IndexEntity	getEntities(int $16)
IndexerQueryResultsBP	getFetcher()
int	getFetchSize()
java.lang.Boolean	getIndexDeletedBOsOld()
IndexingListenerI	getIndexingListener()
java.util.Date	getOldestIndexLmod(org.compass.gps.device.support.parallel.IndexEntity[] _entities)
boolean	isDone()
boolean	isIndexDeletedBOs()
void	logStatus()
void	safeSetMaxId(long _id)
void	setDbm(DBManLocalI $8)
void	setDiff(SchemaVsIndexDiff $12)
void	setEntities(org.compass.gps.device.support.parallel.IndexEntity[] $15)
void	setEntities(int $17, org.compass.gps.device.support.parallel.IndexEntity $18)
void	setFetcher(IndexerQueryResultsBP $14)
void	setFetchSize(int $13)
void	setIndexDeletedBOs(boolean $9)
void	setIndexDeletedBOsOld(java.lang.Boolean $10)
void	setIndexingListener(IndexingListenerI $11)
void	updateIndex(org.compass.core.CompassSession _session)
void	updateIndexForEntity(org.compass.core.CompassIndexSession _session, EntityI _entity, java.util.ArrayList _idList, boolean _indexDeletedBOs)

Methods inherited from class java.lang.Object

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

Constructor Detail

MyTISMIndexEntitiesUpdater

public MyTISMIndexEntitiesUpdater(DBManLocalI _dbm,
                                  org.compass.gps.device.support.parallel.IndexEntity[] _entities,
                                  long _startAtBTId,
                                  int _fetchSize)

Parameters:

_dbm - the DBManLocalI instance with which to load the BOs.

_fetchSize - the "chunk size" which determines how many BOs (of a given Entity) are loaded from the DB for indexing; should not be set to high to avoid queries running to long and being automatically aborted. Default is 50.000.

_indexingListener - FIXME the MyTISMGpsDevice that handles updating the index meta data.

_indexDeletedBOs - if false deleted BOs will not be loaded and indexed and if necessary be removed from the index; if true (the default) all BOs will be loaded and indexed.

MyTISMIndexEntitiesUpdater

public MyTISMIndexEntitiesUpdater(DBManLocalI _dbm,
                                  org.compass.gps.device.support.parallel.IndexEntity[] _entities,
                                  long _startAtBTId,
                                  int _fetchSize,
                                  IndexingListenerI _indexingListener)

MyTISMIndexEntitiesUpdater

public MyTISMIndexEntitiesUpdater(DBManLocalI _dbm,
                                  org.compass.gps.device.support.parallel.IndexEntity[] _entities,
                                  long _startAtBTId,
                                  int _fetchSize,
                                  IndexingListenerI _indexingListener,
                                  boolean _indexDeletedBOs)

Method Detail

isDone

public boolean isDone()

logStatus

public void logStatus()

safeSetMaxId

public void safeSetMaxId(long _id)

updateIndex

public void updateIndex(org.compass.core.CompassSession _session)

close

public void close()

updateIndexForEntity

public void updateIndexForEntity(org.compass.core.CompassIndexSession _session,
                                 EntityI _entity,
                                 java.util.ArrayList _idList,
                                 boolean _indexDeletedBOs)

getOldestIndexLmod

public java.util.Date getOldestIndexLmod(org.compass.gps.device.support.parallel.IndexEntity[] _entities)

getDbm

public DBManLocalI getDbm()

setDbm

public void setDbm(DBManLocalI $8)

isIndexDeletedBOs

public boolean isIndexDeletedBOs()

setIndexDeletedBOs

public void setIndexDeletedBOs(boolean $9)

getIndexDeletedBOsOld

public java.lang.Boolean getIndexDeletedBOsOld()

setIndexDeletedBOsOld

public void setIndexDeletedBOsOld(java.lang.Boolean $10)

getIndexingListener

public IndexingListenerI getIndexingListener()

setIndexingListener

public void setIndexingListener(IndexingListenerI $11)

getDiff

public SchemaVsIndexDiff getDiff()

setDiff

public void setDiff(SchemaVsIndexDiff $12)

getFetchSize

public int getFetchSize()

setFetchSize

public void setFetchSize(int $13)

getFetcher

public IndexerQueryResultsBP getFetcher()

setFetcher

public void setFetcher(IndexerQueryResultsBP $14)

getEntities

public org.compass.gps.device.support.parallel.IndexEntity[] getEntities()

setEntities

public void setEntities(org.compass.gps.device.support.parallel.IndexEntity[] $15)

getEntities

public org.compass.gps.device.support.parallel.IndexEntity getEntities(int $16)

setEntities

public void setEntities(int $17,
                        org.compass.gps.device.support.parallel.IndexEntity $18)