org.molgenis.data.elasticsearch

Class ElasticsearchService

java.lang.Object

org.molgenis.data.elasticsearch.ElasticsearchService

All Implemented Interfaces:

IndexService, SearchService

@Component
public class ElasticsearchService
extends Object
implements SearchService, IndexService

Elasticsearch search service that executes all requests using the elasticsearch client facade.

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_BATCH_SIZE

Constructor Summary

Constructors

Constructor and Description
ElasticsearchService(ClientFacade clientFacade, ContentGenerators contentGenerators, DataService dataService)

Method Summary

Modifier and Type	Method and Description
AggregateResult	aggregate(EntityType entityType, AggregateQuery aggregateQuery)
long	count(EntityType entityType)
long	count(EntityType entityType, Query<Entity> q)
void	createIndex(EntityType entityType)
void	delete(EntityType entityType, Entity entity)
void	delete(EntityType entityType, Stream<? extends Entity> entities)
void	deleteAll(EntityType entityType, Stream<Object> entityIds)
void	deleteById(EntityType entityType, Object entityId)
void	deleteIndex(EntityType entityType)
org.apache.lucene.search.Explanation	explain(EntityType entityType, Object entityId, Query<Entity> q)
boolean	hasIndex(EntityType entityType)
void	index(EntityType entityType, Entity entity)
long	index(EntityType entityType, Stream<? extends Entity> entities)
void	rebuildIndex(Repository<? extends Entity> repository)
void	refreshIndex()
Stream<Object>	search(EntityType entityType, Query<Entity> q)
Object	searchOne(EntityType entityType, Query<Entity> q)

Methods inherited from class java.lang.Object

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

Field Detail

MAX_BATCH_SIZE

public static final int MAX_BATCH_SIZE

See Also:

Constant Field Values

Constructor Detail

ElasticsearchService

public ElasticsearchService(ClientFacade clientFacade,
                            ContentGenerators contentGenerators,
                            DataService dataService)

Method Detail

createIndex

public void createIndex(EntityType entityType)

Specified by:

createIndex in interface IndexService

hasIndex

public boolean hasIndex(EntityType entityType)

Specified by:

hasIndex in interface IndexService

deleteIndex

public void deleteIndex(EntityType entityType)

Specified by:

deleteIndex in interface IndexService

rebuildIndex

public void rebuildIndex(Repository<? extends Entity> repository)

Specified by:

rebuildIndex in interface IndexService

refreshIndex

public void refreshIndex()

Specified by:

refreshIndex in interface IndexService

count

public long count(EntityType entityType)

Specified by:

count in interface SearchService

count

public long count(EntityType entityType,
                  Query<Entity> q)

Specified by:

count in interface SearchService

search

public Stream<Object> search(EntityType entityType,
                             Query<Entity> q)

Specified by:

search in interface SearchService

searchOne

public Object searchOne(EntityType entityType,
                        Query<Entity> q)

Specified by:

searchOne in interface SearchService

aggregate

public AggregateResult aggregate(EntityType entityType,
                                 AggregateQuery aggregateQuery)

Specified by:

aggregate in interface SearchService

explain

public org.apache.lucene.search.Explanation explain(EntityType entityType,
                                                    Object entityId,
                                                    Query<Entity> q)

index

public void index(EntityType entityType,
                  Entity entity)

Specified by:

index in interface IndexService

index

public long index(EntityType entityType,
                  Stream<? extends Entity> entities)

Specified by:

index in interface IndexService

delete

public void delete(EntityType entityType,
                   Entity entity)

Specified by:

delete in interface IndexService

deleteById

public void deleteById(EntityType entityType,
                       Object entityId)

Specified by:

deleteById in interface IndexService

deleteAll

public void deleteAll(EntityType entityType,
                      Stream<Object> entityIds)

Specified by:

deleteAll in interface IndexService

delete

public void delete(EntityType entityType,
                   Stream<? extends Entity> entities)

Specified by:

delete in interface IndexService