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

PaginatedSearch

@ExperimentalRiverApi
@ExperimentalCoroutinesApi
interface PaginatedSearch

Inheritors

Types

Link copied to clipboard
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
Link copied to clipboard
class Default(val index: String, val pageSize: Int = 100, val concurrency: Int = 1, val f: (Query.Builder) -> ObjectBuilder<Query> = { it.matchAll { it } }) : PaginatedSearch

Functions

Link copied to clipboard
abstract fun <T> paginatedSearchFlow(client: ElasticsearchAsyncClient, clazz: Class<T>): Flow<Hit<T>>