connector-elasticsearch/com.river.connector.elasticsearch

Package-level declarations

Types

Document

@ExperimentalRiverApi

data class Document<T>(val id: String, val index: String, val document: T)

PaginatedSearch

@ExperimentalRiverApi

@ExperimentalCoroutinesApi

interface PaginatedSearch

Functions

indexFlow

@ExperimentalRiverApi

fun <T> ElasticsearchAsyncClient.indexFlow(upstream: Flow<Document<T>>, concurrency: Int = 1, groupStrategy: GroupStrategy = GroupStrategy.TimeWindow(100, 250.milliseconds)): Flow<BulkResponseItem>

This function is used to index documents asynchronously into Elasticsearch using bulk requests. It takes a flow of Document objects as input, along with optional parameters for concurrency and chunking.

maxResultWindow

@ExperimentalRiverApi

suspend fun ElasticsearchAsyncClient.maxResultWindow(index: String, default: Int = 10000): Int

paginatedSearchFlow

@ExperimentalRiverApi

inline fun <T> ElasticsearchAsyncClient.paginatedSearchFlow(configuration: PaginatedSearch): Flow<Hit<T>>

toDocument

@ExperimentalRiverApi

fun <T> Flow<T>.toDocument(f: (T) -> Pair<String, String>): Flow<Document<T>>