Package org.apache.tika.pipes.reporters.opensearch

Class OpenSearchClient

java.lang.Object

org.apache.tika.pipes.reporters.opensearch.OpenSearchClient

public class OpenSearchClient
extends Object

Field Summary

Fields

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

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	OpenSearchClient(String openSearchUrl, org.apache.http.client.HttpClient httpClient)

Method Summary

Modifier and Type	Method	Description
void	emitDocument(String emitKey, String routing, Metadata metadata)
JsonResponse	postJson(String url, String json)
void	writeBulkRequest(String id, String routing, StringWriter writer)
void	writeDoc(Metadata metadata, StringWriter writer)

Methods inherited from class java.lang.Object

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

Field Details

openSearchUrl

protected final String openSearchUrl

httpClient

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

Constructor Details

OpenSearchClient

protected OpenSearchClient(String openSearchUrl,
 org.apache.http.client.HttpClient httpClient)

Method Details

emitDocument

public void emitDocument(String emitKey,
 String routing,
 Metadata metadata)
                  throws IOException,
TikaClientException

Throws:

IOException

TikaClientException

postJson

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

Throws:

IOException

writeDoc

public void writeDoc(Metadata metadata,
 StringWriter writer)
              throws IOException

Throws:

IOException

writeBulkRequest

public void writeBulkRequest(String id,
 String routing,
 StringWriter writer)
                      throws IOException

Throws:

IOException