org.xbib.elasticsearch.plugin.jdbc.client

Class BaseIngestTransportClient

java.lang.Object

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

org.xbib.elasticsearch.plugin.jdbc.client.BaseIngestTransportClient

All Implemented Interfaces:

Ingest

Direct Known Subclasses:

BulkTransportClient

public abstract class BaseIngestTransportClient
extends BaseTransportClient
implements Ingest

Field Summary

Fields inherited from class org.xbib.elasticsearch.plugin.jdbc.client.BaseTransportClient

client, configHelper

Constructor Summary

Constructors

Constructor and Description
BaseIngestTransportClient()

Method Summary

Methods

Modifier and Type	Method and Description
BaseIngestTransportClient	deleteIndex(String index) Delete index
BaseIngestTransportClient	deleteMapping(String index, String type)
Ingest	newClient(org.elasticsearch.common.settings.Settings settings)
BaseIngestTransportClient	newIndex(String index) Create a new index
BaseIngestTransportClient	newIndex(String index, org.elasticsearch.common.settings.Settings settings, Map<String,String> mappings)
BaseIngestTransportClient	newIndex(String index, String type, InputStream settings, InputStream mappings)
BaseIngestTransportClient	putMapping(String index)
BaseIngestTransportClient	replica(int replica) The number of replica for index creation
BaseIngestTransportClient	shards(int shards) The number of shards for index creation
BaseIngestTransportClient	waitForCluster(org.elasticsearch.action.admin.cluster.health.ClusterHealthStatus status, org.elasticsearch.common.unit.TimeValue timeValue) Wait for cluster being healthy.

Methods inherited from class org.xbib.elasticsearch.plugin.jdbc.client.BaseTransportClient

addSetting, addSetting, addSetting, client, connect, createClient, findSettings, getConnectedNodes, getMappings, getSettings, getSettingsBuilder, isShutdown, mapping, mapping, resetSettings, setSettings, setting, shutdown

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest

addSetting, addSetting, addSetting, bulkDelete, bulkIndex, client, delete, flush, flushIngest, flushIngestInterval, getConnectedNodes, getMappings, getMetric, getSettings, getSettingsBuilder, getThrowable, hasThrowable, index, isShutdown, mapping, mapping, maxActionsPerBulkRequest, maxConcurrentBulkRequests, maxRequestWait, maxVolumePerBulkRequest, newClient, newClient, refresh, resume, setSettings, setting, shutdown, startBulk, stopBulk, suspend, updateReplicaLevel, waitForRecovery, waitForResponses

Constructor Detail

BaseIngestTransportClient

public BaseIngestTransportClient()

Method Detail

newClient

public Ingest newClient(org.elasticsearch.common.settings.Settings settings)

Specified by:

newClient in interface Ingest

shards

public BaseIngestTransportClient shards(int shards)

Description copied from interface: Ingest

The number of shards for index creation

Specified by:

shards in interface Ingest

Parameters:

shards - the number of shards

Returns:

this

replica

public BaseIngestTransportClient replica(int replica)

Description copied from interface: Ingest

The number of replica for index creation

Specified by:

replica in interface Ingest

Parameters:

replica - the number of replica

Returns:

this

newIndex

public BaseIngestTransportClient newIndex(String index)

Description copied from interface: Ingest

Create a new index

Specified by:

newIndex in interface Ingest

Returns:

this ingest

newIndex

public BaseIngestTransportClient newIndex(String index,
                                 String type,
                                 InputStream settings,
                                 InputStream mappings)
                                   throws IOException

Specified by:

newIndex in interface Ingest

Throws:

IOException

newIndex

public BaseIngestTransportClient newIndex(String index,
                                 org.elasticsearch.common.settings.Settings settings,
                                 Map<String,String> mappings)

Specified by:

newIndex in interface Ingest

deleteIndex

public BaseIngestTransportClient deleteIndex(String index)

Description copied from interface: Ingest

Delete index

Specified by:

deleteIndex in interface Ingest

Returns:

this ingest

putMapping

public BaseIngestTransportClient putMapping(String index)

Specified by:

putMapping in interface Ingest

deleteMapping

public BaseIngestTransportClient deleteMapping(String index,
                                      String type)

Specified by:

deleteMapping in interface Ingest

waitForCluster

public BaseIngestTransportClient waitForCluster(org.elasticsearch.action.admin.cluster.health.ClusterHealthStatus status,
                                       org.elasticsearch.common.unit.TimeValue timeValue)
                                         throws IOException

Description copied from interface: Ingest

Wait for cluster being healthy.

Specified by:

waitForCluster in interface Ingest

Throws:

IOException