connector-elasticsearch/com.river.connector.elasticsearch/PaginatedSearch/Default

Default

class Default(val index: String, val pageSize: Int = 100, val concurrency: Int = 1, val f: (Query.Builder) -> ObjectBuilder<Query> = { it.matchAll { it } }) : PaginatedSearch

Constructors

Default

constructor(index: String, pageSize: Int = 100, concurrency: Int = 1, f: (Query.Builder) -> ObjectBuilder<Query> = { it.matchAll { it } })

Properties

concurrency

val concurrency: Int = 1

val f: (Query.Builder) -> ObjectBuilder<Query>

index

val index: String

pageSize

val pageSize: Int = 100

Functions

paginatedSearchFlow

open override fun <T> paginatedSearchFlow(client: ElasticsearchAsyncClient, clazz: Class<T>): Flow<Hit<T>>