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

BySearchAfter

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

Constructors

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

Types

class Field(val name: String, val order: SortOrder)

Properties

val concurrency: Int = 1

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

val fields: List<PaginatedSearch.BySearchAfter.Field>

val index: String

val pageSize: Int = 100

Functions

paginatedSearchFlow

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