com.sun.labs.minion.classification
Class ClusterManager

java.lang.Object
  com.sun.labs.minion.indexer.partition.PartitionManager
      com.sun.labs.minion.classification.ClusterManager

All Implemented Interfaces:

com.sun.labs.util.props.Component, com.sun.labs.util.props.Configurable

public class ClusterManager
extends PartitionManager

The ClusterManager is a specialization of the PartitionManager. It performs the same roll on cluster partitions that the Partition Manager performs on inverted file partitions.

Nested Class Summary

Nested classes/interfaces inherited from class com.sun.labs.minion.indexer.partition.PartitionManager

PartitionManager.ExtFilter, PartitionManager.HouseKeeper, PartitionManager.Merger

Field Summary

protected ClassifierManager	classifierManager
static java.lang.String	PROP_CLASSIFIER_MANAGER

Fields inherited from class com.sun.labs.minion.indexer.partition.PartitionManager

activeFile, activeLock, activeParts, engine, fieldsToLoad, indexConfig, indexDir, indexDirFile, keeper, keeperThread, lastPurgeTime, lockDirFile, logTag, mergedParts, mergeLock, mergeRate, mergeSpace, mergeThread, metaFile, name, PROP_ACTIVE_CHECK_INTERVAL, PROP_ASYNC_MERGES, PROP_CALCULATE_DVL, PROP_INDEX_CONFIG, PROP_LOCK_DIR, PROP_MAX_MERGE_SIZE, PROP_MERGE_RATE, PROP_OPEN_PARTITION_HIGH_WATER_MARK, PROP_OPEN_PARTITION_LOW_WATER_MARK, PROP_PART_CLOSE_DELAY, PROP_PART_REAP_DELAY, PROP_PARTITION_FACTORY, PROP_REAP_DOES_NOTHING, PROP_STARTING_DATA, PROP_TERMSTATS_DICT_FACTORY, queryTimer, randID, subDir, thingsToClose

Constructor Summary

ClusterManager()
Constructs the ClusterManager.

Method Summary

void	dump() Signals the ClusterManager that all the clusters currently in memory should be dumped to disk so that they can be used for classifying new documents.
ClassifierManager	getClassManager() Gets the class manager that this instance is working with
java.lang.String	getName() Gets the name of the index.
void	newProperties(com.sun.labs.util.props.PropertySheet ps)
protected void	reapPartition(int partNumber) A method to reap a single partition.

Methods inherited from class com.sun.labs.minion.indexer.partition.PartitionManager

addIndexListener, addNewPartition, addNewPartition, checkHK, deleteDocument, deleteDocuments, deleteKeys, getActivePartitions, getAllFieldValues, getCalculateDVL, getDistance, getDistance, getDocumentTerm, getDocumentVector, getDocumentVector, getDocumentVector, getEngine, getFieldInfo, getFieldIterator, getFieldIterator, getFieldNames, getFieldValue, getIndexConfig, getIndexDir, getLastPurgeTime, getLockDir, getMatching, getMerger, getMerger, getMerger, getMergerFromNumbers, getMetaFile, getNActive, getNDocs, getNextPartitionNumber, getNFields, getNTerms, getNTokens, getPartCloseDelay, getPartitions, getPartNumbers, getQueryConfig, getQueryTimer, getRandID, getSimilar, getTermStats, getTermStatsDict, getTopFieldValues, hasFieldedVectors, init, isCasedIndex, isIndexed, makeActiveFile, makeDeletedDocsFile, makeDeletedDocsFile, makeDictionaryFile, makeDictionaryFile, makeMetaFile, makePostingsFile, makePostingsFile, makePostingsFile, makeRemovedPartitionFile, makeRemovedPartitionFile, makeTaxonomyFile, makeTaxonomyFile, makeTermStatsFile, makeVectorLengthFile, makeVectorLengthFile, merge, mergeAll, mergeGeometric, mergeInPieces, newDiskPartition, noMoreMerges, purge, readActiveFile, realMerge, reap, recalculateTermStats, recover, removeIndexListener, setEngine, setLockDir, setMergeRate, setPartCloseDelay, shutdown, startHK, updateActiveParts, updateTermStats, writeActiveFile

Methods inherited from class java.lang.Object

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

Field Detail

classifierManager

protected ClassifierManager classifierManager

PROP_CLASSIFIER_MANAGER

@ConfigComponent(type=ClassifierManager.class)
public static final java.lang.String PROP_CLASSIFIER_MANAGER

See Also:

Constant Field Values

Constructor Detail

ClusterManager

public ClusterManager()

Constructs the ClusterManager. Since the Cluster Manager only provides a main dictionary and a document dictionary, nothing special is needed.

Method Detail

dump

public void dump()
          throws java.io.IOException

Signals the ClusterManager that all the clusters currently in memory should be dumped to disk so that they can be used for classifying new documents.

Throws:

java.io.IOException

reapPartition

protected void reapPartition(int partNumber)

A method to reap a single partition. This can be overridden in a subclass so that the reap method will work for the super and subclass.

Overrides:

reapPartition in class PartitionManager

Parameters:

partNumber - the number of the partition to reap.

getClassManager

public ClassifierManager getClassManager()

Gets the class manager that this instance is working with

Returns:

the classifier manager for this cluster manager

newProperties

public void newProperties(com.sun.labs.util.props.PropertySheet ps)
                   throws com.sun.labs.util.props.PropertyException

Specified by:

newProperties in interface com.sun.labs.util.props.Configurable

Overrides:

newProperties in class PartitionManager

Throws:

com.sun.labs.util.props.PropertyException

getName

public java.lang.String getName()

Description copied from class: PartitionManager

Gets the name of the index.

Overrides:

getName in class PartitionManager

Returns:

the configuration name of the index