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

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)
WriteDocumentsToElasticsearchIndexChain(String index, org.elasticsearch.client.RestClientBuilder restClientBuilder, com.fasterxml.jackson.databind.ObjectMapper objectMapper, Function<Map<String,String>,String> idProvider)
WriteDocumentsToElasticsearchIndexChain(String index, org.elasticsearch.client.RestClientBuilder restClientBuilder, com.fasterxml.jackson.databind.ObjectMapper objectMapper, Function<Map<String,String>,String> idProvider, BiConsumer<String,org.elasticsearch.client.RestClient> indexCreator)

Method Summary

Modifier and Type	Method	Description
static BiConsumer<String,org.elasticsearch.client.RestClient>	defaultIndexCreator(com.fasterxml.jackson.databind.ObjectMapper objectMapper)	Realizes the default way of creating an elasticsearch index using the method from https://github.com/hwchase17/langchain/blob/master/langchain/retrievers/elastic_search_bm25.py
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, Function<Map<String,String>,String> idProvider, BiConsumer<String,org.elasticsearch.client.RestClient> indexCreator)

Parameters:

index - index

restClientBuilder - restClientBuilder

objectMapper - objectMapper

idProvider - idProvider

indexCreator - indexCreator

WriteDocumentsToElasticsearchIndexChain

public WriteDocumentsToElasticsearchIndexChain(String index, org.elasticsearch.client.RestClientBuilder restClientBuilder, com.fasterxml.jackson.databind.ObjectMapper objectMapper, Function<Map<String,String>,String> idProvider)

Parameters:

index - index

restClientBuilder - restClientBuilder

objectMapper - objectMapper

idProvider - idProvider

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

defaultIndexCreator

public static BiConsumer<String,org.elasticsearch.client.RestClient> defaultIndexCreator(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Realizes the default way of creating an elasticsearch index using the method from https://github.com/hwchase17/langchain/blob/master/langchain/retrievers/elastic_search_bm25.py

Parameters:

objectMapper - ObjectMapper for json operations

Returns:

default indexCreator