org.xbib.elasticsearch.plugin.jdbc.client

Class BaseTransportClient

java.lang.Object

org.xbib.elasticsearch.plugin.jdbc.client.BaseTransportClient

Direct Known Subclasses:

BaseIngestTransportClient

public abstract class BaseTransportClient
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected org.elasticsearch.client.transport.TransportClient	client
protected ConfigHelper	configHelper

Constructor Summary

Constructors

Constructor and Description
BaseTransportClient()

Method Summary

Methods

Modifier and Type	Method and Description
void	addSetting(String key, Boolean value)
void	addSetting(String key, Integer value)
void	addSetting(String key, String value)
org.elasticsearch.client.Client	client()
protected void	connect(org.elasticsearch.common.settings.Settings settings)
protected void	createClient(org.elasticsearch.common.settings.Settings settings)
protected org.elasticsearch.common.settings.Settings	findSettings()
List<String>	getConnectedNodes()
Map<String,String>	getMappings()
org.elasticsearch.common.settings.Settings	getSettings()
org.elasticsearch.common.settings.ImmutableSettings.Builder	getSettingsBuilder()
boolean	isShutdown()
void	mapping(String type, InputStream in)
void	mapping(String type, String mapping)
void	resetSettings()
void	setSettings(org.elasticsearch.common.settings.Settings settings)
void	setting(InputStream in)
void	shutdown()

Methods inherited from class java.lang.Object

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

Field Detail

client

protected org.elasticsearch.client.transport.TransportClient client

configHelper

protected ConfigHelper configHelper

Constructor Detail

BaseTransportClient

public BaseTransportClient()

Method Detail

createClient

protected void createClient(org.elasticsearch.common.settings.Settings settings)

client

public org.elasticsearch.client.Client client()

getConnectedNodes

public List<String> getConnectedNodes()

shutdown

public void shutdown()

isShutdown

public boolean isShutdown()

findSettings

protected org.elasticsearch.common.settings.Settings findSettings()

connect

protected void connect(org.elasticsearch.common.settings.Settings settings)
                throws IOException

Throws:

IOException

getSettingsBuilder

public org.elasticsearch.common.settings.ImmutableSettings.Builder getSettingsBuilder()

resetSettings

public void resetSettings()

setting

public void setting(InputStream in)
             throws IOException

Throws:

IOException

addSetting

public void addSetting(String key,
              String value)

addSetting

public void addSetting(String key,
              Boolean value)

addSetting

public void addSetting(String key,
              Integer value)

setSettings

public void setSettings(org.elasticsearch.common.settings.Settings settings)

getSettings

public org.elasticsearch.common.settings.Settings getSettings()

mapping

public void mapping(String type,
           String mapping)
             throws IOException

Throws:

IOException

mapping

public void mapping(String type,
           InputStream in)
             throws IOException

Throws:

IOException

getMappings

public Map<String,String> getMappings()