Module org.apache.lucene.monitor

Package org.apache.lucene.monitor

Class WritableQueryIndex

java.lang.Object

org.apache.lucene.monitor.QueryIndex

org.apache.lucene.monitor.WritableQueryIndex

All Implemented Interfaces:

Closeable, AutoCloseable

class WritableQueryIndex
extends QueryIndex

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	WritableQueryIndex.Indexable
(package private) static final class	WritableQueryIndex.MonitorQueryCollector	A Collector that decodes the stored query for each document hit.

Nested classes/interfaces inherited from class org.apache.lucene.monitor.QueryIndex

QueryIndex.CachePopulator, QueryIndex.DataValues, QueryIndex.FIELDS, QueryIndex.QueryBuilder, QueryIndex.QueryCollector, QueryIndex.QueryTermFilter

Field Summary

Fields

Modifier and Type	Field	Description
private final Object	commitLock
private static final BytesRef	EMPTY
protected long	lastPurged
private final Presearcher	presearcher
private Map<String,QueryCacheEntry>	purgeCache
private final ScheduledExecutorService	purgeExecutor
private final ReadWriteLock	purgeLock
protected ConcurrentMap<String,QueryCacheEntry>	queries
private final IndexWriter	writer

Fields inherited from class org.apache.lucene.monitor.QueryIndex

decomposer, listeners, manager, serializer, termFilters

Constructor Summary

Constructors

Constructor	Description
WritableQueryIndex(MonitorConfiguration configuration, Presearcher presearcher)

Method Summary

Modifier and Type	Method	Description
private List<WritableQueryIndex.Indexable>	buildIndexables(List<MonitorQuery> updates)
int	cacheSize()
void	clear()
void	close()
void	commit(List<MonitorQuery> updates)
private void	commitWithoutNotify(List<MonitorQuery> updates)
void	deleteQueries(List<String> ids)
long	getLastPurged()
int	numDocs()
private void	populateQueryCache(MonitorQuerySerializer serializer, QueryDecomposer decomposer)
void	purgeCache()
(package private) void	purgeCache(QueryIndex.CachePopulator populator)
long	search(QueryIndex.QueryBuilder queryBuilder, QueryIndex.QueryCollector matcher)

Methods inherited from class org.apache.lucene.monitor.QueryIndex

addListener, getQuery, scan, search

Methods inherited from class java.lang.Object

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

Field Details

writer

private final IndexWriter writer

presearcher

private final Presearcher presearcher

purgeCache

private volatile Map<String,QueryCacheEntry> purgeCache

purgeLock

private final ReadWriteLock purgeLock

commitLock

private final Object commitLock

purgeExecutor

private final ScheduledExecutorService purgeExecutor

queries

protected volatile ConcurrentMap<String,QueryCacheEntry> queries

lastPurged

protected long lastPurged

EMPTY

private static final BytesRef EMPTY

Constructor Details

WritableQueryIndex

WritableQueryIndex(MonitorConfiguration configuration,
 Presearcher presearcher)
            throws IOException

Throws:

IOException

Method Details

commit

public void commit(List<MonitorQuery> updates)
            throws IOException

Specified by:

commit in class QueryIndex

Throws:

IOException

commitWithoutNotify

private void commitWithoutNotify(List<MonitorQuery> updates)
                          throws IOException

Throws:

IOException

populateQueryCache

private void populateQueryCache(MonitorQuerySerializer serializer,
 QueryDecomposer decomposer)
                         throws IOException

Throws:

IOException

buildIndexables

private List<WritableQueryIndex.Indexable> buildIndexables(List<MonitorQuery> updates)

search

public long search(QueryIndex.QueryBuilder queryBuilder,
 QueryIndex.QueryCollector matcher)
            throws IOException

Specified by:

search in class QueryIndex

Throws:

IOException

purgeCache

public void purgeCache()
                throws IOException

Specified by:

purgeCache in class QueryIndex

Throws:

IOException

purgeCache

void purgeCache(QueryIndex.CachePopulator populator)
         throws IOException

Specified by:

purgeCache in class QueryIndex

Throws:

IOException

close

public void close()
           throws IOException

Throws:

IOException

numDocs

public int numDocs()
            throws IOException

Specified by:

numDocs in class QueryIndex

Throws:

IOException

cacheSize

public int cacheSize()

Specified by:

cacheSize in class QueryIndex

deleteQueries

public void deleteQueries(List<String> ids)
                   throws IOException

Specified by:

deleteQueries in class QueryIndex

Throws:

IOException

clear

public void clear()
           throws IOException

Specified by:

clear in class QueryIndex

Throws:

IOException

getLastPurged

public long getLastPurged()

Specified by:

getLastPurged in class QueryIndex