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 and Description
protected org.apache.http.client.HttpClient	httpClient
protected String	openSearchUrl

Constructor Summary

Constructors

Modifier	Constructor and 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 and 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 Detail

openSearchUrl

protected final String openSearchUrl

httpClient

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

Constructor Detail

OpenSearchClient

protected OpenSearchClient(String openSearchUrl,
                           org.apache.http.client.HttpClient httpClient,
                           OpenSearchEmitter.AttachmentStrategy attachmentStrategy,
                           OpenSearchEmitter.UpdateStrategy updateStrategy,
                           String embeddedFileFieldName)

Method Detail

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