Package io.vertigo.datafactory.plugins.search.elasticsearch_7_17.client

Class ClientESSearchServicesPlugin

java.lang.Object
io.vertigo.datafactory.plugins.search.elasticsearch_7_17.client.ClientESSearchServicesPlugin
All Implemented Interfaces:
io.vertigo.core.node.component.Activeable, io.vertigo.core.node.component.CoreComponent, io.vertigo.core.node.component.Plugin, io.vertigo.datafactory.impl.search.SearchServicesPlugin
public final class ClientESSearchServicesPlugin extends Object implements io.vertigo.datafactory.impl.search.SearchServicesPlugin, io.vertigo.core.node.component.Activeable
Gestion de la connexion au serveur Solr de manière transactionnel.
Author:
dchallas, npiedeloup

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final String
    SUFFIX_SORT_FIELD
    field suffix for keyword fields added by this plugin.

  • Constructor Summary

    Constructors
    Constructor
    Description
    ClientESSearchServicesPlugin(String envIndexPrefix, int defaultMaxRows, String configFile, Optional<String> connectorNameOpt, Optional<Boolean> optimizeNumSegmentOpt, List<io.vertigo.connectors.elasticsearch_7_17.ElasticSearchConnector> elasticSearchConnectors, io.vertigo.commons.codec.CodecManager codecManager, io.vertigo.datamodel.smarttype.SmartTypeManager smartTypeManager, io.vertigo.core.resource.ResourceManager resourceManager)
    Constructor.

  • Method Summary

    Modifier and Type
    Method
    Description
    io.vertigo.core.analytics.health.HealthMeasure
    checkClusterHealth()
     
    long
    count(io.vertigo.datafactory.search.definitions.SearchIndexDefinition indexDefinition)
    Serializable
    getMetaData(io.vertigo.datafactory.search.definitions.SearchIndexDefinition indexDefinition, String dataPath)
    <R extends io.vertigo.datamodel.data.model.DataObject>
    io.vertigo.datafactory.collections.model.FacetedQueryResult<R,io.vertigo.datafactory.search.model.SearchQuery>
    loadList(List<io.vertigo.datafactory.search.definitions.SearchIndexDefinition> indexDefinitions, io.vertigo.datafactory.search.model.SearchQuery searchQuery, io.vertigo.datamodel.data.model.DtListState listState)
    <K extends io.vertigo.datamodel.data.model.KeyConcept>
    Map<io.vertigo.datamodel.data.model.UID<K>,Serializable>
    loadVersions(io.vertigo.datafactory.search.definitions.SearchIndexDefinition indexDefinition, io.vertigo.datamodel.data.definitions.DataFieldName<K> versionFieldName, io.vertigo.datafactory.collections.ListFilter listFilter, int maxElements)
    <S extends io.vertigo.datamodel.data.model.KeyConcept, I extends io.vertigo.datamodel.data.model.DataObject>
    void
    put(io.vertigo.datafactory.search.definitions.SearchIndexDefinition indexDefinition, io.vertigo.datafactory.search.model.SearchIndex<S,I> index)
    <S extends io.vertigo.datamodel.data.model.KeyConcept, I extends io.vertigo.datamodel.data.model.DataObject>
    void
    putAll(io.vertigo.datafactory.search.definitions.SearchIndexDefinition indexDefinition, Collection<io.vertigo.datafactory.search.model.SearchIndex<S,I>> indexCollection)
    void
    putMetaData(io.vertigo.datafactory.search.definitions.SearchIndexDefinition indexDefinition, String dataPath, Serializable dataValue)
    void
    remove(io.vertigo.datafactory.search.definitions.SearchIndexDefinition indexDefinition, io.vertigo.datafactory.collections.ListFilter listFilter)
    <S extends io.vertigo.datamodel.data.model.KeyConcept>
    void
    remove(io.vertigo.datafactory.search.definitions.SearchIndexDefinition indexDefinition, io.vertigo.datamodel.data.model.UID<S> uri)
    void
    start()
    void
    stop()
    void
    waitForRefresh(List<io.vertigo.datafactory.search.definitions.SearchIndexDefinition> indexDefinitions)

    Methods inherited from class java.lang.Object

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

  • 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

    • ClientESSearchServicesPlugin

      @Inject public ClientESSearchServicesPlugin(String envIndexPrefix, int defaultMaxRows, String configFile, Optional<String> connectorNameOpt, Optional<Boolean> optimizeNumSegmentOpt, List<io.vertigo.connectors.elasticsearch_7_17.ElasticSearchConnector> 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

  • 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

    • putAll

      public <S extends io.vertigo.datamodel.data.model.KeyConcept, I extends io.vertigo.datamodel.data.model.DataObject> void putAll(io.vertigo.datafactory.search.definitions.SearchIndexDefinition indexDefinition, Collection<io.vertigo.datafactory.search.model.SearchIndex<S,I>> indexCollection)
      Specified by:
      putAll in interface io.vertigo.datafactory.impl.search.SearchServicesPlugin

    • put

      public <S extends io.vertigo.datamodel.data.model.KeyConcept, I extends io.vertigo.datamodel.data.model.DataObject> void put(io.vertigo.datafactory.search.definitions.SearchIndexDefinition indexDefinition, io.vertigo.datafactory.search.model.SearchIndex<S,I> index)
      Specified by:
      put in interface io.vertigo.datafactory.impl.search.SearchServicesPlugin

    • remove

      public <S extends io.vertigo.datamodel.data.model.KeyConcept> void remove(io.vertigo.datafactory.search.definitions.SearchIndexDefinition indexDefinition, io.vertigo.datamodel.data.model.UID<S> uri)
      Specified by:
      remove in interface io.vertigo.datafactory.impl.search.SearchServicesPlugin

    • loadList

      public <R extends io.vertigo.datamodel.data.model.DataObject> io.vertigo.datafactory.collections.model.FacetedQueryResult<R,io.vertigo.datafactory.search.model.SearchQuery> loadList(List<io.vertigo.datafactory.search.definitions.SearchIndexDefinition> indexDefinitions, io.vertigo.datafactory.search.model.SearchQuery searchQuery, io.vertigo.datamodel.data.model.DtListState listState)
      Specified by:
      loadList in interface io.vertigo.datafactory.impl.search.SearchServicesPlugin

    • count

      public long count(io.vertigo.datafactory.search.definitions.SearchIndexDefinition indexDefinition)
      Specified by:
      count in interface io.vertigo.datafactory.impl.search.SearchServicesPlugin

    • loadVersions

      public <K extends io.vertigo.datamodel.data.model.KeyConcept> Map<io.vertigo.datamodel.data.model.UID<K>,Serializable> loadVersions(io.vertigo.datafactory.search.definitions.SearchIndexDefinition indexDefinition, io.vertigo.datamodel.data.definitions.DataFieldName<K> versionFieldName, io.vertigo.datafactory.collections.ListFilter listFilter, int maxElements)
      Specified by:
      loadVersions in interface io.vertigo.datafactory.impl.search.SearchServicesPlugin

    • remove

      public void remove(io.vertigo.datafactory.search.definitions.SearchIndexDefinition indexDefinition, io.vertigo.datafactory.collections.ListFilter listFilter)
      Specified by:
      remove in interface io.vertigo.datafactory.impl.search.SearchServicesPlugin

    • putMetaData

      public void putMetaData(io.vertigo.datafactory.search.definitions.SearchIndexDefinition indexDefinition, String dataPath, Serializable dataValue)
      Specified by:
      putMetaData in interface io.vertigo.datafactory.impl.search.SearchServicesPlugin

    • getMetaData

      public Serializable getMetaData(io.vertigo.datafactory.search.definitions.SearchIndexDefinition indexDefinition, String dataPath)
      Specified by:
      getMetaData in interface io.vertigo.datafactory.impl.search.SearchServicesPlugin

    • waitForRefresh

      public void waitForRefresh(List<io.vertigo.datafactory.search.definitions.SearchIndexDefinition> indexDefinitions)
      Specified by:
      waitForRefresh in interface io.vertigo.datafactory.impl.search.SearchServicesPlugin

    • checkClusterHealth

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