org.xbib.elasticsearch.plugin.jdbc.client

Class ClientHelper

java.lang.Object

org.xbib.elasticsearch.plugin.jdbc.client.ClientHelper

public class ClientHelper
extends Object

Constructor Summary

Constructors

Constructor and Description
ClientHelper()

Method Summary

Methods

Modifier and Type	Method and Description
static String	clusterName(org.elasticsearch.client.Client client)
static void	disableRefresh(org.elasticsearch.client.Client client, String index)
static void	enableRefresh(org.elasticsearch.client.Client client, String index)
static void	flush(org.elasticsearch.client.Client client, String index)
static List<String>	getConnectedNodes(org.elasticsearch.client.transport.TransportClient client)
static String	healthColor(org.elasticsearch.client.Client client)
static void	refresh(org.elasticsearch.client.Client client, String index)
static void	updateIndexSetting(org.elasticsearch.client.Client client, String index, String key, Object value)
static int	updateReplicaLevel(org.elasticsearch.client.Client client, String index, int level)
static void	waitForCluster(org.elasticsearch.client.Client client, org.elasticsearch.action.admin.cluster.health.ClusterHealthStatus status, org.elasticsearch.common.unit.TimeValue timeout)
static int	waitForRecovery(org.elasticsearch.client.Client client, String index)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientHelper

public ClientHelper()

Method Detail

getConnectedNodes

public static List<String> getConnectedNodes(org.elasticsearch.client.transport.TransportClient client)

updateIndexSetting

public static void updateIndexSetting(org.elasticsearch.client.Client client,
                      String index,
                      String key,
                      Object value)
                               throws IOException

Throws:

IOException

waitForRecovery

public static int waitForRecovery(org.elasticsearch.client.Client client,
                  String index)
                           throws IOException

Throws:

IOException

waitForCluster

public static void waitForCluster(org.elasticsearch.client.Client client,
                  org.elasticsearch.action.admin.cluster.health.ClusterHealthStatus status,
                  org.elasticsearch.common.unit.TimeValue timeout)
                           throws IOException

Throws:

IOException

clusterName

public static String clusterName(org.elasticsearch.client.Client client)

healthColor

public static String healthColor(org.elasticsearch.client.Client client)

updateReplicaLevel

public static int updateReplicaLevel(org.elasticsearch.client.Client client,
                     String index,
                     int level)
                              throws IOException

Throws:

IOException

disableRefresh

public static void disableRefresh(org.elasticsearch.client.Client client,
                  String index)
                           throws IOException

Throws:

IOException

enableRefresh

public static void enableRefresh(org.elasticsearch.client.Client client,
                 String index)
                          throws IOException

Throws:

IOException

flush

public static void flush(org.elasticsearch.client.Client client,
         String index)

refresh

public static void refresh(org.elasticsearch.client.Client client,
           String index)