Package io.vertigo.datafactory.plugins.search.elasticsearch.rest

Class RestClientESSearchServicesPlugin

java.lang.Object
io.vertigo.datafactory.plugins.search.elasticsearch.rest.RestClientESSearchServicesPlugin
All Implemented Interfaces:
io.vertigo.core.node.component.Activeable, io.vertigo.core.node.component.CoreComponent, io.vertigo.core.node.component.Plugin, SearchServicesPlugin
public final class RestClientESSearchServicesPlugin extends Object implements SearchServicesPlugin, io.vertigo.core.node.component.Activeable
Gestion de la connexion au serveur ElasticSearch.
Author:
dchallas, npiedeloup, mlaroche

  • Field Details

    • SUFFIX_SORT_FIELD

      public static final String SUFFIX_SORT_FIELD
      field suffix for keyword fields added by this plugin.
      See Also:

  • Constructor Details

    • RestClientESSearchServicesPlugin

      @Inject public RestClientESSearchServicesPlugin(String envIndexPrefix, int defaultMaxRows, String configFile, Optional<String> connectorNameOpt, List<io.vertigo.connectors.elasticsearch.RestElasticSearchConnector> elasticSearchConnectors, io.vertigo.commons.codec.CodecManager codecManager, io.vertigo.datamodel.smarttype.SmartTypeManager smartTypeManager, io.vertigo.core.resource.ResourceManager resourceManager)
      Constructor.
      Parameters:
      envIndexPrefix - ES index name
      defaultMaxRows - Nombre de lignes
      configFile - Fichier de configuration des indexs
      codecManager - Manager de codec
      resourceManager - Manager des resources
      indexNameIsPrefix - indexName use as prefix

  • Method Details

    • start

      public void start()
      Specified by:
      start in interface io.vertigo.core.node.component.Activeable

    • stop

      public void stop()
      Specified by:
      stop in interface io.vertigo.core.node.component.Activeable

    • showStringDifference

      public static String showStringDifference(String current, String expected)

    • putAll

      public <S extends io.vertigo.datamodel.data.model.KeyConcept, I extends io.vertigo.datamodel.data.model.DataObject> void putAll(SearchIndexDefinition indexDefinition, Collection<SearchIndex<S,I>> indexCollection)
      Ajout de plusieurs ressources à l'index. Si les éléments étaient déjà dans l'index ils sont remplacés.
      Specified by:
      putAll in interface SearchServicesPlugin
      Type Parameters:
      S - Type du keyConcept métier indexé
      I - Type de l'objet représentant l'index
      Parameters:
      indexDefinition - Type de l'index
      indexCollection - Liste des objets à pousser dans l'index

    • put

      public <S extends io.vertigo.datamodel.data.model.KeyConcept, I extends io.vertigo.datamodel.data.model.DataObject> void put(SearchIndexDefinition indexDefinition, SearchIndex<S,I> index)
      Ajout d'une ressource à l'index. Si l'élément était déjà dans l'index il est remplacé.
      Specified by:
      put in interface SearchServicesPlugin
      Type Parameters:
      S - Type du keyConcept métier indexé
      I - Type de l'objet représentant l'index
      Parameters:
      indexDefinition - Type de l'index
      index - Objet à pousser dans l'index

    • remove

      public <S extends io.vertigo.datamodel.data.model.KeyConcept> void remove(SearchIndexDefinition indexDefinition, io.vertigo.datamodel.data.model.UID<S> uri)
      Suppression d'une ressource de l'index.
      Specified by:
      remove in interface SearchServicesPlugin
      Type Parameters:
      S - Type du keyConcept métier indexé
      Parameters:
      indexDefinition - Type de l'index
      uri - UID de la ressource à supprimer

    • loadList

      public <R extends io.vertigo.datamodel.data.model.DataObject> FacetedQueryResult<R,SearchQuery> loadList(List<SearchIndexDefinition> indexDefinitions, SearchQuery searchQuery, io.vertigo.datamodel.data.model.DtListState listState)
      Récupération du résultat issu d'une requête.
      Specified by:
      loadList in interface SearchServicesPlugin
      Type Parameters:
      R - Type de l'objet resultant de la recherche
      Parameters:
      searchQuery - critères initiaux
      listState - Etat de la liste (tri et pagination)
      Returns:
      Résultat correspondant à la requête

    • count

      public long count(SearchIndexDefinition indexDefinition)
      Specified by:
      count in interface SearchServicesPlugin
      Parameters:
      indexDefinition - Type de l'index
      Returns:
      Nombre de document indexés

    • loadVersions

      public <K extends io.vertigo.datamodel.data.model.KeyConcept> Map<io.vertigo.datamodel.data.model.UID<K>,Serializable> loadVersions(SearchIndexDefinition indexDefinition, io.vertigo.datamodel.data.definitions.DataFieldName<K> versionFieldName, ListFilter listFilter, int maxElements)
      Specified by:
      loadVersions in interface SearchServicesPlugin
      Type Parameters:
      K - Type du keyConcept métier indexé
      Parameters:
      indexDefinition - Type de l'index
      versionFieldName - Field qui porte la version du keyconcept
      listFilter - Filtre des document
      maxElements - Nb Max elements to return
      Returns:
      Map des versions par UID

    • remove

      public void remove(SearchIndexDefinition indexDefinition, ListFilter listFilter)
      Suppression des données correspondant à un filtre.
      Specified by:
      remove in interface SearchServicesPlugin
      Parameters:
      indexDefinition - Type de l'index
      listFilter - Filtre des éléments à supprimer

    • getMetaData

      public Serializable getMetaData(SearchIndexDefinition indexDefinition, String dataPath)
      Lecture de meta data à l'index.
      Specified by:
      getMetaData in interface SearchServicesPlugin
      Parameters:
      indexDefinition - Type de l'index
      dataPath - Clé de la métadonnée
      Returns:
      Valeur de la métadonnée, null si pas de donnée

    • putMetaData

      public void putMetaData(SearchIndexDefinition indexDefinition, String dataPath, Serializable dataValue)
      Ajout de meta data à l'index. Si l'élément était déjà dans l'index il est remplacé.
      Specified by:
      putMetaData in interface SearchServicesPlugin
      Parameters:
      indexDefinition - Type de l'index
      dataPath - Clé de la métadonnée
      dataValue - Valeur de la métadonnée

    • waitForRefresh

      public void waitForRefresh(List<SearchIndexDefinition> indexDefinitions)
      Attente de la prise en compte des données dans l'index.
      Specified by:
      waitForRefresh in interface SearchServicesPlugin
      Parameters:
      indexDefinitions - Type de l'index

    • checkClusterHealth

      public io.vertigo.core.analytics.health.HealthMeasure checkClusterHealth()