Package org.apache.lucene.monitor

Class QueryIndex

java.lang.Object

org.apache.lucene.monitor.QueryIndex

All Implemented Interfaces:

Closeable, AutoCloseable

class QueryIndex
extends Object
implements Closeable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static interface	QueryIndex.CachePopulator
(package private) static final class	QueryIndex.DataValues
(package private) static final class	QueryIndex.FIELDS
private static class	QueryIndex.Indexable
(package private) static final class	QueryIndex.MonitorQueryCollector	A Collector that decodes the stored query for each document hit.
(package private) static interface	QueryIndex.QueryBuilder
(package private) static interface	QueryIndex.QueryCollector
(package private) static class	QueryIndex.QueryTermFilter
private class	QueryIndex.TermsHashBuilder

Field Summary

Fields

Modifier and Type	Field	Description
private final Object	commitLock
private final QueryDecomposer	decomposer
private static final BytesRef	EMPTY
private final SearcherManager	manager
private final Presearcher	presearcher
private Map<String,QueryCacheEntry>	purgeCache
private final ReadWriteLock	purgeLock
private ConcurrentMap<String,QueryCacheEntry>	queries
private final MonitorQuerySerializer	serializer
(package private) final Map<IndexReader.CacheKey,QueryIndex.QueryTermFilter>	termFilters
private final IndexWriter	writer

Constructor Summary

Constructors

Constructor	Description
QueryIndex(MonitorConfiguration config, Presearcher presearcher)

Method Summary

Modifier and Type	Method	Description
private List<QueryIndex.Indexable>	buildIndexables(List<MonitorQuery> updates)
(package private) int	cacheSize()
(package private) void	clear()
void	close()
(package private) void	commit(List<MonitorQuery> updates)
(package private) void	deleteQueries(Iterable<String> ids)
(package private) MonitorQuery	getQuery(String queryId)
(package private) int	numDocs()
private void	populateQueryCache(MonitorQuerySerializer serializer, QueryDecomposer decomposer)
(package private) void	purgeCache()
private void	purgeCache(QueryIndex.CachePopulator populator)	Remove unused queries from the query cache.
(package private) void	scan(QueryIndex.QueryCollector matcher)
(package private) long	search(QueryIndex.QueryBuilder queryBuilder, QueryIndex.QueryCollector matcher)
(package private) long	search(Query query, QueryIndex.QueryCollector matcher)

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

manager

private final SearcherManager manager

decomposer

private final QueryDecomposer decomposer

serializer

private final MonitorQuerySerializer serializer

presearcher

private final Presearcher presearcher

purgeCache

private volatile Map<String,QueryCacheEntry> purgeCache

purgeLock

private final ReadWriteLock purgeLock

commitLock

private final Object commitLock

queries

private volatile ConcurrentMap<String,QueryCacheEntry> queries

termFilters

final Map<IndexReader.CacheKey,QueryIndex.QueryTermFilter> termFilters

EMPTY

private static final BytesRef EMPTY

Constructor Details

QueryIndex

QueryIndex(MonitorConfiguration config,
 Presearcher presearcher)
    throws IOException

Throws:

IOException

Method Details

populateQueryCache

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

Throws:

IOException

commit

void commit(List<MonitorQuery> updates)
     throws IOException

Throws:

IOException

buildIndexables

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

getQuery

MonitorQuery getQuery(String queryId)
               throws IOException

Throws:

IOException

scan

void scan(QueryIndex.QueryCollector matcher)
   throws IOException

Throws:

IOException

search

long search(Query query,
 QueryIndex.QueryCollector matcher)
     throws IOException

Throws:

IOException

search

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

Throws:

IOException

purgeCache

void purgeCache()
         throws IOException

Throws:

IOException

purgeCache

private void purgeCache(QueryIndex.CachePopulator populator)
                 throws IOException

Remove unused queries from the query cache.

This is normally called from a background thread at a rate set by configurePurgeFrequency().

Throws:

IOException - on IO errors

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

numDocs

int numDocs()

cacheSize

int cacheSize()

deleteQueries

void deleteQueries(Iterable<String> ids)
            throws IOException

Throws:

IOException

clear

void clear()
    throws IOException

Throws:

IOException