Package com.intellij.util.indexing.impl

Class MapReduceIndex<Key,Value,Input>

java.lang.Object

com.intellij.util.indexing.impl.MapReduceIndex<Key,Value,Input>

All Implemented Interfaces:

InvertedIndex<Key,Value,Input>

Direct Known Subclasses:

DiscoveredTestsIndex, TestFilesIndex, VfsAwareMapReduceIndex

public abstract class MapReduceIndex<Key,Value,Input>
extends java.lang.Object
implements InvertedIndex<Key,Value,Input>

Field Summary

Fields

Modifier and Type	Field and Description
protected IndexExtension<Key,Value,Input>	myExtension
protected DataIndexer<Key,Value,Input>	myIndexer
protected IndexId<Key,Value>	myIndexId
protected java.util.concurrent.atomic.AtomicLong	myModificationStamp
protected IndexStorage<Key,Value>	myStorage
protected DataExternalizer<Value>	myValueExternalizer

Fields inherited from interface com.intellij.util.indexing.InvertedIndex

ARE_COMPOSITE_INDEXERS_ENABLED

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	MapReduceIndex(IndexExtension<Key,Value,Input> extension, IndexStorage<Key,Value> storage, ForwardIndex forwardIndex, ForwardIndexAccessor<Key,Value> forwardIndexAccessor)
protected	MapReduceIndex(IndexExtension<Key,Value,Input> extension, IndexStorage<Key,Value> storage, ForwardIndex forwardIndex, ForwardIndexAccessor<Key,Value> forwardIndexAccessor, java.util.concurrent.locks.ReadWriteLock lock)

Method Summary

Modifier and Type	Method and Description
protected UpdateData<Key,Value>	calculateUpdateData(int inputId, Input content)
abstract void	checkCanceled()
static <Key,Value> void	checkValuesHaveProperEqualsAndHashCode(java.util.Map<Key,Value> data, IndexId<Key,Value> indexId, DataExternalizer<Value> valueExternalizer)
void	clear()
protected Computable<java.lang.Boolean>	createIndexUpdateComputation(AbstractUpdateData<Key,Value> updateData)
void	dispose()
protected void	doClear()
protected void	doDispose()
protected void	doFlush()
void	flush()
ValueContainer<Value>	getData(Key key)
IndexExtension<Key,Value,Input>	getExtension()
ForwardIndex	getForwardIndex()
ForwardIndexAccessor<Key,Value>	getForwardIndexAccessor()
protected InputDataDiffBuilder<Key,Value>	getKeysDiffBuilder(int inputId)
java.util.concurrent.locks.ReadWriteLock	getLock()
long	getModificationStamp()
java.util.concurrent.locks.Lock	getReadLock()
IndexStorage<Key,Value>	getStorage()
java.util.concurrent.locks.Lock	getWriteLock()
protected java.util.Map<Key,Value>	mapByIndexer(int inputId, Input content)
protected InputData<Key,Value>	mapInput(int inputId, Input content)
protected abstract void	requestRebuild(java.lang.Throwable e)
Computable<java.lang.Boolean>	update(int inputId, Input content)
protected void	updateForwardIndex(int inputId, InputData<Key,Value> data)
void	updateWithMap(AbstractUpdateData<Key,Value> updateData)

Methods inherited from class java.lang.Object

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

Field Detail

myIndexId

protected final IndexId<Key,Value> myIndexId

myStorage

protected final IndexStorage<Key,Value> myStorage

myValueExternalizer

protected final DataExternalizer<Value> myValueExternalizer

myExtension

protected final IndexExtension<Key,Value,Input> myExtension

myModificationStamp

protected final java.util.concurrent.atomic.AtomicLong myModificationStamp

myIndexer

protected final DataIndexer<Key,Value,Input> myIndexer

Constructor Detail

MapReduceIndex

protected MapReduceIndex(IndexExtension<Key,Value,Input> extension,
                         IndexStorage<Key,Value> storage,
                         ForwardIndex forwardIndex,
                         ForwardIndexAccessor<Key,Value> forwardIndexAccessor,
                         java.util.concurrent.locks.ReadWriteLock lock)

MapReduceIndex

protected MapReduceIndex(IndexExtension<Key,Value,Input> extension,
                         IndexStorage<Key,Value> storage,
                         ForwardIndex forwardIndex,
                         ForwardIndexAccessor<Key,Value> forwardIndexAccessor)

Method Detail

getForwardIndex

public ForwardIndex getForwardIndex()

getForwardIndexAccessor

public ForwardIndexAccessor<Key,Value> getForwardIndexAccessor()

getExtension

public IndexExtension<Key,Value,Input> getExtension()

getStorage

public IndexStorage<Key,Value> getStorage()

getLock

public final java.util.concurrent.locks.ReadWriteLock getLock()

clear

public void clear()

Specified by:

clear in interface InvertedIndex<Key,Value,Input>

doClear

protected void doClear()
                throws StorageException,
                       java.io.IOException

Throws:

StorageException

java.io.IOException

flush

public void flush()
           throws StorageException

Specified by:

flush in interface InvertedIndex<Key,Value,Input>

Throws:

StorageException

doFlush

protected void doFlush()
                throws java.io.IOException,
                       StorageException

Throws:

java.io.IOException

StorageException

dispose

public void dispose()

Specified by:

dispose in interface InvertedIndex<Key,Value,Input>

doDispose

protected void doDispose()
                  throws StorageException

Throws:

StorageException

getReadLock

public final java.util.concurrent.locks.Lock getReadLock()

getWriteLock

public final java.util.concurrent.locks.Lock getWriteLock()

getData

public ValueContainer<Value> getData(Key key)
                              throws StorageException

Specified by:

getData in interface InvertedIndex<Key,Value,Input>

Throws:

StorageException

update

public final Computable<java.lang.Boolean> update(int inputId,
                                                  Input content)

Specified by:

update in interface InvertedIndex<Key,Value,Input>

Parameters:

inputId - *positive* id of content.

createIndexUpdateComputation

protected Computable<java.lang.Boolean> createIndexUpdateComputation(AbstractUpdateData<Key,Value> updateData)

calculateUpdateData

protected UpdateData<Key,Value> calculateUpdateData(int inputId,
                                                    Input content)

updateForwardIndex

protected void updateForwardIndex(int inputId,
                                  InputData<Key,Value> data)
                           throws java.io.IOException

Throws:

java.io.IOException

getKeysDiffBuilder

protected InputDataDiffBuilder<Key,Value> getKeysDiffBuilder(int inputId)
                                                      throws java.io.IOException

Throws:

java.io.IOException

mapInput

protected InputData<Key,Value> mapInput(int inputId,
                                        Input content)

mapByIndexer

protected java.util.Map<Key,Value> mapByIndexer(int inputId,
                                                Input content)

checkCanceled

public abstract void checkCanceled()

requestRebuild

protected abstract void requestRebuild(java.lang.Throwable e)

getModificationStamp

public long getModificationStamp()

updateWithMap

public void updateWithMap(AbstractUpdateData<Key,Value> updateData)
                   throws StorageException

Throws:

StorageException

checkValuesHaveProperEqualsAndHashCode

public static <Key,Value> void checkValuesHaveProperEqualsAndHashCode(java.util.Map<Key,Value> data,
                                                                      IndexId<Key,Value> indexId,
                                                                      DataExternalizer<Value> valueExternalizer)