elasticmagic/dev.evo.elasticmagic.aggs/ScriptedMetricAgg

ScriptedMetricAgg

data class ScriptedMetricAgg<T>(val resultProcessor: (Deserializer.ObjectCtx) -> T, val initScript: Script? = null, val mapScript: Script, val combineScript: Script? = null, val reduceScript: Script? = null, val params: Params = Params()) : MetricAggregation<ScriptedMetricAggResult<T>>

Constructors

ScriptedMetricAgg

constructor(resultProcessor: (Deserializer.ObjectCtx) -> T, initScript: Script? = null, mapScript: Script, combineScript: Script? = null, reduceScript: Script? = null, params: Params = Params())

Types

object Companion

Properties

val combineScript: Script? = null

val initScript: Script? = null

val mapScript: Script

open override val name: String

val params: Params

val reduceScript: Script? = null

resultProcessor

val resultProcessor: (Deserializer.ObjectCtx) -> T

Functions

open override fun accept(ctx: Serializer.ObjectCtx, compiler: BaseSearchQueryCompiler)

open fun children(): Iterator<Expression<*>>?

open override fun clone(): ScriptedMetricAgg<T>

open fun processResult(obj: Deserializer.ObjectCtx): ScriptedMetricAggResult<T>

open override fun processResult(obj: Deserializer.ObjectCtx, docSourceFactory: (Deserializer.ObjectCtx) -> BaseDocSource): ScriptedMetricAggResult<T>

Processes corresponding aggregation response.

open fun reduce(): Expression<Serializer.ObjectCtx>?

open fun rewrite(newNode: QueryExpressionNode<*>): Expression<Serializer.ObjectCtx>

open override fun visit(ctx: Serializer.ObjectCtx, compiler: BaseSearchQueryCompiler)