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

BySearchAfter

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

Types

Field

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

Properties

concurrency

val concurrency: Int = 1

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

fields

val fields: List<PaginatedSearch.BySearchAfter.Field>

index

val index: String

pageSize

val pageSize: Int = 100

Functions

paginatedSearchFlow

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