Package io.vertigo.datafactory.plugins.search.elasticsearch_5_6

Class AbstractESSearchServicesPlugin

java.lang.Object
io.vertigo.datafactory.plugins.search.elasticsearch_5_6.AbstractESSearchServicesPlugin
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
Direct Known Subclasses:
ESEmbeddedSearchServicesPlugin, ESNodeSearchServicesPlugin, ESTransportSearchServicesPlugin
public abstract class AbstractESSearchServicesPlugin extends Object implements io.vertigo.datafactory.impl.search.SearchServicesPlugin, io.vertigo.core.node.component.Activeable
Gestion de la connexion au serveur ElasticSearch 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
    Modifier
    Constructor
    Description
    protected
    AbstractESSearchServicesPlugin(String indexNameOrPrefix, boolean indexNameIsPrefix, int defaultMaxRows, String configFile, 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()
     
    protected abstract void
    closeClient()
    Close created client.
    final long
    count(io.vertigo.datafactory.search.definitions.SearchIndexDefinition indexDefinition)
    protected abstract org.elasticsearch.client.Client
    createClient()
     
    Serializable
    getMetaData(io.vertigo.datafactory.search.definitions.SearchIndexDefinition indexDefinition, String dataPath)
    final <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 indexDefinitions, io.vertigo.datamodel.data.definitions.DataFieldName<K> versionFieldName, io.vertigo.datafactory.collections.ListFilter listFilter, int maxElements)
    final <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)
    final <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)
    final void
    remove(io.vertigo.datafactory.search.definitions.SearchIndexDefinition indexDefinition, io.vertigo.datafactory.collections.ListFilter listFilter)
    final <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)
    final void
    start()
    final 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

    • AbstractESSearchServicesPlugin

      protected AbstractESSearchServicesPlugin(String indexNameOrPrefix, boolean indexNameIsPrefix, int defaultMaxRows, String configFile, io.vertigo.commons.codec.CodecManager codecManager, io.vertigo.datamodel.smarttype.SmartTypeManager smartTypeManager, io.vertigo.core.resource.ResourceManager resourceManager)
      Constructor.
      Parameters:
      indexNameOrPrefix - ES index name
      indexNameIsPrefix - indexName use as prefix
      defaultMaxRows - Nombre de lignes
      configFile - Fichier de configuration des indexs
      codecManager - Manager de codec
      resourceManager - Manager des resources

  • Method Details

    • start

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

    • createClient

      protected abstract org.elasticsearch.client.Client createClient()
      Returns:
      ElasticSearch client.

    • closeClient

      protected abstract void closeClient()
      Close created client.

    • stop

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

    • putAll

      public final <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 final <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 final <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 final <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 final long count(io.vertigo.datafactory.search.definitions.SearchIndexDefinition indexDefinition)
      Specified by:
      count in interface io.vertigo.datafactory.impl.search.SearchServicesPlugin

    • remove

      public final 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

    • 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 indexDefinitions, 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

    • 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()