elasticmagic/dev.evo.elasticmagic.compile/DeleteByQueryCompiler

DeleteByQueryCompiler

class DeleteByQueryCompiler(val features: ElasticsearchFeatures) : BaseUpdateByQueryCompiler

Constructors

DeleteByQueryCompiler

fun DeleteByQueryCompiler(features: ElasticsearchFeatures)

Functions

fun compile(serde: Serde, deleteByQuery: WithIndex<SearchQuery.Delete>): ApiRequest<DeleteByQueryResult>

fun compileAsync(serde: Serde, deleteByQuery: WithIndex<SearchQuery.Delete>): ApiRequest<AsyncResult<DeleteByQueryPartialResult, DeleteByQueryResult?>>

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): DeleteByQueryResult

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, deleteByQuery: WithIndex<SearchQuery.Delete>)

Properties

val features: ElasticsearchFeatures