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

Class ESNodeSearchServicesPlugin

java.lang.Object

io.vertigo.datafactory.plugins.search.elasticsearch_5_6.AbstractESSearchServicesPlugin

io.vertigo.datafactory.plugins.search.elasticsearch_5_6.commonshttp.ESNodeSearchServicesPlugin

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 ESNodeSearchServicesPlugin
extends AbstractESSearchServicesPlugin

Gestion de la connexion au serveur elasticSearch en mode HTTP.

Author:

npiedeloup

Field Summary

Fields inherited from class io.vertigo.datafactory.plugins.search.elasticsearch_5_6.AbstractESSearchServicesPlugin

SUFFIX_SORT_FIELD

Constructor Summary

Constructors

Constructor	Description
ESNodeSearchServicesPlugin(String serversNamesStr, String envIndex, Optional<Boolean> envIndexIsPrefix, int rowsPerQuery, String clusterName, String configFile, Optional<String> nodeNameOpt, 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
protected void	closeClient()	Close created client.
protected org.elasticsearch.client.Client	createClient()

Methods inherited from class io.vertigo.datafactory.plugins.search.elasticsearch_5_6.AbstractESSearchServicesPlugin

checkClusterHealth, count, getMetaData, loadList, loadVersions, put, putAll, putMetaData, remove, remove, start, stop, waitForRefresh

Methods inherited from class java.lang.Object

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

Constructor Details

ESNodeSearchServicesPlugin

@Inject
public ESNodeSearchServicesPlugin(String serversNamesStr,
 String envIndex,
 Optional<Boolean> envIndexIsPrefix,
 int rowsPerQuery,
 String clusterName,
 String configFile,
 Optional<String> nodeNameOpt,
 io.vertigo.commons.codec.CodecManager codecManager,
 io.vertigo.datamodel.smarttype.SmartTypeManager smartTypeManager,
 io.vertigo.core.resource.ResourceManager resourceManager)

Constructor.

Parameters:

serversNamesStr - URL du serveur ElasticSearch avec le port de communication de cluster (9300 en général)

envIndex - Nom de l'index de l'environment

envIndexIsPrefix - Si Nom de l'index de l'environment est un prefix

rowsPerQuery - Liste des indexes

clusterName - : nom du cluster à rejoindre

configFile - fichier de configuration des index

nodeNameOpt - : nom du node

codecManager - Manager des codecs

resourceManager - Manager d'accès aux ressources

Method Details

createClient

protected org.elasticsearch.client.Client createClient()

Specified by:

createClient in class AbstractESSearchServicesPlugin

Returns:

ElasticSearch client.

closeClient

protected void closeClient()

Close created client.

Specified by:

closeClient in class AbstractESSearchServicesPlugin