org.molgenis.data.elasticsearch.client

Class ClientFacade

java.lang.Object

org.molgenis.data.elasticsearch.client.ClientFacade

All Implemented Interfaces:

Closeable, AutoCloseable

public class ClientFacade
extends Object
implements Closeable

Elasticsearch client facade: - Provides simplified interface to Elasticsearch transport client - Reduces Elasticsearch transport client dependencies - Translates Elasticsearch transport client exceptions to MOLGENIS indexing exceptions - Logs requests and responses

Constructor Summary

Constructors

Constructor and Description
ClientFacade(org.elasticsearch.client.Client client)

Method Summary

Modifier and Type	Method and Description
org.elasticsearch.search.aggregations.Aggregations	aggregate(List<org.elasticsearch.search.aggregations.AggregationBuilder> aggregations, org.elasticsearch.index.query.QueryBuilder query, Index index)
void	close()
void	createIndex(Index index, IndexSettings indexSettings, Stream<Mapping> mappingStream)
void	deleteById(Index index, Document document)
void	deleteIndex(Index index)
org.apache.lucene.search.Explanation	explain(SearchHit searchHit, org.elasticsearch.index.query.QueryBuilder query)
long	getCount(Index index)
long	getCount(org.elasticsearch.index.query.QueryBuilder query, Index index)
void	index(Index index, Document document)
boolean	indexesExist(Index index)
void	processDocumentActions(Stream<DocumentAction> documentActions)
void	refreshIndexes()
SearchHits	search(org.elasticsearch.index.query.QueryBuilder query, int from, int size, List<Index> indexes)
SearchHits	search(org.elasticsearch.index.query.QueryBuilder query, int from, int size, Sort sort, Index index)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientFacade

public ClientFacade(org.elasticsearch.client.Client client)

Method Detail

createIndex

public void createIndex(Index index,
                        IndexSettings indexSettings,
                        Stream<Mapping> mappingStream)

indexesExist

public boolean indexesExist(Index index)

deleteIndex

public void deleteIndex(Index index)

refreshIndexes

public void refreshIndexes()

getCount

public long getCount(Index index)

getCount

public long getCount(org.elasticsearch.index.query.QueryBuilder query,
                     Index index)

search

public SearchHits search(org.elasticsearch.index.query.QueryBuilder query,
                         int from,
                         int size,
                         List<Index> indexes)

search

public SearchHits search(org.elasticsearch.index.query.QueryBuilder query,
                         int from,
                         int size,
                         Sort sort,
                         Index index)

aggregate

public org.elasticsearch.search.aggregations.Aggregations aggregate(List<org.elasticsearch.search.aggregations.AggregationBuilder> aggregations,
                                                                    org.elasticsearch.index.query.QueryBuilder query,
                                                                    Index index)

explain

public org.apache.lucene.search.Explanation explain(SearchHit searchHit,
                                                    org.elasticsearch.index.query.QueryBuilder query)

index

public void index(Index index,
                  Document document)

deleteById

public void deleteById(Index index,
                       Document document)

processDocumentActions

public void processDocumentActions(Stream<DocumentAction> documentActions)

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException