Package com.intellij.util.indexing

Class VfsAwareMapReduceIndex<Key,Value>

java.lang.Object

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

com.intellij.util.indexing.VfsAwareMapReduceIndex<Key,Value>

All Implemented Interfaces:

InvertedIndex<Key,Value,FileContent>, UpdatableIndex<Key,Value,FileContent>

public class VfsAwareMapReduceIndex<Key,Value>
extends MapReduceIndex<Key,Value,FileContent>
implements UpdatableIndex<Key,Value,FileContent>

Field Summary

Fields

Modifier and Type	Field and Description
static int	VERSION

Fields inherited from class com.intellij.util.indexing.impl.MapReduceIndex

myExtension, myIndexer, myIndexId, myModificationStamp, myStorage, myValueExternalizer

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

ARE_COMPOSITE_INDEXERS_ENABLED

Constructor Summary

Constructors

Constructor and Description
VfsAwareMapReduceIndex(IndexExtension<Key,Value,FileContent> extension, IndexStorage<Key,Value> storage)
VfsAwareMapReduceIndex(IndexExtension<Key,Value,FileContent> extension, IndexStorage<Key,Value> storage, ForwardIndex forwardIndexMap, ForwardIndexAccessor<Key,Value> forwardIndexAccessor, SnapshotInputMappings<Key,Value> snapshotInputMappings, java.util.concurrent.locks.ReadWriteLock lock)
VfsAwareMapReduceIndex(IndexExtension<Key,Value,FileContent> extension, IndexStorage<Key,Value> storage, SnapshotInputMappings<Key,Value> snapshotInputMappings)

Method Summary

Modifier and Type	Method and Description
void	checkCanceled()
void	cleanupForNextTest()
void	cleanupMemoryStorage()
protected void	doClear()
protected void	doDispose()
protected void	doFlush()
java.util.Map<Key,Value>	getIndexedFileData(int fileId)
protected InputDataDiffBuilder<Key,Value>	getKeysDiffBuilder(int inputId)
protected InputDataDiffBuilder<Key,Value>	getKeysDiffBuilderInMemoryMode(int inputId, java.util.Map<Key,Value> keysAndValues)
static boolean	isCompositeIndexer(DataIndexer<?,?,?> indexer)
protected boolean	isIndexConfigurationUpToDate(int fileId, IndexedFile file)
boolean	isIndexedStateForFile(int fileId, IndexedFile file)
protected InputData<Key,Value>	mapInput(int inputId, FileContent content)
boolean	processAllKeys(Processor<? super Key> processor, GlobalSearchScope scope, IdFilter idFilter)
void	removeTransientDataForFile(int inputId)
protected void	removeTransientDataForInMemoryKeys(int inputId, java.util.Map<? extends Key,? extends Value> map)
void	removeTransientDataForKeys(int inputId, java.util.Collection<? extends Key> keys)
protected void	requestRebuild(java.lang.Throwable ex)
void	resetIndexedStateForFile(int fileId)
void	setBufferingEnabled(boolean enabled)
void	setIndexedStateForFile(int fileId, IndexedFile file)
protected void	updateForwardIndex(int inputId, InputData<Key,Value> data)

Methods inherited from class com.intellij.util.indexing.impl.MapReduceIndex

calculateUpdateData, checkValuesHaveProperEqualsAndHashCode, clear, createIndexUpdateComputation, dispose, flush, getData, getExtension, getForwardIndex, getForwardIndexAccessor, getLock, getModificationStamp, getReadLock, getStorage, getWriteLock, mapByIndexer, update, updateWithMap

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.intellij.util.indexing.UpdatableIndex

getExtension, getLock, getModificationStamp, getReadLock, getWriteLock, updateWithMap

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

clear, dispose, flush, getData, update

Field Detail

VERSION

public static final int VERSION

See Also:

Constant Field Values

Constructor Detail

VfsAwareMapReduceIndex

public VfsAwareMapReduceIndex(IndexExtension<Key,Value,FileContent> extension,
                              IndexStorage<Key,Value> storage)
                       throws java.io.IOException

Throws:

java.io.IOException

VfsAwareMapReduceIndex

public VfsAwareMapReduceIndex(IndexExtension<Key,Value,FileContent> extension,
                              IndexStorage<Key,Value> storage,
                              SnapshotInputMappings<Key,Value> snapshotInputMappings)
                       throws java.io.IOException

Throws:

java.io.IOException

VfsAwareMapReduceIndex

public VfsAwareMapReduceIndex(IndexExtension<Key,Value,FileContent> extension,
                              IndexStorage<Key,Value> storage,
                              ForwardIndex forwardIndexMap,
                              ForwardIndexAccessor<Key,Value> forwardIndexAccessor,
                              SnapshotInputMappings<Key,Value> snapshotInputMappings,
                              java.util.concurrent.locks.ReadWriteLock lock)

Method Detail

isCompositeIndexer

public static boolean isCompositeIndexer(DataIndexer<?,?,?> indexer)

mapInput

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

Overrides:

mapInput in class MapReduceIndex<Key,Value,FileContent>

getKeysDiffBuilder

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

Overrides:

getKeysDiffBuilder in class MapReduceIndex<Key,Value,FileContent>

Throws:

java.io.IOException

getKeysDiffBuilderInMemoryMode

protected InputDataDiffBuilder<Key,Value> getKeysDiffBuilderInMemoryMode(int inputId,
                                                                         java.util.Map<Key,Value> keysAndValues)

updateForwardIndex

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

Overrides:

updateForwardIndex in class MapReduceIndex<Key,Value,FileContent>

Throws:

java.io.IOException

setIndexedStateForFile

public void setIndexedStateForFile(int fileId,
                                   IndexedFile file)

Specified by:

setIndexedStateForFile in interface UpdatableIndex<Key,Value,FileContent>

resetIndexedStateForFile

public void resetIndexedStateForFile(int fileId)

Specified by:

resetIndexedStateForFile in interface UpdatableIndex<Key,Value,FileContent>

isIndexedStateForFile

public boolean isIndexedStateForFile(int fileId,
                                     IndexedFile file)

Specified by:

isIndexedStateForFile in interface UpdatableIndex<Key,Value,FileContent>

isIndexConfigurationUpToDate

protected boolean isIndexConfigurationUpToDate(int fileId,
                                               IndexedFile file)

removeTransientDataForFile

public void removeTransientDataForFile(int inputId)

Specified by:

removeTransientDataForFile in interface UpdatableIndex<Key,Value,FileContent>

removeTransientDataForInMemoryKeys

protected void removeTransientDataForInMemoryKeys(int inputId,
                                                  java.util.Map<? extends Key,? extends Value> map)

removeTransientDataForKeys

public void removeTransientDataForKeys(int inputId,
                                       java.util.Collection<? extends Key> keys)

Specified by:

removeTransientDataForKeys in interface UpdatableIndex<Key,Value,FileContent>

setBufferingEnabled

public void setBufferingEnabled(boolean enabled)

Specified by:

setBufferingEnabled in interface UpdatableIndex<Key,Value,FileContent>

cleanupMemoryStorage

public void cleanupMemoryStorage()

Specified by:

cleanupMemoryStorage in interface UpdatableIndex<Key,Value,FileContent>

cleanupForNextTest

public void cleanupForNextTest()

Specified by:

cleanupForNextTest in interface UpdatableIndex<Key,Value,FileContent>

processAllKeys

public boolean processAllKeys(Processor<? super Key> processor,
                              GlobalSearchScope scope,
                              IdFilter idFilter)
                       throws StorageException

Specified by:

processAllKeys in interface UpdatableIndex<Key,Value,FileContent>

Throws:

StorageException

getIndexedFileData

public java.util.Map<Key,Value> getIndexedFileData(int fileId)
                                            throws StorageException

Specified by:

getIndexedFileData in interface UpdatableIndex<Key,Value,FileContent>

Throws:

StorageException

checkCanceled

public void checkCanceled()

Specified by:

checkCanceled in class MapReduceIndex<Key,Value,FileContent>

requestRebuild

protected void requestRebuild(java.lang.Throwable ex)

Specified by:

requestRebuild in class MapReduceIndex<Key,Value,FileContent>

doClear

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

Overrides:

doClear in class MapReduceIndex<Key,Value,FileContent>

Throws:

StorageException

java.io.IOException

doFlush

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

Overrides:

doFlush in class MapReduceIndex<Key,Value,FileContent>

Throws:

java.io.IOException

StorageException

doDispose

protected void doDispose()
                  throws StorageException

Overrides:

doDispose in class MapReduceIndex<Key,Value,FileContent>

Throws:

StorageException