elasticmagic/dev.evo.elasticmagic.compile/UpdateByQueryCompiler

UpdateByQueryCompiler

class UpdateByQueryCompiler(val features: ElasticsearchFeatures) : BaseUpdateByQueryCompiler

Constructors

UpdateByQueryCompiler

fun UpdateByQueryCompiler(features: ElasticsearchFeatures)

Functions

fun compile(serde: Serde, updateByQuery: WithIndex<SearchQuery.Update>): ApiRequest<UpdateByQueryResult>

fun compileAsync(serde: Serde, updateByQuery: WithIndex<SearchQuery.Update>): ApiRequest<AsyncResult<UpdateByQueryPartialResult, UpdateByQueryResult?>>

open override fun dispatch(ctx: Serializer.ArrayCtx, value: Any?)

open override fun dispatch(ctx: Serializer.ObjectCtx, name: String, value: Any?)

processBulkError

fun processBulkError(ctx: Deserializer.ObjectCtx): BulkError

processBulkScrollFailure

fun processBulkScrollFailure(ctx: Deserializer.ObjectCtx): BulkScrollFailure

processPartialResult

fun processPartialResult(ctx: Deserializer.ObjectCtx): UpdateByQueryPartialResult

fun processResult(ctx: Deserializer.ObjectCtx): UpdateByQueryResult

fun visit(ctx: Serializer.ArrayCtx, values: Array<*>)

fun visit(ctx: Serializer.ArrayCtx, values: List<*>)

fun visit(ctx: Serializer.ObjectCtx, params: Map<*, *>)

fun visit(ctx: Serializer.ArrayCtx, expression: Expression<Serializer.ArrayCtx>)

open fun visit(ctx: Serializer.ObjectCtx, searchQuery: PreparedSearchQuery)

fun visit(ctx: Serializer.ObjectCtx, expression: Expression<Serializer.ObjectCtx>)

fun visit(ctx: Serializer.ObjectCtx, updateByQuery: WithIndex<SearchQuery.Update>)

Properties

val features: ElasticsearchFeatures