de.ipcon.db.fulltext.compass

Class MyTISMIndexEntitiesIndexer

java.lang.Object

de.ipcon.db.fulltext.compass.MyTISMIndexEntitiesIndexer

All Implemented Interfaces:

org.compass.gps.device.support.parallel.IndexEntitiesIndexer

public class MyTISMIndexEntitiesIndexer
extends java.lang.Object
implements org.compass.gps.device.support.parallel.IndexEntitiesIndexer

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

Constructor Summary

Constructors

Constructor and Description
MyTISMIndexEntitiesIndexer(DBManLocalI _dbm, int _fetchSize)
MyTISMIndexEntitiesIndexer(DBManLocalI _dbm, int _fetchSize, IndexingListenerI _indexingListener)
MyTISMIndexEntitiesIndexer(DBManLocalI _dbm, int _fetchSize, IndexingListenerI _indexingListener, boolean _indexDeletedBOs)

Method Summary

Modifier and Type	Method and Description
DBManLocalI	getDbm()
SchemaVsIndexDiff	getDiff()
int	getFetchSize()
java.lang.Boolean	getIndexDeletedBOsOld()
IndexingListenerI	getIndexingListener()
boolean	isIndexDeletedBOs()
void	performIndex(org.compass.core.CompassSession _session, org.compass.gps.device.support.parallel.IndexEntity[] _entities)
void	setDbm(DBManLocalI $4)
void	setDiff(SchemaVsIndexDiff $8)
void	setFetchSize(int $9)
void	setIndexDeletedBOs(boolean $5)
void	setIndexDeletedBOsOld(java.lang.Boolean $6)
void	setIndexingListener(IndexingListenerI $7)

Methods inherited from class java.lang.Object

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

Constructor Detail

MyTISMIndexEntitiesIndexer

public MyTISMIndexEntitiesIndexer(DBManLocalI _dbm,
                                  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.

MyTISMIndexEntitiesIndexer

public MyTISMIndexEntitiesIndexer(DBManLocalI _dbm,
                                  int _fetchSize,
                                  IndexingListenerI _indexingListener)

MyTISMIndexEntitiesIndexer

public MyTISMIndexEntitiesIndexer(DBManLocalI _dbm,
                                  int _fetchSize,
                                  IndexingListenerI _indexingListener,
                                  boolean _indexDeletedBOs)

Method Detail

performIndex

public void performIndex(org.compass.core.CompassSession _session,
                         org.compass.gps.device.support.parallel.IndexEntity[] _entities)
                  throws org.compass.core.CompassException

Specified by:

performIndex in interface org.compass.gps.device.support.parallel.IndexEntitiesIndexer

Throws:

org.compass.core.CompassException

getDbm

public DBManLocalI getDbm()

setDbm

public void setDbm(DBManLocalI $4)

isIndexDeletedBOs

public boolean isIndexDeletedBOs()

setIndexDeletedBOs

public void setIndexDeletedBOs(boolean $5)

getIndexDeletedBOsOld

public java.lang.Boolean getIndexDeletedBOsOld()

setIndexDeletedBOsOld

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

getIndexingListener

public IndexingListenerI getIndexingListener()

setIndexingListener

public void setIndexingListener(IndexingListenerI $7)

getDiff

public SchemaVsIndexDiff getDiff()

setDiff

public void setDiff(SchemaVsIndexDiff $8)

getFetchSize

public int getFetchSize()

setFetchSize

public void setFetchSize(int $9)