com.akuiteo.search.service

Interface ElasticService

public interface ElasticService

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	ElasticService.IDENTIFIER

Field Summary

Fields

Modifier and Type	Field and Description
static String	INDEX_AKDOC
static String	INDEX_AKSUPPORT
static String	SERVICE_ID

Method Summary

Methods

Modifier and Type	Method and Description
ElasticState	checkConnection() Vérifie la connexion à un moteur ES
Long	countDocuments(String index)
long	countQueryType(String type) Compte le nombre de document dans l'index ayant le type type
void	createIndex(String indexName, boolean isIndexUsedForFiles) Créé un index sur un noeud ElasticSearch
void	deleteFromIndex(String id, String index, String type) Supprime un élément de l'index
void	deleteIndex(String indexName)
String	getElasticHQUrl() Retourne l'url du plugin HQ sur le serveur elasticSearch
void	index(List<Object> objects, String[] aliases, String type) Index un ensemble d'objet
void	index(List<Object> objects, String[] aliases, String index, String type) Index un ensemble d'objet
Long	indexAkuiteoDocuments() Indexe les documents Akuiteo
long	indexFiles(String nomIndex, ElasticService.IDENTIFIER identifier, List<File> files) Indexe massivement une liste de fichiers
boolean	isConnected() Test la connexion au service
void	reindexSourceExterieure(List<CtxESSourceExt> datasources)
ESResult	search(String text) Effectue une recherche
ESResult	search(String text, String indice) Effectue une recherche
ESResult	searchAkuiteoObjectsAndDocuments(String text, Set<String> facets, int maxNumberOfResults) Effectue une recherche par facettes
ESResult	searchByFacet(String text, String facet, int maxNumberOfResults) Effectue une recherche par facette
ESResult	searchByFacets(String text, Set<String> facets, int numberOfRetrievedResults)
ESResult	searchByFacets(String text, Set<String> facets, String indice, int maxNumberOfResults) Effectue une recherche par facettes
void	searchingSeekAndDestroy() Détruit tous les index et reconstruit la base elastic search
void	wipeAndReindex() Détruite les index sur le serveur ES et fait une demande de rebuild des index

Field Detail

SERVICE_ID

static final String SERVICE_ID

See Also:

Constant Field Values

INDEX_AKSUPPORT

static final String INDEX_AKSUPPORT

See Also:

Constant Field Values

INDEX_AKDOC

static final String INDEX_AKDOC

See Also:

Constant Field Values

Method Detail

checkConnection

ElasticState checkConnection()

Vérifie la connexion à un moteur ES

Returns:

index

void index(List<Object> objects,
         String[] aliases,
         String type)

Index un ensemble d'objet

Parameters:

objects -

index

void index(List<Object> objects,
         String[] aliases,
         String index,
         String type)

Index un ensemble d'objet

Parameters:

objects -

deleteFromIndex

void deleteFromIndex(String id,
                   String index,
                   String type)

Supprime un élément de l'index

Parameters:

id -

index -

type -

search

ESResult search(String text)

Effectue une recherche

Parameters:

text -

Returns:

search

ESResult search(String text,
              String indice)

Effectue une recherche

Parameters:

text -

Returns:

searchByFacet

ESResult searchByFacet(String text,
                     String facet,
                     int maxNumberOfResults)

Effectue une recherche par facette

searchByFacets

ESResult searchByFacets(String text,
                      Set<String> facets,
                      String indice,
                      int maxNumberOfResults)

Effectue une recherche par facettes

searchAkuiteoObjectsAndDocuments

ESResult searchAkuiteoObjectsAndDocuments(String text,
                                        Set<String> facets,
                                        int maxNumberOfResults)

Effectue une recherche par facettes

getElasticHQUrl

String getElasticHQUrl()

Retourne l'url du plugin HQ sur le serveur elasticSearch

Returns:

countQueryType

long countQueryType(String type)

Compte le nombre de document dans l'index ayant le type type

Parameters:

type -

Returns:

isConnected

boolean isConnected()

Test la connexion au service

Returns:

searchingSeekAndDestroy

void searchingSeekAndDestroy()

Détruit tous les index et reconstruit la base elastic search

createIndex

void createIndex(String indexName,
               boolean isIndexUsedForFiles)

Créé un index sur un noeud ElasticSearch

Parameters:

indexName - nom de l'index

isIndexUsedForFiles - si true, l'index sert à stocker des fichiers

deleteIndex

void deleteIndex(String indexName)

Parameters:

indexName - nom de l'index à supprimer

indexFiles

long indexFiles(String nomIndex,
              ElasticService.IDENTIFIER identifier,
              List<File> files)

Indexe massivement une liste de fichiers

Parameters:

nomIndex - nom de l'index

identifier - indique le champ utilisé comme identifiant (nom du fichier ou chemin complet)

files - fichiers à stocker

Returns:

Throws:

IOException

searchByFacets

ESResult searchByFacets(String text,
                      Set<String> facets,
                      int numberOfRetrievedResults)

Parameters:

text -

facets -

numberOfRetrievedResults -

Returns:

indexAkuiteoDocuments

Long indexAkuiteoDocuments()
                           throws Exception

Indexe les documents Akuiteo

Returns:

Throws:

Exception - en cas de problèmes

countDocuments

Long countDocuments(String index)

Parameters:

index -

Returns:

le nombre de documents dans l'index index

reindexSourceExterieure

void reindexSourceExterieure(List<CtxESSourceExt> datasources)

Parameters:

datasources -

wipeAndReindex

void wipeAndReindex()

Détruite les index sur le serveur ES et fait une demande de rebuild des index

Parameters:

datasources -