Package org.apache.tika.pipes.emitter.es

Class ESClient

java.lang.Object

org.apache.tika.pipes.emitter.es.ESClient

public class ESClient
extends Object

Plain HTTP client for the ES REST API.

This does not use the ES Java client library (which is SSPL / Elastic License). Instead it talks directly to the _bulk REST endpoint using Apache HttpClient (ASL v2).

Supports API key authentication (Authorization: ApiKey ...) as well as basic auth via the underlying HttpClient.

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.apache.http.client.HttpClient	httpClient

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ESClient(ESEmitterConfig config, org.apache.http.client.HttpClient httpClient)

Method Summary

Modifier and Type	Method	Description
void	emitDocument(String emitKey, List<Metadata> metadataList)
void	emitDocuments(List<? extends EmitData> emitData)
JsonResponse	postJson(String url, String json)

Methods inherited from class java.lang.Object

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

Field Details

httpClient

protected final org.apache.http.client.HttpClient httpClient

Constructor Details

ESClient

protected ESClient(ESEmitterConfig config,
 org.apache.http.client.HttpClient httpClient)

Method Details

emitDocuments

public void emitDocuments(List<? extends EmitData> emitData)
                   throws IOException,
TikaClientException

Throws:

IOException

TikaClientException

emitDocument

public void emitDocument(String emitKey,
 List<Metadata> metadataList)
                  throws IOException,
TikaClientException

Throws:

IOException

TikaClientException

postJson

public JsonResponse postJson(String url,
 String json)
                      throws IOException

Throws:

IOException