TIKA_4235 -- add pipeline parameter
diff --git a/tika-pipes/tika-emitters/tika-emitter-opensearch/src/main/java/org/apache/tika/pipes/emitter/opensearch/OpenSearchClient.java b/tika-pipes/tika-emitters/tika-emitter-opensearch/src/main/java/org/apache/tika/pipes/emitter/opensearch/OpenSearchClient.java
index 8be4165..a1cdfca 100644
--- a/tika-pipes/tika-emitters/tika-emitter-opensearch/src/main/java/org/apache/tika/pipes/emitter/opensearch/OpenSearchClient.java
+++ b/tika-pipes/tika-emitters/tika-emitter-opensearch/src/main/java/org/apache/tika/pipes/emitter/opensearch/OpenSearchClient.java
@@ -83,7 +83,7 @@
TikaClientException {
String requestUrl = openSearchUrl + "/_bulk";
if (pipeline.isPresent()) {
- requestUrl += "?pipeline=" + URLEncoder.encode(pipeline.get());
+ requestUrl += "?pipeline=" + URLEncoder.encode(pipeline.get(), StandardCharsets.UTF_8);
}
JsonResponse response = postJson(requestUrl, json.toString());
if (response.getStatus() != 200) {
@@ -98,7 +98,6 @@
}
}
-
public void emitDocument(String emitKey, List<Metadata> metadataList,
Optional<String> pipeline) throws IOException,
TikaClientException {
diff --git a/tika-pipes/tika-emitters/tika-emitter-opensearch/src/main/java/org/apache/tika/pipes/emitter/opensearch/OpenSearchEmitter.java b/tika-pipes/tika-emitters/tika-emitter-opensearch/src/main/java/org/apache/tika/pipes/emitter/opensearch/OpenSearchEmitter.java
index b547882..d945bf0 100644
--- a/tika-pipes/tika-emitters/tika-emitter-opensearch/src/main/java/org/apache/tika/pipes/emitter/opensearch/OpenSearchEmitter.java
+++ b/tika-pipes/tika-emitters/tika-emitter-opensearch/src/main/java/org/apache/tika/pipes/emitter/opensearch/OpenSearchEmitter.java
@@ -188,6 +188,11 @@
httpClientFactory.setProxyPort(proxyPort);
}
+ @Field
+ public void setPipeline(String pipeline) {
+ this.pipeline = pipeline;
+ }
+
public void setUpdateStrategy(UpdateStrategy updateStrategy) {
this.updateStrategy = updateStrategy;
}
