Package com.github.hakenadu.javalangchains.chains.data.writer

Class WriteDocumentsToElasticsearchIndexChain

java.lang.Object

com.github.hakenadu.javalangchains.chains.data.writer.WriteDocumentsToElasticsearchIndexChain

All Implemented Interfaces:

Chain<Stream<Map<String,String>>,Void>

public class WriteDocumentsToElasticsearchIndexChain
extends Object
implements Chain<Stream<Map<String,String>>,Void>

Inserts documents into an elasticsearch index

Field Summary

Fields inherited from interface com.github.hakenadu.javalangchains.chains.Chain

LOGGER

Constructor Summary

Constructors

Constructor	Description
WriteDocumentsToElasticsearchIndexChain(String index)	creates a WriteDocumentsToElasticsearchIndexChain with the default HttpHost (http://localhost:9200) and a default ObjectMapper
WriteDocumentsToElasticsearchIndexChain(String index, org.elasticsearch.client.RestClientBuilder restClientBuilder)	creates a WriteDocumentsToElasticsearchIndexChain with the default ObjectMapper
WriteDocumentsToElasticsearchIndexChain(String index, org.elasticsearch.client.RestClientBuilder restClientBuilder, com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Summary

Modifier and Type	Method	Description
Void	run(Stream<Map<String,String>> input)	Execute this Chain

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.github.hakenadu.javalangchains.chains.Chain

chain

Constructor Details

WriteDocumentsToElasticsearchIndexChain

public WriteDocumentsToElasticsearchIndexChain(String index, org.elasticsearch.client.RestClientBuilder restClientBuilder, com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Parameters:

index - index

restClientBuilder - restClientBuilder

objectMapper - objectMapper

WriteDocumentsToElasticsearchIndexChain

public WriteDocumentsToElasticsearchIndexChain(String index, org.elasticsearch.client.RestClientBuilder restClientBuilder)

creates a WriteDocumentsToElasticsearchIndexChain with the default ObjectMapper

Parameters:

index - index

restClientBuilder - restClientBuilder

WriteDocumentsToElasticsearchIndexChain

public WriteDocumentsToElasticsearchIndexChain(String index)

creates a WriteDocumentsToElasticsearchIndexChain with the default HttpHost (http://localhost:9200) and a default ObjectMapper

Parameters:

index - index

Method Details

run

public Void run(Stream<Map<String,String>> input)

Description copied from interface: Chain

Execute this Chain

Specified by:

run in interface Chain<Stream<Map<String,String>>,Void>

Parameters:

input - this chain's input

Returns:

this chain's output