Package org.apache.tika.pipes.emitter.opensearch

Class OpenSearchClient

java.lang.Object

org.apache.tika.pipes.emitter.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, OpenSearchEmitter.AttachmentStrategy attachmentStrategy, OpenSearchEmitter.UpdateStrategy updateStrategy, String embeddedFileFieldName)

Method Summary

Modifier and Type	Method	Description
void	emitDocument(String emitKey, List<Metadata> metadataList)
void	emitDocuments(List<? extends EmitData> emitData)
protected static String	metadataToJsonContainerInsert(Metadata metadata, OpenSearchEmitter.AttachmentStrategy attachmentStrategy)
protected static String	metadataToJsonEmbeddedInsert(Metadata metadata, OpenSearchEmitter.AttachmentStrategy attachmentStrategy, String emitKey, String embeddedFileFieldName)
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

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,
 OpenSearchEmitter.AttachmentStrategy attachmentStrategy,
 OpenSearchEmitter.UpdateStrategy updateStrategy,
 String embeddedFileFieldName)

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

metadataToJsonContainerInsert

protected static String metadataToJsonContainerInsert(Metadata metadata,
 OpenSearchEmitter.AttachmentStrategy attachmentStrategy)
                                               throws IOException

Throws:

IOException

metadataToJsonEmbeddedInsert

protected static String metadataToJsonEmbeddedInsert(Metadata metadata,
 OpenSearchEmitter.AttachmentStrategy attachmentStrategy,
 String emitKey,
 String embeddedFileFieldName)
                                              throws IOException

Throws:

IOException

postJson

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

Throws:

IOException