Class WriteDocumentsToElasticsearchIndexChain
java.lang.Object
com.github.hakenadu.javalangchains.chains.data.writer.WriteDocumentsToElasticsearchIndexChain
public class WriteDocumentsToElasticsearchIndexChain extends Object implements Chain<Stream<Map<String,String>>,Void>
Inserts documents into an elasticsearch index
-
Field Summary
-
Constructor Summary
Constructors Constructor Description WriteDocumentsToElasticsearchIndexChain(String index)creates aWriteDocumentsToElasticsearchIndexChainwith the defaultHttpHost(http://localhost:9200) and a defaultObjectMapperWriteDocumentsToElasticsearchIndexChain(String index, org.elasticsearch.client.RestClientBuilder restClientBuilder)creates aWriteDocumentsToElasticsearchIndexChainwith the defaultObjectMapperWriteDocumentsToElasticsearchIndexChain(String index, org.elasticsearch.client.RestClientBuilder restClientBuilder, com.fasterxml.jackson.databind.ObjectMapper objectMapper) -
Method Summary
-
Constructor Details
-
WriteDocumentsToElasticsearchIndexChain
public WriteDocumentsToElasticsearchIndexChain(String index, org.elasticsearch.client.RestClientBuilder restClientBuilder, com.fasterxml.jackson.databind.ObjectMapper objectMapper)- Parameters:
index-indexrestClientBuilder-restClientBuilderobjectMapper-objectMapper
-
WriteDocumentsToElasticsearchIndexChain
public WriteDocumentsToElasticsearchIndexChain(String index, org.elasticsearch.client.RestClientBuilder restClientBuilder)creates aWriteDocumentsToElasticsearchIndexChainwith the defaultObjectMapper- Parameters:
index-indexrestClientBuilder-restClientBuilder
-
WriteDocumentsToElasticsearchIndexChain
creates aWriteDocumentsToElasticsearchIndexChainwith the defaultHttpHost(http://localhost:9200) and a defaultObjectMapper- Parameters:
index-index
-
-
Method Details