Uses of Interface
org.xbib.elasticsearch.plugin.jdbc.client.Ingest

Packages that use Ingest

Package	Description
org.xbib.elasticsearch.plugin.jdbc.client
org.xbib.elasticsearch.plugin.jdbc.client.node
org.xbib.elasticsearch.plugin.jdbc.client.transport
org.xbib.elasticsearch.river.jdbc.strategy.simple

Uses of Ingest in org.xbib.elasticsearch.plugin.jdbc.client

Classes in org.xbib.elasticsearch.plugin.jdbc.client that implement Ingest

Modifier and Type	Class and Description
class	BaseIngestTransportClient

Methods in org.xbib.elasticsearch.plugin.jdbc.client that return Ingest

Modifier and Type	Method and Description
Ingest	Ingest.bulkDelete(org.elasticsearch.action.delete.DeleteRequest deleteRequest) Bulked delete request.
Ingest	Ingest.bulkIndex(org.elasticsearch.action.index.IndexRequest indexRequest) Bulked index request.
Ingest	IngestFactory.create()
Ingest	Ingest.delete(String index, String type, String id) Delete document
Ingest	Ingest.deleteIndex(String index) Delete index
Ingest	Ingest.deleteMapping(String index, String type)
Ingest	Ingest.flush(String index) Flush the index
Ingest	Ingest.flushIngest() Flush ingest, move all pending documents to the bulk indexer
Ingest	Ingest.flushIngestInterval(org.elasticsearch.common.unit.TimeValue flushInterval) Set the flush interval for automatic flushing outstanding ingest requests
Ingest	Ingest.index(String index, String type, String id, String source) Index document
Ingest	Ingest.maxActionsPerBulkRequest(int maxActions) Set the maximum number of actions per bulk request
Ingest	Ingest.maxConcurrentBulkRequests(int maxConcurentBulkRequests) Set the maximum concurent bulk requests
Ingest	Ingest.maxRequestWait(org.elasticsearch.common.unit.TimeValue timeout) Set request timeout.
Ingest	Ingest.maxVolumePerBulkRequest(org.elasticsearch.common.unit.ByteSizeValue maxVolume) Set the maximum volume for bulk request before flush
Ingest	Ingest.newClient(org.elasticsearch.client.Client client)
Ingest	Ingest.newClient(Map<String,String> settings)
Ingest	Ingest.newClient(org.elasticsearch.common.settings.Settings settings)
Ingest	BaseIngestTransportClient.newClient(org.elasticsearch.common.settings.Settings settings)
Ingest	Ingest.newIndex(String index) Create a new index
Ingest	Ingest.newIndex(String index, org.elasticsearch.common.settings.Settings settings, Map<String,String> mappings)
Ingest	Ingest.newIndex(String index, String type, InputStream settings, InputStream mappings)
Ingest	Ingest.putMapping(String index)
Ingest	Ingest.refresh(String index) Refresh the index.
Ingest	Ingest.replica(int replica) The number of replica for index creation
Ingest	Ingest.shards(int shards) The number of shards for index creation
Ingest	Ingest.startBulk(String index) Start bulk mode
Ingest	Ingest.stopBulk(String index) Stops bulk mode.
Ingest	Ingest.waitForCluster(org.elasticsearch.action.admin.cluster.health.ClusterHealthStatus status, org.elasticsearch.common.unit.TimeValue timeValue) Wait for cluster being healthy.
Ingest	Ingest.waitForResponses(org.elasticsearch.common.unit.TimeValue maxWait) Wait for all outstanding responses

Uses of Ingest in org.xbib.elasticsearch.plugin.jdbc.client.node

Classes in org.xbib.elasticsearch.plugin.jdbc.client.node that implement Ingest

Modifier and Type	Class and Description
class	BulkNodeClient Node client support with bulk processing

Uses of Ingest in org.xbib.elasticsearch.plugin.jdbc.client.transport

Classes in org.xbib.elasticsearch.plugin.jdbc.client.transport that implement Ingest

Modifier and Type	Class and Description
class	BulkTransportClient Client using the BulkProcessor of Elasticsearch

Uses of Ingest in org.xbib.elasticsearch.river.jdbc.strategy.simple

Fields in org.xbib.elasticsearch.river.jdbc.strategy.simple declared as Ingest

Modifier and Type	Field and Description
protected Ingest	SimpleRiverMouth.ingest