public class PercolatorQueriesRegistry extends AbstractIndexShardComponent implements Closeable
PercolatorService.TYPE_NAME
document type in the index.
For shards with indices that have no PercolatorService.TYPE_NAME
document type, this will hold no percolate queries.
Once a document type has been created, the real-time percolator will start to listen to write events and update the
this registry with queries in real time.Modifier and Type | Field and Description |
---|---|
String |
MAP_UNMAPPED_FIELDS_AS_STRING |
componentSettings, indexSettings, logger, shardId
Constructor and Description |
---|
PercolatorQueriesRegistry(ShardId shardId,
Settings indexSettings,
IndexQueryParserService queryParserService,
ShardIndexingService indexingService,
IndicesLifecycle indicesLifecycle,
MapperService mapperService,
IndexCache indexCache,
IndexFieldDataService indexFieldDataService,
ShardPercolateService shardPercolateService) |
Modifier and Type | Method and Description |
---|---|
void |
addPercolateQuery(String idAsString,
BytesReference source) |
void |
clear() |
void |
close() |
ConcurrentMap<org.apache.lucene.util.BytesRef,org.apache.lucene.search.Query> |
percolateQueries() |
void |
removePercolateQuery(String idAsString) |
indexSettings, nodeName, shardId
public final String MAP_UNMAPPED_FIELDS_AS_STRING
@Inject public PercolatorQueriesRegistry(ShardId shardId, @IndexSettings Settings indexSettings, IndexQueryParserService queryParserService, ShardIndexingService indexingService, IndicesLifecycle indicesLifecycle, MapperService mapperService, IndexCache indexCache, IndexFieldDataService indexFieldDataService, ShardPercolateService shardPercolateService)
public ConcurrentMap<org.apache.lucene.util.BytesRef,org.apache.lucene.search.Query> percolateQueries()
public void close()
close
in interface Closeable
close
in interface AutoCloseable
public void clear()
public void addPercolateQuery(String idAsString, BytesReference source)
public void removePercolateQuery(String idAsString)
Copyright © 2009–2015. All rights reserved.