Package dev.evo.elasticmagic.aggs

Types

AggRange

data class AggRange<T>(from: T?, to: T?, key: String?)

Aggregation

interface Aggregation<R : AggregationResult> : NamedExpression

Base aggregation expression.

AggregationResult

interface AggregationResult

Aggregation result interface marker.

AggValue

sealed class AggValue<T> : ObjExpression

Represents value source for an aggregation:

Field takes values from a field.
Script gets values as a script result.
ValueScript combines a field with a script. There is special variable _value that contains field value.

AvgAgg

data class AvgAgg<T>(value: AggValue<T>, missing: T?, format: String?) : SingleDoubleValueAgg<T>

BaseBucket

abstract class BaseBucket : AggAwareResult

BaseHistogramAgg

abstract class BaseHistogramAgg<T, R : AggregationResult, B> : BucketAggregation<R>

BaseRangeAgg

abstract class BaseRangeAgg<T, R : AggregationResult, B> : BucketAggregation<R>

BaseTermsAgg

abstract class BaseTermsAgg<T, R : AggregationResult> : BucketAggregation<R>

BucketAggregation

abstract class BucketAggregation<R : AggregationResult> : Aggregation<R>

BucketAggResult

abstract class BucketAggResult<B : BaseBucket> : AggregationResult

BucketsOrder

data class BucketsOrder(key: String, order: Sort.Order) : ObjExpression

CalendarInterval

enum CalendarInterval : Enum<CalendarInterval> , ToValue<String>

CardinalityAgg

data class CardinalityAgg<T>(value: AggValue<T>, missing: T?) : SingleLongValueAgg<T>

DateHistogramAgg

data class DateHistogramAgg<T>(value: AggValue<T>, interval: DateHistogramAgg.Interval, offset: FixedInterval?, minDocCount: Long?, missing: T?, format: String?, order: List<BucketsOrder>, extendedBounds: HistogramBounds<T>?, hardBounds: HistogramBounds<T>?, params: Params, aggs: Map<String, Aggregation<*>>) : BaseHistogramAgg<T, DateHistogramAggResult<T>, DateHistogramBucket<T>>

DateHistogramAggResult

data class DateHistogramAggResult<T>(buckets: List<DateHistogramBucket<T>>) : BucketAggResult<DateHistogramBucket<T>>

DateHistogramBucket

data class DateHistogramBucket<T>(key: Long, keyAsString: String?, keyAsDatetime: T, docCount: Long, aggs: Map<String, AggregationResult>) : KeyedBucket<Long>

DateRangeAgg

data class DateRangeAgg<T>(value: AggValue<T>, ranges: List<AggRange<T>>, format: String?, missing: T?, params: Params, aggs: Map<String, Aggregation<*>>) : BaseRangeAgg<T, DateRangeAggResult<T>, DateRangeBucket<T>>

DateRangeAggResult

data class DateRangeAggResult<T>(buckets: List<DateRangeBucket<T>>) : BucketAggResult<DateRangeBucket<T>>

DateRangeBucket

data class DateRangeBucket<T>(key: String, docCount: Long, from: Double?, fromAsString: String?, fromAsDatetime: T?, to: Double?, toAsString: String?, toAsDatetime: T?, aggs: Map<String, AggregationResult>) : KeyedBucket<String>

ExtendedStatsAgg

data class ExtendedStatsAgg<T>(value: AggValue<T>, missing: T?, format: String?) : NumericValueAgg<T, ExtendedStatsAggResult>

ExtendedStatsAggResult

data class ExtendedStatsAggResult(count: Long, min: Double?, max: Double?, avg: Double?, sum: Double, sumOfSquares: Double?, variance: Double?, stdDeviation: Double?, stdDeviationBounds: ExtendedStatsAggResult.StdDeviationBounds) : AggregationResult

FilterAgg

data class FilterAgg(filter: QueryExpression, aggs: Map<String, Aggregation<*>>) : SingleBucketAggregation

FiltersAgg

data class FiltersAgg(filters: Map<String, QueryExpression>, otherBucketKey: String?, aggs: Map<String, Aggregation<*>>) : BucketAggregation<FiltersAggResult>

FiltersAggResult

data class FiltersAggResult(buckets: Map<String, FiltersBucket>) : AggregationResult

FiltersBucket

data class FiltersBucket(key: String, docCount: Long, aggs: Map<String, AggregationResult>) : KeyedBucket<String>

FixedInterval

sealed class FixedInterval : ToValue<String>

GlobalAgg

data class GlobalAgg(aggs: Map<String, Aggregation<*>>) : SingleBucketAggregation

HistogramAgg

data class HistogramAgg<T : Number>(value: AggValue<T>, interval: T, offset: T?, minDocCount: Long?, missing: T?, format: String?, order: List<BucketsOrder>, extendedBounds: HistogramBounds<T>?, hardBounds: HistogramBounds<T>?, params: Params, aggs: Map<String, Aggregation<*>>) : BaseHistogramAgg<T, HistogramAggResult, HistogramBucket>

HistogramAggResult

data class HistogramAggResult(buckets: List<HistogramBucket>) : BucketAggResult<HistogramBucket>

HistogramBounds

data class HistogramBounds<T>(min: T?, max: T?)

HistogramBucket

data class HistogramBucket(key: Double, docCount: Long, aggs: Map<String, AggregationResult>, keyAsString: String?) : KeyedBucket<Double>

KeyedBucket

abstract class KeyedBucket<K> : BaseBucket

MaxAgg

data class MaxAgg<T>(value: AggValue<T>, missing: T?, format: String?) : SingleDoubleValueAgg<T>

MedianAbsoluteDeviationAgg

data class MedianAbsoluteDeviationAgg<T>(value: AggValue<T>, missing: T?) : SingleDoubleValueAgg<T>

MetricAggregation

abstract class MetricAggregation<R : AggregationResult> : Aggregation<R>

MinAgg

data class MinAgg<T>(value: AggValue<T>, missing: T?, format: String?) : SingleDoubleValueAgg<T>

NestedAgg

data class NestedAgg(path: FieldOperations<Nothing>, aggs: Map<String, Aggregation<*>>) : SingleBucketAggregation

NumericValueAgg

abstract class NumericValueAgg<T, R : AggregationResult> : MetricAggregation<R>

RangeAgg

data class RangeAgg<T : Number>(value: AggValue<T>, ranges: List<AggRange<T>>, format: String?, missing: T?, params: Params, aggs: Map<String, Aggregation<*>>) : BaseRangeAgg<T, RangeAggResult, RangeBucket>

RangeAggResult

data class RangeAggResult(buckets: List<RangeBucket>) : BucketAggResult<RangeBucket>

RangeBucket

data class RangeBucket(key: String, docCount: Long, from: Double?, fromAsString: String?, to: Double?, toAsString: String?, aggs: Map<String, AggregationResult>) : KeyedBucket<String>

SignificantTermBucket

data class SignificantTermBucket<T>(key: T, docCount: Long, bgCount: Long, score: Float, docCountErrorUpperBound: Long?, aggs: Map<String, AggregationResult>) : KeyedBucket<T>

SignificantTermsAgg

data class SignificantTermsAgg<T>(value: AggValue<T>, size: Int?, shardSize: Int?, minDocCount: Int?, shardMinDocCount: Int?, include: BaseTermsAgg.Include?, exclude: BaseTermsAgg.Exclude?, missing: T?, order: List<BucketsOrder>, collectMode: BaseTermsAgg.CollectMode?, executionHint: BaseTermsAgg.ExecutionHint?, backgroundFilter: QueryExpression?, params: Params, aggs: Map<String, Aggregation<*>>) : BaseTermsAgg<T, SignificantTermsAggResult<T>>

SignificantTermsAggResult

data class SignificantTermsAggResult<T>(docCount: Long, bgCount: Long, buckets: List<SignificantTermBucket<T>>) : BucketAggResult<SignificantTermBucket<T>>

SingleBucketAggregation

abstract class SingleBucketAggregation : BucketAggregation<SingleBucketAggResult>

SingleBucketAggResult

data class SingleBucketAggResult(docCount: Long, aggs: Map<String, AggregationResult>) : BaseBucket, AggregationResult

SingleDoubleValueAgg

abstract class SingleDoubleValueAgg<T> : NumericValueAgg<T, SingleValueMetricAggResult<Double>>

SingleLongValueAgg

abstract class SingleLongValueAgg<T> : NumericValueAgg<T, SingleValueMetricAggResult<Long>>

SingleValueMetricAggResult

data class SingleValueMetricAggResult<T>(value: T?, valueAsString: String?) : AggregationResult

StatsAgg

data class StatsAgg<T>(value: AggValue<T>, missing: T?, format: String?) : NumericValueAgg<T, StatsAggResult>

StatsAggResult

data class StatsAggResult(count: Long, min: Double?, max: Double?, avg: Double?, sum: Double, minAsString: String?, maxAsString: String?, avgAsString: String?, sumAsString: String?) : AggregationResult

SumAgg

data class SumAgg<T : Number>(value: AggValue<T>, missing: T?, format: String?) : SingleDoubleValueAgg<T>

TermBucket

data class TermBucket<T>(key: T, docCount: Long, docCountErrorUpperBound: Long?, aggs: Map<String, AggregationResult>) : KeyedBucket<T>

TermsAgg

data class TermsAgg<T>(value: AggValue<T>, size: Int?, shardSize: Int?, minDocCount: Int?, shardMinDocCount: Int?, include: BaseTermsAgg.Include?, exclude: BaseTermsAgg.Exclude?, missing: T?, order: List<BucketsOrder>, collectMode: BaseTermsAgg.CollectMode?, executionHint: BaseTermsAgg.ExecutionHint?, showTermDocCountError: Boolean?, params: Params, aggs: Map<String, Aggregation<*>>) : BaseTermsAgg<T, TermsAggResult<T>>

TermsAggResult

data class TermsAggResult<T>(buckets: List<TermBucket<T>>, docCountErrorUpperBound: Long, sumOtherDocCount: Long) : BucketAggResult<TermBucket<T>>

ValueCountAgg

data class ValueCountAgg<T>(value: AggValue<T>, missing: T?) : SingleLongValueAgg<T>

WeightedAvgAgg

data class WeightedAvgAgg<T>(value: WeightedAvgAgg.ValueSource<T>, weight: WeightedAvgAgg.ValueSource<T>, format: String?) : MetricAggregation<SingleValueMetricAggResult<Double>>