ci HddlZddlmZddlmZmZmZmZm Z m Z m Z m Z m Z mZmZmZmZddlmZddlmZddlmZmZmZmZddlmZmZmZerdd lmZdd l m!Z!dd l"m#Z#dd l$m%Z% dd ee e&efde&fdeee&dfdeddfdZ'Gddee eZ(Gdde eZ)Gdde)ee(eZ*Gdde(eZ+Gdde*eZ,Gdde*eZ-Gd d!e(eZ.Gd"d#e+eZ/Gd$d%e(eZ0Gd&d'e+eZ1Gd(d)e+eZ2Gd*d+e*eZ3Gd,d-e+eZ4Gd.d/e+eZ5Gd0d1e(eZ6Gd2d3e(eZ7Gd4d5e(eZ8Gd6d7e*eZ9Gd8d9e+eZ:Gd:d;e*eZ;Gd<d=e*eZ<Gd>d?e+eZ=Gd@dAe+eZ>GdBdCe*eZ?GdDdEe*eZ@GdFdGe+eZAGdHdIe*eZBGdJdKe(eZCGdLdMe+eZDGdNdOe(eZEGdPdQe*eZFGdRdSe*eZGGdTdUe(eZHGdVdWe(eZIGdXdYe*eZJGdZd[e*eZKGd\d]e(eZLGd^d_e*eZMGd`dae*eZNGdbdce*eZOGdddee*eZPGdfdge*eZQGdhdie*eZRGdjdke+eZSGdldme(eZTGdndoe(eZUGdpdqe(eZVGdrdse+eZWGdtdue(eZXGdvdwe(eZYGdxdye+eZZGdzd{e*eZ[Gd|d}e+eZ\Gd~de\eZ]Gdde\eZ^Gdde\eZ_Gdde\eZ`Gdde\eZaGdde+eZbGdde+eZcGdde*eZdGdde*eZeGdde+eZfGdde*eZgGdde(eZhGdde(eZiGdde+eZjGdde*eZkGdde*eZlGdde(eZmGdde*eZnGdde*eZoGdde*eZpGdde(eZqGdde+eZrGdde*eZsGdde*eZtGdde(eZuGdde+eZvGdde(eZwGdde(eZxGdde+eZyGdde*eZzGdde*eZ{Gdde(eZ|Gdde(eZ}Gdde(eZ~Gd„de(eZGdĄde(eZGdƄde*eZdS)N)deepcopy) TYPE_CHECKINGAnyClassVarDictGenericIterableLiteralMappingMutableMappingOptionalSequenceUnioncast)DEFAULT)Query) AggResponse BucketDataFieldBucketData TopHitsData)_RAttrDictDslBase) DefaultType)types)InstrumentedField) SearchBase name_or_aggzAgg[_R]filterrparamsreturnc ||dkrtd|z||d<t|tjjr|rtdt |}|dd}|dd}t|dkrtd|z|\}}|r| }||d<|r| }||d<tt |d dd i|St|tr|rtd |Stt |d i|S) Nr z;Aggregation %r doesn't accept positional argument 'filter'.z4A() cannot accept parameters when passing in a dict.aggsmetarzTA() can only accept dict with an aggregation ({"terms": {...}}). Instead it got (%r)_expand__to_dotFz;A() cannot accept parameters when passing in an Agg object.) ValueError isinstance collectionsabcr rpoplenpopitemcopyAggr get_dsl_class)rr r!aggr$r%agg_types V/var/www/html/auto_sub_bot/venv/lib/python3.11/site-packages/elasticsearch/dsl/aggs.pyAr52s  ( " "M "x+{=>>  USTT T{##wwvt$$wwvt$$ s88q==&(34 ;;==&  "[[]]F!F6N  "[[]]F!F6N2w$$X..OOuOOOO K % %  M  r7  - - 7 7 7 77ceZdZdZeeZdZdede fdZ de ee fffd Z ddd e ee fdee fd ZxZS) r0r2keyr"cdSNFr'selfr9s r4 __contains__zAgg.__contains__isur6c$t}t||jtrNt t ttf||j}d|vr| d|d<|S)Nr%) superto_dictr)namedictrrstrrr,r=dn __class__s r4rAz Agg.to_dictlsl GGOO   a lD ) ) *T#s(^Qty\22A{{EE&MM& r6searchSearchBase[_R]datac:tt|||SN)rrr=rIrKs r4resultz Agg.resultts2tVT222r6)__name__ __module__ __qualname__ _type_name staticmethodr5_type_shortcutrBrDboolr>rrrArrO __classcell__rHs@r4r0r0dsJ!\!__N Dc3h3-3T#s(^3QT 33333333r6r0c beZdZUeeeefed<eeed<eeefed<ddddiZ e eeefed<ded e fd Z d ed eefd Z d edeed d fdZd eefdZde dedeeeefeeefdeded eef dZdedeeeefeeefdeded eef dZdedeeeefeeefdeded df dZdedeeeefeeefdeded df dZddded eefdZd S)AggBaser$_base_paramsr2Ttypehash _param_defsr9r"c<||jdivSNr$)r\getr<s r4r>zAggBase.__contains__sdl&&vr2222r6agg_namecttt|jdi|}t |t r't|jfi|j}||jd|<|Srb) rr0rr\ setdefaultr)Bucketr5rBr=rdr2s r4 __getitem__zAggBase.__getitem__st GT\,,VR88B   c6 " " 1CH,, ,,C-0DL  * r6Nc4t||j|<dSrM)r5r$rhs r4 __setitem__zAggBase.__setitem__sff (r6c*t|jSrM)iterr$)r=s r4__iter__zAggBase.__iter__sDIr6bucketrBr3argsr!cBt|g|Ri|x}||<|r|S|jSrM)r5r[)r=rorBr3rpr!r2s r4_aggz AggBase._aggsCX7777777d4j  J: r6c(|jd||g|Ri|Sr;)rrr=rBr3rpr!s r4metriczAggBase.metrics*tyh@@@@@@@r6 Bucket[_R]cDtd|jd||g|Ri|S)NrvTrrrrts r4rozAggBase.buckets4L)$)D$"R4"R"R"R6"R"RSSSr6 Pipeline[_R]cDtd|jd||g|Ri|S)NryFrxrts r4pipelinezAggBase.pipelines4NIDIeT8$Ud$U$U$Uf$U$UVVVr6rIrJrKc$t|||SrM)rrNs r4rOzAggBase.results$---r6)rPrQrRrrDr0r__annotations__rr`rrVr>rirkr rnrrrruror{rrOr'r6r4rZrZxs sCG|  r7NNN #s(^---K$sCx.)333333 C CG    %C%c"g%$%%%%(3-S#XB45      R"AAS#XB45A A  A R AAAATTS#XB45T T  T  TTTTWWS#XB45W W  W  WWWW.-.S.Xc]......r6rZcDeZdZdeffd Zdeeefffd ZxZS)rgr!c Htjdi|||_dSNr')r@__init__r[)r=r!rHs r4rzBucket.__init__s+""6""" r6r"c$tt|}t||jt rGt tt||j}d|vr| d|d<|Srb) r@rZrAr)rBrCrrrr,rEs r4rAzBucket.to_dictsp '4 ( ( * * a lD ) ) *Xc]AdiL11A{{EE&MM& r6) rPrQrRrrrrDrArWrXs@r4rgrgsq c3hr6rgceZdZdS)PipelineN)rPrQrRr'r6r4rrsDr6rczeZdZdZdZddddiZeeddeee e fdfd ee dfd e ffd Z xZ S) AdjacencyMatrixa A bucket aggregation returning a form of adjacency matrix. The request provides a collection of named filter expressions, similar to the `filters` aggregation. Each bucket in the response represents a non- empty cell in the matrix of intersecting filters. :arg filters: Filters used to create buckets. At least one filter is required. :arg separator: Separator used to concatenate filter names. Defaults to &. adjacency_matrixfiltersqueryTr]r separatorrrkwargsc @tjd||d|dS)Nrr'r@r)r=rrrrHs r4rzAdjacencyMatrix.__init__s/ HIHHHHHHHr6)rPrQrR__doc__rBr`rrr rDrrrrWrXs@r4rrs   DGT22K>E/6 IIIwsEz*M9:Im+, I  IIIIIIIIIIr6rc6eZdZdZdZeeeeeeeeed deedfdeeddfdeedfd ee d dfd e d eedfd ee ee fdfdede ee fdfdeedfde ffdZ ddde dee fdZxZS)AutoDateHistograma A multi-bucket aggregation similar to the date histogram, except instead of providing an interval to use as the width of each bucket, a target number of buckets is provided. :arg buckets: The target number of buckets. Defaults to `10` if omitted. :arg field: The field on which to run the aggregation. :arg format: The date format used to format `key_as_string` in the response. If no `format` is specified, the first date format specified in the field mapping is used. :arg minimum_interval: The minimum rounding interval. This can make the collection process more efficient, as the aggregation will not attempt to round at any interval lower than `minimum_interval`. :arg missing: The value to apply to documents that do not have a value. By default, documents without a value are ignored. :arg offset: Time zone specified as a ISO 8601 UTC offset. :arg params: :arg script: :arg time_zone: Time zone ID. auto_date_histogram bucketsfieldformatminimum_intervalmissingoffsetr!script time_zonerrrrrr)secondminutehourdaymonthyearrrr!r types.Scriptrrc Ntjd||||||||| d | dS)Nrr'r) r=rrrrrrr!rrrrHs r4rzAutoDateHistogram.__init__sY  -  r6rIrJrKr"c$t|||SrMrrNs r4rOzAutoDateHistogram.result,tVT222r6)rPrQrRrrBrrintrDr rr rrrrOrWrXs@r4rrsx, !D .5@G,3 ,3:AGN/6   sM)* S-}<=  c=()   F G V   c=() gc3h'67 nd38nmCD m+,       :3-3S3Xc]33333333r6rc eZdZdZdZeeeeddeedfdeeddfdeeee e dfd ed e ee fdfd e f fd Z xZS) Avgas A single-value metrics aggregation that computes the average of numeric values that are extracted from the aggregated documents. :arg format: :arg field: The field on which to run the aggregation. :arg missing: The value to apply to documents that do not have a value. By default, documents without a value are ignored. :arg script: avgrrrrrrrrrrrrc Dtjd||||d|dSNrr'rr=rrrrrrHs r4rz Avg.__init__>E    JP     r6rPrQrRrrBrrrDrfloatrVrrrrWrXs@r4rr0   D -4@G?FGN    c=()  S-}<=  sCm;<  nd38nmCD             r6rc eZdZdZdZeeeddeedfdeeddfdeee ee eefdfd e ffd Z xZ S) AvgBucketug A sibling pipeline aggregation which calculates the mean value of a specified metric in a sibling aggregation. The specified metric must be numeric and the sibling aggregation must be a multi-bucket aggregation. :arg format: `DecimalFormat` pattern for the output value. If specified, the formatted value is returned in the aggregation’s `value_as_string` property. :arg gap_policy: Policy to apply when gaps are found in the data. Defaults to `skip` if omitted. :arg buckets_path: Path to the buckets that contain one set of values to correlate. avg_bucketr gap_policy buckets_pathrrrskip insert_zeros keep_valuesrrc Btjd|||d|dSNrr'rr=rrrrrHs r4rzAvgBucket.__init__^C  j|  OU     r6rPrQrRrrBrrrDr rr rrrWrXs@r4rrLs   D -4     c=()  9 :M I   #S 1= @            r6rceZdZdZdZeeeeeddeedfdeeddfdee d dfd ee e ee dfd ed e e e fdfd e f fdZxZS)Boxplota A metrics aggregation that computes a box plot of numeric values extracted from the aggregated documents. :arg compression: Limits the maximum number of nodes used by the underlying TDigest algorithm to `20 * compression`, enabling control of memory usage and approximation error. :arg execution_hint: The default implementation of TDigest is optimized for performance, scaling to millions or even billions of sample values while maintaining acceptable accuracy levels (close to 1% relative error for millions of samples in some cases). To use an implementation optimized for accuracy, set this parameter to high_accuracy instead. Defaults to `default` if omitted. :arg field: The field on which to run the aggregation. :arg missing: The value to apply to documents that do not have a value. By default, documents without a value are ignored. :arg script: boxplot compressionexecution_hintrrrrrrdefault high_accuracyrrrrrrc Ftjd|||||d|dS)Nrr'r)r=rrrrrrrHs r4rzBoxplot.__init__sM  #)         r6rPrQrRrrBrrrr rDrrVrrrrWrXs@r4rros& D 4; @G?FGN   5-/0  . / >  S-}<= sCm;< nd38nmCD           r6rceZdZdZdZeeeeddedeee fdfdeedfdee d dfd eee ee eefdfd e f fd Z xZS) BucketScriptuW A parent pipeline aggregation which runs a script which can perform per bucket computations on metrics in the parent multi-bucket aggregation. :arg script: The script to run for this aggregation. :arg format: `DecimalFormat` pattern for the output value. If specified, the formatted value is returned in the aggregation’s `value_as_string` property. :arg gap_policy: Policy to apply when gaps are found in the data. Defaults to `skip` if omitted. :arg buckets_path: Path to the buckets that contain one set of values to correlate. bucket_scriptrrrrrrrrrrrrc Dtjd||||d|dSNrr'rr=rrrrrrHs r4rzBucketScript.__init__J  !%         r6rPrQrRrrBrrrrDrr rr rrWrXs@r4rrs   D HO,3     nd38nmCD c=()   9 :M I   #S 1= @            r6rceZdZdZdZeeeeddedeee fdfdeedfdee d dfd eee ee eefdfd e f fd Z xZS) BucketSelectoru[ A parent pipeline aggregation which runs a script to determine whether the current bucket will be retained in the parent multi-bucket aggregation. :arg script: The script to run for this aggregation. :arg format: `DecimalFormat` pattern for the output value. If specified, the formatted value is returned in the aggregation’s `value_as_string` property. :arg gap_policy: Policy to apply when gaps are found in the data. Defaults to `skip` if omitted. :arg buckets_path: Path to the buckets that contain one set of values to correlate. bucket_selectorrrrrrrrrrc Dtjd||||d|dSrrrs r4rzBucketSelector.__init__rr6rrXs@r4rrs   D HO,3     nd38nmCD c=()   9 :M I   #S 1= @            r6rceZdZdZdZeeeeddeedfdeeddfdeedfd eeee d fd fe eee d fd fe e e fdfd e f fd Z xZS) BucketSorta A parent pipeline aggregation which sorts the buckets of its parent multi-bucket aggregation. :arg from: Buckets in positions prior to `from` will be truncated. :arg gap_policy: The policy to apply when gaps are found in the data. Defaults to `skip` if omitted. :arg size: The number of buckets to return. Defaults to all buckets of the parent aggregation. :arg sort: The list of fields to sort on. bucket_sortfrom_rsizesortrrrrrrrtypes.SortOptionsrc Dtjd||||d|dS)Nrr'r)r=rrrrrrHs r4rzBucketSort.__init__sE  JT  HN     r6)rPrQrRrrBrrrr rDrrrrrWrXs@r4rrs   D ,3 *1    S-'(  9 :M I  C&'  %0013FF G U5&9!9:8?:AFM 07*13:9@   S-}<= !m!34  "#}"45  $C$67  !&hsm]&B C "' 5tCH~} T"  #},- C&' S-/0 #3 #56           r6r c eZdZdZdZeeeddeedfdeeddfdeee ee eefdfd e ffd Z xZ S) ChangePointu3 A sibling pipeline that detects, spikes, dips, and change points in a metric. Given a distribution of values provided by the sibling multi- bucket aggregation, this aggregation indicates the bucket of any spike or dip and/or the bucket at which the largest change in the distribution of values, if they are statistically significant. There must be at least 22 bucketed values. Fewer than 1,000 is preferred. :arg format: `DecimalFormat` pattern for the output value. If specified, the formatted value is returned in the aggregation’s `value_as_string` property. :arg gap_policy: Policy to apply when gaps are found in the data. Defaults to `skip` if omitted. :arg buckets_path: Path to the buckets that contain one set of values to correlate. change_pointrrrrrrrc Btjd|||d|dSrrrs r4rzChangePoint.__init__%rr6rrXs@r4rrs" D -4     c=()  9 :M I   #S 1= @            r6rcDeZdZdZdZefdeedfdeffd Z xZ S)Childrenz A single bucket aggregation that selects child documents that have the specified type, as defined in a `join` field. :arg type: The child type that should be selected. childrenr^rrc >tjdd|i|dSNr^r'rr=r^rrHs r4rzChildren.__init__@+--d-f-----r6 rPrQrRrrBrrrDrrrWrXs@r4rr6sn D9@..U3 #56.C..........r6rc eZdZdZdZeeeddeeeedfee e ee de ffdfdee dfd ee eeeefdfd e ffd ZxZS) Compositeax A multi-bucket aggregation that creates composite buckets from different sources. Unlike the other multi-bucket aggregations, you can use the `composite` aggregation to paginate *all* buckets from a multi-level aggregation efficiently. :arg after: When paginating, use the `after_key` value returned in the previous response to retrieve the next page. :arg size: The number of composite buckets that should be returned. Defaults to `10` if omitted. :arg sources: The value sources used to build composite buckets. Keys are returned in the order of the `sources` definition. compositeafterrsourcesr&rNrrr'rc Btjd|||d|dS)Nr%r'r)r=r&rr'rrHs r4rzComposite.__init__Us1 Ku4KKFKKKKKr6)rPrQrRrrBrrr rDrrrVrrr0rrrWrXs@r4r#r#Ds   D *1IP L L L c../sE3dTW7W1XX     LC&' LxSW 56 EF L L L L L L L L L L Lr6r#c eZdZdZdZeeeddeedfdeeddfdeee ee eefdfd e ffd Z xZ S) CumulativeCardinalityu A parent pipeline aggregation which calculates the cumulative cardinality in a parent `histogram` or `date_histogram` aggregation. :arg format: `DecimalFormat` pattern for the output value. If specified, the formatted value is returned in the aggregation’s `value_as_string` property. :arg gap_policy: Policy to apply when gaps are found in the data. Defaults to `skip` if omitted. :arg buckets_path: Path to the buckets that contain one set of values to correlate. cumulative_cardinalityrrrrrrrc Btjd|||d|dSrrrs r4rzCumulativeCardinality.__init__urr6rrXs@r4r*r*es   $D -4     c=()  9 :M I   #S 1= @            r6r*c eZdZdZdZeeeddeedfdeeddfdeee ee eefdfd e ffd Z xZ S) CumulativeSumu  A parent pipeline aggregation which calculates the cumulative sum of a specified metric in a parent `histogram` or `date_histogram` aggregation. :arg format: `DecimalFormat` pattern for the output value. If specified, the formatted value is returned in the aggregation’s `value_as_string` property. :arg gap_policy: Policy to apply when gaps are found in the data. Defaults to `skip` if omitted. :arg buckets_path: Path to the buckets that contain one set of values to correlate. cumulative_sumrrrrrrrc Btjd|||d|dSrrrs r4rzCumulativeSum.__init__rr6rrXs@r4r.r.s   D -4     c=()  9 :M I   #S 1= @            r6r.c!eZdZdZdZeeeeeeeeeeeeeeeddeeddfdedee e fdfd edee e fdfd ee d dfd e d ee dfde dee dfde de dee ee d fedfe e ee d fedfdfdee e e fdfdedee e fdfdee dfdeedfde f fdZddde dee fdZxZS) DateHistograma A multi-bucket values source based aggregation that can be applied on date values or date range values extracted from the documents. It dynamically builds fixed size (interval) buckets over the values. :arg calendar_interval: Calendar-aware interval. Can be specified using the unit name, such as `month`, or as a single unit quantity, such as `1M`. :arg extended_bounds: Enables extending the bounds of the histogram beyond the data itself. :arg hard_bounds: Limits the histogram to specified bounds. :arg field: The date field whose values are use to build a histogram. :arg fixed_interval: Fixed intervals: a fixed number of SI units and never deviate, regardless of where they fall on the calendar. :arg format: The date format used to format `key_as_string` in the response. If no `format` is specified, the first date format specified in the field mapping is used. :arg interval: :arg min_doc_count: Only returns buckets that have `min_doc_count` number of documents. By default, all buckets between the first bucket that matches documents and the last one are returned. :arg missing: The value to apply to documents that do not have a value. By default, documents without a value are ignored. :arg offset: Changes the start value of each bucket by the specified positive (`+`) or negative offset (`-`) duration. :arg order: The sort order of the returned buckets. :arg params: :arg script: :arg time_zone: Time zone used for bucketing and rounding. Defaults to Coordinated Universal Time (UTC). :arg keyed: Set to `true` to associate a unique string key with each bucket and return the ranges as a hash rather than an array. date_histogramcalendar_intervalextended_bounds hard_boundsrfixed_intervalrintervalrrrorderr!rrkeyedr5rrrrweekrquarterrrr6types.ExtendedBoundsr7rrr8rr9rrrr:ascdescr!rrrr;rc Ztjd||||||||| | | | | ||d|dS)Nr4r'r)r=r5r6r7rr8rr9rrrr:r!rrr;rrHs r4rzDateHistogram.__init__slB  /+#)'  !     r6rIrJrKr"c$t|||SrMrrNs r4rOzDateHistogram.resultrr6)rPrQrRrrBrrr rrDrrr rrVrrrOrWrXs@r4r2r2sM  D D   @G%,33: :AGN/6,3=2 2 2 ! U    2  "DcNM A 2  "DcNM A 2 S-}<=2 !2 "c=()#2 $%2 &S-/0'2 ()2 *+2 , E#223W]5KK L WU3(;#;TTU V   -2 6gc3h'6772 8nd38nmCD92 :m+,;2 <T=()=2 >?2 2 2 2 2 2 h3-3S3Xc]33333333r6r2ceZdZdZdZeeeeeeddeeddfdeedfdeeee e dfd ee d e e ee fdfd eedfd ee dfd e ffdZxZS) DateRangea A multi-bucket value source based aggregation that enables the user to define a set of date ranges - each representing a bucket. :arg field: The date field whose values are use to build ranges. :arg format: The date format used to format `from` and `to` in the response. :arg missing: The value to apply to documents that do not have a value. By default, documents without a value are ignored. :arg ranges: Array of date ranges. :arg time_zone: Time zone used to convert dates from another time zone to UTC. :arg keyed: Set to `true` to associate a unique string key with each bucket and returns the ranges as a hash rather than an array. date_rangerrrrangesrr;rrrrrrIztypes.DateRangeExpressionrr;rc Htjd||||||d|dS)NrHr'r) r=rrrrIrr;rrHs r4rzDateRange.__init__sP          r6)rPrQrRrrBrrrDrrrVrrrrrWrXs@r4rFrFs D AH,3?F /6,3   S-}<= c=()  sCm;<   0 1 T#s(^ $    m+, T=()           r6rFc eZdZdZdZeeeddeedfdeeddfdeee ee eefdfd e ffd Z xZ S) Derivativeu A parent pipeline aggregation which calculates the derivative of a specified metric in a parent `histogram` or `date_histogram` aggregation. :arg format: `DecimalFormat` pattern for the output value. If specified, the formatted value is returned in the aggregation’s `value_as_string` property. :arg gap_policy: Policy to apply when gaps are found in the data. Defaults to `skip` if omitted. :arg buckets_path: Path to the buckets that contain one set of values to correlate. derivativerrrrrrrc Btjd|||d|dSrrrs r4rzDerivative.__init__Crr6rrXs@r4rLrL2   D -4     c=()  9 :M I   #S 1= @            r6rLceZdZdZdZeeeeeddeeddfdeedfded e e e fdfd eedfd ee d dfd e f fdZ xZ S)DiversifiedSamplera A filtering aggregation used to limit any sub aggregations' processing to a sample of the top-scoring documents. Similar to the `sampler` aggregation, but adds the ability to limit the number of matches that share a common value. :arg execution_hint: The type of value used for de-duplication. Defaults to `global_ordinals` if omitted. :arg max_docs_per_value: Limits how many documents are permitted per choice of de-duplicating value. Defaults to `1` if omitted. :arg script: :arg shard_size: Limits how many top-scoring documents are collected in the sample processed on each shard. Defaults to `100` if omitted. :arg field: The field used to provide values used for de-duplication. diversified_samplerrmax_docs_per_valuerrrr)mapr bytes_hashrrTrrrrrrc Ftjd|||||d|dS)NrSr'r)r=rrTrrrrrHs r4rzDiversifiedSampler.__init__hsM  )1!         r6)rPrQrRrrBrrr rrrDrrrWrXs@r4rQrQTs" !D 8?GN07@G    : ;] J  "#}"45  nd38nmCD #},- S-}<=           r6rQceZdZdZdZeeeeeddeedfdeedfdeeddfd eee ee dfd ed e ee fdfd e f fd Z xZS) ExtendedStatsa A multi-value metrics aggregation that computes stats over numeric values extracted from the aggregated documents. :arg sigma: The number of standard deviations above/below the mean to display. :arg format: :arg field: The field on which to run the aggregation. :arg missing: The value to apply to documents that do not have a value. By default, documents without a value are ignored. :arg script: extended_statssigmarrrrr\rrrrrrrrc Ftjd|||||d|dS)Nr[r'r)r=r\rrrrrrHs r4rzExtendedStats.__init__sM           r6)rPrQrRrrBrrrrDrrVrrrrWrXs@r4rYrY~s   D .5,3@G?FGN   UM)* c=()  S-}<=  sCm;<  nd38nmCD           r6rYceZdZdZdZeeeeddeedfdeedfdee ddfd eee ee eefdfd e f fd Z xZS) ExtendedStatsBucketuk A sibling pipeline aggregation which calculates a variety of stats across all bucket of a specified metric in a sibling aggregation. :arg sigma: The number of standard deviations above/below the mean to display. :arg format: `DecimalFormat` pattern for the output value. If specified, the formatted value is returned in the aggregation’s `value_as_string` property. :arg gap_policy: Policy to apply when gaps are found in the data. Defaults to `skip` if omitted. :arg buckets_path: Path to the buckets that contain one set of values to correlate. extended_stats_bucketr\rrrr\rrrrrrc Dtjd||||d|dS)Nrar'r)r=r\rrrrrHs r4rzExtendedStatsBucket.__init__sJ  !%         r6)rPrQrRrrBrrrrDr rr rrrWrXs@r4r_r_s   #D .5,3     UM)* c=()   9 :M I   #S 1= @            r6r_c eZdZdZdZdddiiZeeeeeddeedee e e fd fd ee d fd ee d fd ee d fdeed fd e f fdZxZS)FrequentItemSetsa( A bucket aggregation which finds frequent item sets, a form of association rules mining that identifies items that often occur together. :arg fields: (required) Fields to analyze. :arg minimum_set_size: The minimum size of one item set. Defaults to `1` if omitted. :arg minimum_support: The minimum support of one item set. Defaults to `0.1` if omitted. :arg size: The number of top item sets to return. Defaults to `10` if omitted. :arg filter: Query that filters documents from analysis. frequent_item_setsr r^rfieldsminimum_set_sizeminimum_supportrr rgztypes.FrequentItemSetsFieldrrhrirrc Ftjd|||||d|dS)Nrfr'r)r=rgrhrirr rrHs r4rzFrequentItemSets.__init__sM  -+         r6)rPrQrRrrBr`rrrrrDrrrrrrWrXs@r4rdrds   D67#K 6=7>*1.5    2 3 T#s(^ $     ] 23 um34 C&' e]*+           r6rdcxeZdZdZdZddiddddZefdeed fd e ffd Z d e e e fffd Z xZS)Filterz A single bucket aggregation that narrows the set of documents to those that match a query. :arg filter: A single bucket aggregation that narrows the set of documents to those that match a query. r r^rr2Tr])r r$rrc >tjdd|i|dS)Nr r'r)r=r rrHs r4rzFilter.__init__s+111&11111r6r"c0t}t||jtrTt t t||j}|| di|S)Nr ) r@rAr)rBrCrrrupdater,rEs r4rAzFilter.to_dict sl GGOO   a lD ) ) *Xc]AdiL11A HHQUU8R(( ) ) )r6)rPrQrRrrBr`rrrrrrrDrArWrXs@r4rlrls D7#--K >E22uUM%9:2PS222222c3hr6rlc eZdZdZdZdddddddZeeeeddeee e fd fd ee d fd ee d fd ee d fd e f fdZ xZS)Filtersa A multi-bucket aggregation where each bucket contains the documents that match a query. :arg filters: Collection of queries from which to build buckets. :arg other_bucket: Set to `true` to add a bucket to the response which will contain all documents that do not match any of the given filters. :arg other_bucket_key: The key with which the other bucket is returned. Defaults to `_other_` if omitted. :arg keyed: By default, the named filters aggregation returns the buckets as an object. Set to `false` to return the buckets as an array of objects. Defaults to `True` if omitted. rrTr]r2)rr$r other_bucketother_bucket_keyr;rrsrtr;rc Dtjd||||d|dS)Nrrr'r)r=rrsrtr;rrHs r4rzFilters.__init__'sJ  %-         r6)rPrQrRrrBr`rrrrDrrVrrrWrXs@r4rqrqs   D#T22--K;B3:6=,3    tCJ'67 D-/0   ] 23  T=()            r6rqc eZdZdZdZeeeeddeedfdeeddfdeee e edfd ed e ee fdfd e f fd Z xZS) GeoBoundsa A metric aggregation that computes the geographic bounding box containing all values for a Geopoint or Geoshape field. :arg wrap_longitude: Specifies whether the bounding box should be allowed to overlap the international date line. Defaults to `True` if omitted. :arg field: The field on which to run the aggregation. :arg missing: The value to apply to documents that do not have a value. By default, documents without a value are ignored. :arg script: geo_boundswrap_longituderrrrzrrrrrrrc Dtjd||||d|dS)Nryr'r)r=rzrrrrrHs r4rzGeoBounds.__init__IsJ  )         r6rPrQrRrrBrrrVrDrrrrrrWrXs@r4rwrw9s   D 6=@G?FGN    dM12 S-}<=  sCm;<  nd38nmCD            r6rwceZdZdZdZeeeeeddeedfdeddee e e e e fdfd ee d dfd ee ee e dfd ed e e e fdfde f fdZxZS) GeoCentroidah A metric aggregation that computes the weighted centroid from all coordinate values for geo fields. :arg count: :arg location: :arg field: The field on which to run the aggregation. :arg missing: The value to apply to documents that do not have a value. By default, documents without a value are ignored. :arg script: geo_centroidcountlocationrrrrrrtypes.LatLonGeoLocationtypes.GeoHashLocationrrrrrrc Ftjd|||||d|dS)Nrr'r)r=rrrrrrrHs r4rzGeoCentroid.__init__jsM"           r6)rPrQrRrrBrrrrrrDrrrVrrWrXs@r4r~r~[s    D ,3 @G?FGN   S-'(  % # UO  cN     S-}<= sCm;< nd38nmCD           r6r~ceZdZdZdZeeeeeddeeddfdeeddfd ed d e e ee ee fdfd ee d e e ee fdfdeeddfde f fdZ xZS) GeoDistanceaH A multi-bucket aggregation that works on `geo_point` fields. Evaluates the distance of each document value from an origin point and determines the buckets it belongs to, based on ranges defined in the request. :arg distance_type: The distance calculation type. Defaults to `arc` if omitted. :arg field: A field of type `geo_point` used to evaluate the distance. :arg origin: The origin used to evaluate the distance. :arg ranges: An array of ranges used to bucket documents. :arg unit: The distance unit. Defaults to `m` if omitted. geo_distance distance_typeroriginrIunitr)arcplanerrrrrrrItypes.AggregationRanger) inftydminmikmmcmmmrc Ftjd|||||d|dS)Nrr'r)r=rrrrIrrrHs r4rzGeoDistance.__init__sM*  '         r6)rPrQrRrrBrrr rDrrrrrrWrXs@r4rrs&   D HO@G   %   W^4mCD S-}<=   % # UO  cN      - .c3h0H- W   H I= X ! &'          r6rc eZdZdZdZeeeeeddeddddeee fd fd eed d fd ee ed fd ee d fdee d fde f fdZ xZ S) GeohashGrida A multi-bucket aggregation that groups `geo_point` and `geo_shape` values into buckets that represent a grid. Each cell is labeled using a geohash which is of user-definable precision. :arg bounds: The bounding box to filter the points in each bucket. :arg field: Field containing indexed `geo_point` or `geo_shape` values. If the field contains an array, `geohash_grid` aggregates all array values. :arg precision: The string length of the geohashes used to define cells/buckets in the results. Defaults to `5` if omitted. :arg shard_size: Allows for more accurate counting of the top cells returned in the final result the aggregation. Defaults to returning `max(10,(size x number-of-shards))` buckets from each shard. :arg size: The maximum number of geohash buckets to return. Defaults to `10000` if omitted. geohash_gridboundsr precisionrrrtypes.CoordsGeoBounds!types.TopLeftBottomRightGeoBounds!types.TopRightBottomLeftGeoBoundstypes.WktGeoBoundsrrrrrrrc Ftjd|||||d|dS)Nrr'r)r=rrrrrrrHs r4rzGeohashGrid.__init__sM"  !         r6)rPrQrRrrBrrrrDrrrrrWrXs@r4rrs& D @G6=07*1    # / / cN     S-}<= ]23 #},- C&'           r6rc eZdZdZdZeeeeeddedeee fdfdedeee fdfd ee dfd ee d dfd ee dfd e f fdZ xZS)GeoLinead Aggregates all `geo_point` values within a bucket into a `LineString` ordered by the chosen sort field. :arg point: (required) The name of the geo_point field. :arg sort: (required) The name of the numeric field to use as the sort key for ordering the points. When the `geo_line` aggregation is nested inside a `time_series` aggregation, this field defaults to `@timestamp`, and any other value will result in error. :arg include_sort: When `true`, returns an additional array of the sort values in the feature properties. :arg sort_order: The order in which the line is sorted (ascending or descending). Defaults to `asc` if omitted. :arg size: The maximum length of the line represented in the aggregation. Valid sizes are between 1 and 10000. Defaults to `10000` if omitted. geo_linepointr include_sort sort_orderrrtypes.GeoLinePointrrtypes.GeoLineSortrrr@rrc Ftjd|||||d|dSNrr'rr=rrrrrrrHs r4rzGeoLine.__init__M  %!         r6rPrQrRrrBrrrrDrrVr rrrWrXs@r4rrs$ D MTJQ3:CJ*1   )4S>=HI 'c3hFG  D-/0  '-0-?@  C&'           r6rceZdZdZdZeeeeeddeeddfdeedfdee dfd ee dfd ed d d de ee fdfde f fdZ xZ S) GeotileGrida A multi-bucket aggregation that groups `geo_point` and `geo_shape` values into buckets that represent a grid. Each cell corresponds to a map tile as used by many online map sites. :arg field: Field containing indexed `geo_point` or `geo_shape` values. If the field contains an array, `geotile_grid` aggregates all array values. :arg precision: Integer zoom of the key used to define cells/buckets in the results. Values outside of the range [0,29] will be rejected. Defaults to `7` if omitted. :arg shard_size: Allows for more accurate counting of the top cells returned in the final result the aggregation. Defaults to returning `max(10,(size x number-of-shards))` buckets from each shard. :arg size: The maximum number of buckets to return. Defaults to `10000` if omitted. :arg bounds: A bounding box to filter the geo-points or geo-shapes in each bucket. geotile_gridrrrrrrrrrrrrrrrrrc Ftjd|||||d|dS)Nrr'r)r=rrrrrrrHs r4rzGeotileGrid.__init__'sM"  !         r6)rPrQrRrrBrrrDrrrrrrWrXs@r4rrs* D AH1807*1    S-}<=  -.  #},-  C&'   # / / cN               r6rceZdZdZdZeeeeeddeeddfdeedfded d d d e ee fdfd eedfdeedfde f fdZ xZ S) GeohexGrida$ A multi-bucket aggregation that groups `geo_point` and `geo_shape` values into buckets that represent a grid. Each cell corresponds to a H3 cell index and is labeled using the H3Index representation. :arg field: (required) Field containing indexed `geo_point` or `geo_shape` values. If the field contains an array, `geohex_grid` aggregates all array values. :arg precision: Integer zoom of the key used to defined cells or buckets in the results. Value should be between 0-15. Defaults to `6` if omitted. :arg bounds: Bounding box used to filter the geo-points in each bucket. :arg size: Maximum number of buckets to return. Defaults to `10000` if omitted. :arg shard_size: Number of buckets returned from each shard. geohex_gridrrrrrrrrrrrrrrrrrc Ftjd|||||d|dS)Nrr'r)r=rrrrrrrHs r4rzGeohexGrid.__init__WsM"  !         r6) rPrQrRrrBrrrDrrrrrWrXs@r4rrBs$ D AH/6 *107   S-}<= m+,   # / / cN     C&' #},-           r6rc,eZdZdZdZdeffd ZxZS)Globalu Defines a single bucket of all the documents within the search execution context. This context is defined by the indices and the document types you’re searching on, but is not influenced by the search query itself. globalrc :tjdi|dSrrr=rrHs r4rzGlobal.__init__|&""6"""""r6rPrQrRrrBrrrWrXs@r4rrrsU D###########r6rceZdZdZdZeeeeeeeeeeed dedeee fdfdedeee fdfdeed dfd ee dfd ee dfd ee dfd ee dfdee eed fe dfee eed fe dfdfdedeee fdfdeedfdeedfde ffdZddde dee fdZxZS) Histograma A multi-bucket values source based aggregation that can be applied on numeric values or numeric range values extracted from the documents. It dynamically builds fixed size (interval) buckets over the values. :arg extended_bounds: Enables extending the bounds of the histogram beyond the data itself. :arg hard_bounds: Limits the range of buckets in the histogram. It is particularly useful in the case of open data ranges that can result in a very large number of buckets. :arg field: The name of the field to aggregate on. :arg interval: The interval for the buckets. Must be a positive decimal. :arg min_doc_count: Only returns buckets that have `min_doc_count` number of documents. By default, the response will fill gaps in the histogram with empty buckets. :arg missing: The value to apply to documents that do not have a value. By default, documents without a value are ignored. :arg offset: By default, the bucket keys start with 0 and then continue in even spaced steps of `interval`. The bucket boundaries can be shifted by using the `offset` option. :arg order: The sort order of the returned buckets. By default, the returned buckets are sorted by their key ascending. :arg script: :arg format: :arg keyed: If `true`, returns buckets as a hash instead of an array, keyed by the bucket keys. histogram r6r7rr9rrrr:rrr;r6r?rr7rrr9rrrr:r@rrrr;rc  Rtjd||||||||| | | d | dS)Nrr'r)r=r6r7rr9rrrr:rrr;rrHs r4rzHistogram.__init__s_0  +#'  r6rIrJrKr"c$t|||SrMrrNs r4rOzHistogram.resultrr6)rPrQrRrrBrrrrDrrrr r rrVrrrOrWrXs@r4rrs: D  @G073:/6.5 GN,3,3+% % %  "DcNM A %  "DcNM A % S-}<=% },-% S-/0% um+,% e]*+%  E#223W]5KK L WU3(;#;TTU V   % &nd38nmCD'% (c=())% *T=()+% ,-% % % % % % N3-3S3Xc]33333333r6rc eZdZdZdZeeddeeddfdeedee ee fdfd e ffd Z xZ S) IPRangez A multi-bucket value source based aggregation that enables the user to define a set of IP ranges - each representing a bucket. :arg field: The date field whose values are used to build ranges. :arg ranges: Array of IP ranges. ip_rangerrIrrrrIztypes.IpRangeAggregationRangerc @tjd||d|dS)Nrr'r)r=rrIrrHs r4rzIPRange.__init__s/ >uV>>v>>>>>r6) rPrQrRrrBrrrDrrrrrWrXs@r4rrs D AH  ? ? ?S-}<= ? 4 5 T#s(^ $   ? ? ? ? ? ? ? ? ? ? ?r6rceZdZdZdZeeeeeeddeeddfdeedfdee dfd ee dfd ee dfd eedfd e ffd Z xZ S)IPPrefixaN A bucket aggregation that groups documents based on the network or sub-network of an IP address. :arg field: (required) The IP address field to aggregation on. The field mapping type must be `ip`. :arg prefix_length: (required) Length of the network prefix. For IPv4 addresses the accepted range is [0, 32]. For IPv6 addresses the accepted range is [0, 128]. :arg is_ipv6: Defines whether the prefix applies to IPv6 addresses. :arg append_prefix_length: Defines whether the prefix length is appended to IP address keys in the response. :arg keyed: Defines whether buckets are returned as a hash rather than an array in the response. :arg min_doc_count: Minimum number of documents in a bucket for it to be included in the response. Defaults to `1` if omitted. ip_prefixr prefix_lengthis_ipv6append_prefix_lengthr;rrrrrrrr;rrc Htjd||||||d|dS)Nrr'r) r=rrrrr;rrrHs r4rzIPPrefix.__init__sP  '!5'        r6) rPrQrRrrBrrrDrrVrrrWrXs@r4rrs$ D AH3:.5;B,33:   S-}<= S-/0  t]*+  $D-$78  T=() S-/0           r6rceZdZdZdZeeeeeddeedfdedeee fdfdeedfd ee d dfd eee ee eefdfd e f fd Z xZS) Inferenceu A parent pipeline aggregation which loads a pre-trained model and performs inference on the collated result fields from the parent bucket aggregation. :arg model_id: (required) The ID or alias for the trained model. :arg inference_config: Contains the inference type and its options. :arg format: `DecimalFormat` pattern for the output value. If specified, the formatted value is returned in the aggregation’s `value_as_string` property. :arg gap_policy: Policy to apply when gaps are found in the data. Defaults to `skip` if omitted. :arg buckets_path: Path to the buckets that contain one set of values to correlate. inferencemodel_idinference_configrrrrrrztypes.InferenceConfigContainerrrrrrc Ftjd|||||d|dS)Nrr'r)r=rrrrrrrHs r4rzInference.__init__"sM  -!%         r6)rPrQrRrrBrrrDrrr rr rrWrXs@r4rrs D /6 ,3     ]*+  ,d38nm K  c=()  9 :M I   #S 1= @            r6rc eZdZdZdZeeeeeddedeee fdfdedeee fdfd ee dfd ee d dfd ee dfd e f fdZ xZS)Linea :arg point: (required) The name of the geo_point field. :arg sort: (required) The name of the numeric field to use as the sort key for ordering the points. When the `geo_line` aggregation is nested inside a `time_series` aggregation, this field defaults to `@timestamp`, and any other value will result in error. :arg include_sort: When `true`, returns an additional array of the sort values in the feature properties. :arg sort_order: The order in which the line is sorted (ascending or descending). Defaults to `asc` if omitted. :arg size: The maximum length of the line represented in the aggregation. Valid sizes are between 1 and 10000. Defaults to `10000` if omitted. linerrrrrrrrr@rrc Ftjd|||||d|dSrrrs r4rz Line.__init__Nrr6rrXs@r4rr<s   D MTJQ3:CJ*1   )4S>=HI 'c3hFG  D-/0  '-0-?@  C&'           r6rc eZdZdZdZeeeddeeddfdeeedfe eedfdfd ee eedfe fdfd e ffd Z xZS) MatrixStatsa  A numeric aggregation that computes the following statistics over a set of document fields: `count`, `mean`, `variance`, `skewness`, `kurtosis`, `covariance`, and `covariance`. :arg mode: Array value the aggregation will use for array or multi- valued fields. Defaults to `avg` if omitted. :arg fields: An array of fields for computing the statistics. :arg missing: The value to apply to documents that do not have a value. By default, documents without a value are ignored. matrix_statsmodergrr)minmaxsumrmedianrrgrrrc Btjd|||d|dS)Nrr'r)r=rrgrrrHs r4rzMatrixStats.__init__qs1 Md67MMfMMMMMr6)rPrQrRrrBrrr rDrr rrrrWrXs@r4rrbs   D   NNN 8 9= H N  #** + U3 334 5   N E#223U: ;] J NNNNNNNNNNNr6rc eZdZdZdZeeeeddeedfdeeddfdeeee e dfd ed e ee fdfd e f fd Z xZS) Maxav A single-value metrics aggregation that returns the maximum value among the numeric values extracted from the aggregated documents. :arg format: :arg field: The field on which to run the aggregation. :arg missing: The value to apply to documents that do not have a value. By default, documents without a value are ignored. :arg script: rrrrrrrrrrc Dtjd||||d|dSrrrs r4rz Max.__init__rr6rrXs@r4rrrr6rc eZdZdZdZeeeddeedfdeeddfdeee ee eefdfd e ffd Z xZ S) MaxBucketuO A sibling pipeline aggregation which identifies the bucket(s) with the maximum value of a specified metric in a sibling aggregation and outputs both the value and the key(s) of the bucket(s). :arg format: `DecimalFormat` pattern for the output value. If specified, the formatted value is returned in the aggregation’s `value_as_string` property. :arg gap_policy: Policy to apply when gaps are found in the data. Defaults to `skip` if omitted. :arg buckets_path: Path to the buckets that contain one set of values to correlate. max_bucketrrrrrrrc Btjd|||d|dSrrrs r4rzMaxBucket.__init__rr6rrXs@r4rrrOr6rceZdZdZdZeeeeeeddeedfdeeddfdee dfd ee d dfd ee e ee dfd ed e e e fdfde ffdZxZS)MedianAbsoluteDeviationa A single-value aggregation that approximates the median absolute deviation of its search results. :arg compression: Limits the maximum number of nodes used by the underlying TDigest algorithm to `20 * compression`, enabling control of memory usage and approximation error. Defaults to `1000` if omitted. :arg execution_hint: The default implementation of TDigest is optimized for performance, scaling to millions or even billions of sample values while maintaining acceptable accuracy levels (close to 1% relative error for millions of samples in some cases). To use an implementation optimized for accuracy, set this parameter to high_accuracy instead. Defaults to `default` if omitted. :arg format: :arg field: The field on which to run the aggregation. :arg missing: The value to apply to documents that do not have a value. By default, documents without a value are ignored. :arg script: median_absolute_deviationrrrrrrrrrrrrrrrrrc Htjd||||||d|dS)Nrr'r) r=rrrrrrrrHs r4rz MedianAbsoluteDeviation.__init__sP  #)        r6rrXs@r4rrs * 'D 4; ,3@G?FGN   5-/0  . / >  c=() S-}<= sCm;< nd38nmCD           r6rc eZdZdZdZeeeeddeedfdeeddfdeeee e dfd ed e ee fdfd e f fd Z xZS) Minar A single-value metrics aggregation that returns the minimum value among numeric values extracted from the aggregated documents. :arg format: :arg field: The field on which to run the aggregation. :arg missing: The value to apply to documents that do not have a value. By default, documents without a value are ignored. :arg script: rrrrrrrrrrc Dtjd||||d|dSrrrs r4rz Min.__init__rr6rrXs@r4rrrr6rc eZdZdZdZeeeddeedfdeeddfdeee ee eefdfd e ffd Z xZ S) MinBucketuO A sibling pipeline aggregation which identifies the bucket(s) with the minimum value of a specified metric in a sibling aggregation and outputs both the value and the key(s) of the bucket(s). :arg format: `DecimalFormat` pattern for the output value. If specified, the formatted value is returned in the aggregation’s `value_as_string` property. :arg gap_policy: Policy to apply when gaps are found in the data. Defaults to `skip` if omitted. :arg buckets_path: Path to the buckets that contain one set of values to correlate. min_bucketrrrrrrrc Btjd|||d|dSrrrs r4rzMinBucket.__init__rr6rrXs@r4rrrOr6rc deZdZdZdZeeddeeddfdeeee e dfde ffdZ xZ S) Missinga/ A field data based single bucket aggregation, that creates a bucket of all documents in the current document set context that are missing a field value (effectively, missing a field or having the configured NULL value set). :arg field: The name of the field. :arg missing: rrrrrrrc @tjd||d|dS)Nrr'r)r=rrrrHs r4rzMissing.__init__=s/ @ug@@@@@@@r6)rPrQrRrrBrrrDrrrVrrrWrXs@r4rr0s D AH?F AAAS-}<=AsCm;< A  AAAAAAAAAAr6rc,eZdZdZdZdeffd ZxZS) MovingAvg moving_avgrc :tjdi|dSrrrs r4rzMovingAvg.__init__Lrr6rrXs@r4rrGsN G D###########r6rc eZdZdZeeeeeeeeddededeeefdfdee dfdee dfd ee dfd eedfd ee d dfd eee ee eefdfdeffdZxZS)LinearMovingAverageAggregation :arg model: (required) :arg settings: (required) :arg minimize: :arg predict: :arg window: :arg format: `DecimalFormat` pattern for the output value. If specified, the formatted value is returned in the aggregation’s `value_as_string` property. :arg gap_policy: Policy to apply when gaps are found in the data. Defaults to `skip` if omitted. :arg buckets_path: Path to the buckets that contain one set of values to correlate. modelsettingsminimizepredictwindowrrrr r types.EmptyObjectrrrrrrrrrc Ltjd||||||||d| dSNr r'r r=r r rrrrrrrrHs r4rz'LinearMovingAverageAggregation.__init__`V"  !%  r6rPrQrRrrrrrrDrVrr rr rrWrXs@r4r r P7  $NU/6-4,3,3      +T#s(^]JK  m+,  sM)*  c=() c=()  9 :M I   #S 1= @            r6r c eZdZdZeeeeeeeeddededeeefdfdee dfdee dfd ee dfd eedfd ee d dfd eee ee eefdfdeffdZxZS)SimpleMovingAverageAggregationr r r r rrrrrrrrrrc Ltjd||||||||d| dSrrrs r4rz'SimpleMovingAverageAggregation.__init__rr6rrXs@r4rr~rr6rc eZdZdZeeeeeeeeddededeeefdfdee dfdee dfd ee dfd eedfd ee d dfd eee ee eefdfdeffdZxZS)EwmaMovingAverageAggregationr r r r ztypes.EwmaModelSettingsrrrrrrrrrc Ltjd||||||||d| dSrrrs r4rz%EwmaMovingAverageAggregation.__init__V&  !%  r6rrXs@r4rrs;  $ /6-4,3,3  !     %tCH~} D  m+, sM)* c=() c=()  9 :M I   #S 1= @  "#          r6rc eZdZdZeeeeeeeeddededeeefdfdee dfdee dfd ee dfd eedfd ee d dfd eee ee eefdfdeffdZxZS)HoltMovingAverageAggregationr r r r ztypes.HoltLinearModelSettingsrrrrrrrrrc Ltjd||||||||d| dSrrrs r4rz%HoltMovingAverageAggregation.__init__rr6rrXs@r4r r s;  $ /6-4,3,3  !     +T#s(^] J  m+, sM)* c=() c=()  9 :M I   #S 1= @  "#          r6r c eZdZdZeeeeeeeeddededeeefdfdee dfdee dfd ee dfd eedfd ee d dfd eee ee eefdfdeffdZxZS)#HoltWintersMovingAverageAggregationr r r r ztypes.HoltWintersModelSettingsrrrrrrrrrc Ltjd||||||||d| dSrrrs r4rz,HoltWintersMovingAverageAggregation.__init__ rr6rrXs@r4r#r# s;  $ /6-4,3,3  !     ,d38nm K  m+, sM)* c=() c=()  9 :M I   #S 1= @  "#          r6r#ceZdZdZdZeeeeeeddeedfdeedfdeedfdee dfd ee d dfd ee e e e e e fdfd e ffd ZxZS)MovingPercentilesu Given an ordered series of percentiles, "slides" a window across those percentiles and computes cumulative percentiles. :arg window: The size of window to "slide" across the histogram. :arg shift: By default, the window consists of the last n values excluding the current bucket. Increasing `shift` by 1, moves the starting window position by 1 to the right. :arg keyed: :arg format: `DecimalFormat` pattern for the output value. If specified, the formatted value is returned in the aggregation’s `value_as_string` property. :arg gap_policy: Policy to apply when gaps are found in the data. Defaults to `skip` if omitted. :arg buckets_path: Path to the buckets that contain one set of values to correlate. moving_percentilesrshiftr;rrrrrr)r;rrrrrc Htjd||||||d|dS)Nr(r'r) r=rr)r;rrrrrHs r4rzMovingPercentiles.__init__Q sP  !%        r6)rPrQrRrrBrrrrVrDr rr rrrWrXs@r4r&r&< s$ D -4+2,3,3     c=() S-'(  T=()  c=()   9 :M I   #S 1= @            r6r&ceZdZdZdZeeeeeeddeedfdeedfdeedfdeedfd ee d dfd eee ee eefdfd e ffd Z xZS)MovingFnu Given an ordered series of data, "slides" a window across the data and runs a custom script on each window of data. For convenience, a number of common functions are predefined such as `min`, `max`, and moving averages. :arg script: The script that should be executed on each window of data. :arg shift: By default, the window consists of the last n values excluding the current bucket. Increasing `shift` by 1, moves the starting window position by 1 to the right. :arg window: The size of window to "slide" across the histogram. :arg format: `DecimalFormat` pattern for the output value. If specified, the formatted value is returned in the aggregation’s `value_as_string` property. :arg gap_policy: Policy to apply when gaps are found in the data. Defaults to `skip` if omitted. :arg buckets_path: Path to the buckets that contain one set of values to correlate. moving_fnrr)rrrrrrr)rrrrrrc Htjd||||||d|dS)Nr.r'r) r=rr)rrrrrrHs r4rzMovingFn.__init__ sP  !%        r6)rPrQrRrrBrrrDrr rr rrrWrXs@r4r,r,k s* D -4+2,3,3     c=() S-'(  c=()  c=()   9 :M I   #S 1= @            r6r,c|eZdZdZdZeeeeeeeeddeedeee e fdfdee ddfd ee ee d fe d fee ee d fe d fdfd ee dfd ee dfdee dfdeedfdee dfde ffdZxZS) MultiTermsan A multi-bucket value source based aggregation where buckets are dynamically built - one per unique set of values. :arg terms: (required) The field from which to generate sets of terms. :arg collect_mode: Specifies the strategy for data collection. Defaults to `breadth_first` if omitted. :arg order: Specifies the sort order of the buckets. Defaults to sorting by descending document count. :arg min_doc_count: The minimum number of documents in a bucket for it to be returned. Defaults to `1` if omitted. :arg shard_min_doc_count: The minimum number of documents in a bucket on each shard for it to be returned. Defaults to `1` if omitted. :arg shard_size: The number of candidate terms produced by each shard. By default, `shard_size` will be automatically estimated based on the number of shards and the `size` parameter. :arg show_term_doc_count_error: Calculates the doc count error on per term basis. :arg size: The number of term buckets should be returned out of the overall terms list. Defaults to `10` if omitted. multi_termsterms collect_moder:rrrshow_term_doc_count_errorrr4ztypes.MultiTermLookuprr5 depth_first breadth_firstr:rr@rrrr6rrc Ltjd||||||||d| dS)Nr3r'r) r=r4r5r:rrrr6rrrHs r4rzMultiTerms.__init__ sV*  %' 3!&?  r6)rPrQrRrrBrrrrrDrr r rrVrrWrXs@r4r1r1 s, D   3:9@07@G*1%    , -xS#X/G V   2 3] B   E#223W]5KK L WU3(;#;TTU V    S-/0 #3 #56 #},-! "$)})<#=# $C&'% &'          r6r1cFeZdZdZdZefdeeddfdeffd Z xZ S)Nestedz A special single bucket aggregation that enables aggregating nested documents. :arg path: The path to the field of type `nested`. nestedpathrrrc >tjdd|i|dSNr>r'rr=r>rrHs r4rzNested.__init__ - --d-f-----r6r!rXs@r4r<r< sy D@G..C,m;<...........r6r<ceZdZdZdZeeeeddeeddfdeedfdeed dfd eee ee eefdfd e f fd Z xZ S) Normalizeu- A parent pipeline aggregation which calculates the specific normalized/rescaled value for a specific bucket value. :arg method: The specific method to apply. :arg format: `DecimalFormat` pattern for the output value. If specified, the formatted value is returned in the aggregation’s `value_as_string` property. :arg gap_policy: Policy to apply when gaps are found in the data. Defaults to `skip` if omitted. :arg buckets_path: Path to the buckets that contain one set of values to correlate. normalizemethodrrrrG) rescale_0_1 rescale_0_100percent_of_summeanzz-scoresoftmaxrrrrrrc Dtjd||||d|dS)NrFr'r)r=rGrrrrrHs r4rzNormalize.__init__ sJ.  !%         r6)rPrQrRrrBrrr rDrr rrrWrXs@r4rDrD s   D ,3  )          c=()  9 :M I  $ #S 1= @ % *+          r6rDcDeZdZdZdZefdeedfdeffd Z xZ S)Parentz A special single bucket aggregation that selects parent documents that have the specified type, as defined in a `join` field. :arg type: The child type that should be selected. parentr^rrc >tjdd|i|dSrrrs r4rzParent.__init__% r r6r!rXs@r4rOrO sn D9@..U3 #56.C..........r6rOc,eZdZdZdZeeeeeeeeddeedfdeee ddfded e e e fdfd ed e e e fdfd ee dfd ee ddfdee e e edfdede e e fdfde ffdZxZS)PercentileRanksa A multi-value metrics aggregation that calculates one or more percentile ranks over numeric values extracted from the aggregated documents. :arg keyed: By default, the aggregation associates a unique string key with each bucket and returns the ranges as a hash rather than an array. Set to `false` to disable this behavior. Defaults to `True` if omitted. :arg values: An array of values for which to calculate the percentile ranks. :arg hdr: Uses the alternative High Dynamic Range Histogram algorithm to calculate percentile ranks. :arg tdigest: Sets parameters for the default TDigest algorithm used to calculate percentile ranks. :arg format: :arg field: The field on which to run the aggregation. :arg missing: The value to apply to documents that do not have a value. By default, documents without a value are ignored. :arg script: percentile_ranksr;valueshdrtdigestrrrrr;rrVNrWtypes.HdrMethodrX types.TDigestrrrrrrrc Ltjd||||||||d| dS)NrUr'r) r=r;rVrWrXrrrrrrHs r4rzPercentileRanks.__init__B sV    r6rPrQrRrrBrrrVrrrrDrrrrWrXs@r4rSrS) sJ, D -4>EGNIP,3@G?FGN   T=() huot]:;  $d38nmC D  S#X EF  c=() S-}<= sCm;< nd38nmCD           r6rSc*eZdZdZdZeeeeeeeeddeedfdeee dfdede e e fdfd ed e e e fdfd ee dfd ee d dfdee e e edfdede e e fdfde ffdZxZS) Percentilesax A multi-value metrics aggregation that calculates one or more percentiles over numeric values extracted from the aggregated documents. :arg keyed: By default, the aggregation associates a unique string key with each bucket and returns the ranges as a hash rather than an array. Set to `false` to disable this behavior. Defaults to `True` if omitted. :arg percents: The percentiles to calculate. :arg hdr: Uses the alternative High Dynamic Range Histogram algorithm to calculate percentiles. :arg tdigest: Sets parameters for the default TDigest algorithm used to calculate percentiles. :arg format: :arg field: The field on which to run the aggregation. :arg missing: The value to apply to documents that do not have a value. By default, documents without a value are ignored. :arg script: percentilesr;percentsrWrXrrrrr;rrarWrYrXrZrrrrrrrc Ltjd||||||||d| dS)Nr`r'r) r=r;rarWrXrrrrrrHs r4rzPercentiles.__init__t sV    r6r\rXs@r4r^r^\ sH* D -4:AGNIP,3@G?FGN   T=() 67  $d38nmC D  S#X EF  c=() S-}<= sCm;< nd38nmCD           r6r^ceZdZdZdZeeeeddeeedfdee dfdee ddfd ee ee e e e fdfd e f fd Z xZS) PercentilesBucketuB A sibling pipeline aggregation which calculates percentiles across all bucket of a specified metric in a sibling aggregation. :arg percents: The list of percentiles to calculate. :arg format: `DecimalFormat` pattern for the output value. If specified, the formatted value is returned in the aggregation’s `value_as_string` property. :arg gap_policy: Policy to apply when gaps are found in the data. Defaults to `skip` if omitted. :arg buckets_path: Path to the buckets that contain one set of values to correlate. percentiles_bucketrarrrrarrrrrrc Dtjd||||d|dS)Nrfr'r)r=rarrrrrHs r4rzPercentilesBucket.__init__ sJ  !%         r6)rPrQrRrrBrrrrrDr r rrrWrXs@r4rdrd s   D ;B,3     67 c=()   9 :M I   #S 1= @            r6rdceZdZdZdZeeeeeeddeeddfdeedfdee d e e ee fdfd ed e ee fdfd ee dfd eedfde ffdZ xZS)RangeaD A multi-bucket value source based aggregation that enables the user to define a set of ranges - each representing a bucket. :arg field: The date field whose values are use to build ranges. :arg missing: The value to apply to documents that do not have a value. By default, documents without a value are ignored. :arg ranges: An array of ranges used to bucket documents. :arg script: :arg keyed: Set to `true` to associate a unique string key with each bucket and return the ranges as a hash rather than an array. :arg format: rangerrrIrr;rrrrrrIrrrr;rrc Htjd||||||d|dS)Nrkr'r) r=rrrIrr;rrrHs r4rzRange.__init__ sP          r6)rPrQrRrrBrrrDrrrrrVrrWrXs@r4riri s   D AH-4 GN,3,3   S-}<= sM)*   - .c3h0H- W  nd38nmCD T=() c=()           r6riceZdZdZdZeeeeeeeddeeeedfdeeddfdeeeed e ee fdfd ee dfd eee e e dfd ee dfd eedfde ffdZxZS) RareTermsu< A multi-bucket value source based aggregation which finds "rare" terms — terms that are at the long-tail of the distribution and are not frequent. :arg exclude: Terms that should be excluded from the aggregation. :arg field: The field from which to return rare terms. :arg include: Terms that should be included in the aggregation. :arg max_doc_count: The maximum number of documents a term should appear in. Defaults to `1` if omitted. :arg missing: The value to apply to documents that do not have a value. By default, documents without a value are ignored. :arg precision: The precision of the internal CuckooFilters. Smaller precision leads to better approximation, but higher memory usage. Defaults to `0.001` if omitted. :arg value_type: rare_termsexcluderinclude max_doc_countrr value_typerqrrrrrtypes.TermsPartitionrsrrrtrc Jtjd|||||||d|dS)Nrpr'r) r=rqrrrrsrrrtrrHs r4rzRareTerms.__init__ sS  '!  r6)rPrQrRrrBrrrDrrrrrrVrrWrXs@r4rnrn s-$ D =D@G 3:?F1807   sHSM=89 S-}<=   # 6S#X U  S-/0 sCm;<  -. #},-           r6rnceZdZdZdZeeeeeeddeeddfdeeddfd eedfd eed dfd eee e e dfd ede ee fdfde ffdZxZS)Ratea6 Calculates a rate of documents or a field in each bucket. Can only be used inside a `date_histogram` or `composite` aggregation. :arg unit: The interval used to calculate the rate. By default, the interval of the `date_histogram` is used. :arg mode: How the rate is calculated. Defaults to `sum` if omitted. :arg format: :arg field: The field on which to run the aggregation. :arg missing: The value to apply to documents that do not have a value. By default, documents without a value are ignored. :arg script: raterrrrrrrr<rr)r value_countrrrrrrrc Htjd||||||d|dS)Nrzr'r) r=rrrrrrrrHs r4rz Rate.__init__ sP          r6)rPrQrRrrBrrr rDrrrVrrrrWrXs@r4rxrx s   D DK,3@G?FGN    U     G01=@A c=() S-}<= sCm;< nd38nmCD           r6rxcFeZdZdZdZefdeeddfdeffd Z xZ S) ReverseNestedad A special single bucket aggregation that enables aggregating on parent documents from nested documents. Should only be defined inside a `nested` aggregation. :arg path: Defines the nested object field that should be joined back to. The default is empty, which means that it joins back to the root/main document level. reverse_nestedr>rrrc >tjdd|i|dSr@rrAs r4rzReverseNested.__init__F rBr6r!rXs@r4r~r~9 sy D@G..C,m;<...........r6r~c reZdZdZdZeeeddeedfdeedfdeedfde ffd Z xZ S) RandomSamplera A single bucket aggregation that randomly includes documents in the aggregated results. Sampling provides significant speed improvement at the cost of accuracy. :arg probability: (required) The probability that a document will be included in the aggregated data. Must be greater than 0, less than 0.5, or exactly 1. The lower the probability, the fewer documents are matched. :arg seed: The seed to generate the random sampling of documents. When a seed is provided, the random subset of documents is the same between calls. :arg shard_seed: When combined with seed, setting shard_seed ensures 100% consistent sampling over shards where data is exactly the same. random_sampler probabilityseed shard_seedrrrrrc Btjd|||d|dS)Nrr'r)r=rrrrrHs r4rzRandomSampler.__init__b sC  #$:  IO     r6) rPrQrRrrBrrrrrrrWrXs@r4rrN s" D 4;*107    5-/0  C&'  #},-             r6rcDeZdZdZdZefdeedfdeffd Z xZ S)Samplera A filtering aggregation used to limit any sub aggregations' processing to a sample of the top-scoring documents. :arg shard_size: Limits how many top-scoring documents are collected in the sample processed on each shard. Defaults to `100` if omitted. samplerrrrc >tjdd|i|dS)Nrr'r)r=rrrHs r4rzSampler.__init__{ s+99J9&99999r6) rPrQrRrrBrrrrrrWrXs@r4rro so D?F::5m);#<:RU::::::::::r6rcReZdZdZdZeeeeeeeeddedeee fdfdedeee fdfdedeee fdfd ee ee fdfd edeee fdfd eed dfd eee e e dfdedeee fdfde ffdZxZS)ScriptedMetrica A metric aggregation that uses scripts to provide a metric output. :arg combine_script: Runs once on each shard after document collection is complete. Allows the aggregation to consolidate the state returned from each shard. :arg init_script: Runs prior to any collection of documents. Allows the aggregation to set up any initial state. :arg map_script: Run once per document collected. If no `combine_script` is specified, the resulting state needs to be stored in the `state` object. :arg params: A global object with script parameters for `init`, `map` and `combine` scripts. It is shared between the scripts. :arg reduce_script: Runs once on the coordinating node after all shards have returned their results. The script is provided with access to a variable `states`, which is an array of the result of the `combine_script` on each shard. :arg field: The field on which to run the aggregation. :arg missing: The value to apply to documents that do not have a value. By default, documents without a value are ignored. :arg script: scripted_metriccombine_script init_script map_scriptr! reduce_scriptrrrrrrrrr!rrrrrrc Ltjd||||||||d| dS)Nrr'r) r=rrrr!rrrrrrHs r4rzScriptedMetric.__init__ sV  )#!'  r6)rPrQrRrrBrrrrDrr rrrVrrWrXs@r4rr sb. D PWLSKR:ANU@G?FGN   nd38nmKL >4S>=HI  .$sCx.-GH  gc3h'67  ^T#s(^]JK S-}<= sCm;< nd38nmCD           r6rceZdZdZdZeeeeddeedfdeedfdee ddfd eee ee eefdfd e f fd Z xZS) SerialDiffuj An aggregation that subtracts values in a time series from themselves at different time lags or periods. :arg lag: The historical bucket to subtract from the current value. Must be a positive, non-zero integer. :arg format: `DecimalFormat` pattern for the output value. If specified, the formatted value is returned in the aggregation’s `value_as_string` property. :arg gap_policy: Policy to apply when gaps are found in the data. Defaults to `skip` if omitted. :arg buckets_path: Path to the buckets that contain one set of values to correlate. serial_difflagrrrrrrrrrrc Dtjd||||d|dS)Nrr'r)r=rrrrrrHs r4rzSerialDiff.__init__ sJ  !%         r6)rPrQrRrrBrrrrDr rr rrrWrXs@r4rr s   D *1,3     3 % & c=()   9 :M I   #S 1= @            r6rc#XeZdZdZdZdddiiZeeeeeeeeeeeeeeeeddeedfded e e e fdfd ee e e dfd ee d dfd ee ddfdede e e fdfdee e e de e e fdfdede e e fdfdeedfdede e e fdfdede e e fdfdede e e fdfdede e e fdfdeedfdeedfd eedfd!e f"fd"ZxZS)#SignificantTermsaf Returns interesting or unusual occurrences of terms in a set. :arg background_filter: A background filter that can be used to focus in on significant terms within a narrower context, instead of the entire index. :arg chi_square: Use Chi square, as described in "Information Retrieval", Manning et al., Chapter 13.5.2, as the significance score. :arg exclude: Terms to exclude. :arg execution_hint: Mechanism by which the aggregation should be executed: using field values directly or using global ordinals. :arg field: The field from which to return significant terms. :arg gnd: Use Google normalized distance as described in "The Google Similarity Distance", Cilibrasi and Vitanyi, 2007, as the significance score. :arg include: Terms to include. :arg jlh: Use JLH score as the significance score. :arg min_doc_count: Only return terms that are found in more than `min_doc_count` hits. Defaults to `3` if omitted. :arg mutual_information: Use mutual information as described in "Information Retrieval", Manning et al., Chapter 13.5.1, as the significance score. :arg percentage: A simple calculation of the number of documents in the foreground sample with a term divided by the number of documents in the background with the term. :arg script_heuristic: Customized score, implemented via a script. :arg p_value: Significant terms heuristic that calculates the p-value between the term existing in foreground and background sets. The p-value is the probability of obtaining test results at least as extreme as the results actually observed, under the assumption that the null hypothesis is correct. The p-value is calculated assuming that the foreground set and the background set are independent https://en.wikipedia.org/wiki/Bernoulli_trial, with the null hypothesis that the probabilities are the same. :arg shard_min_doc_count: Regulates the certainty a shard has if the term should actually be added to the candidate list or not with respect to the `min_doc_count`. Terms will only be considered if their local shard frequency within the set is higher than the `shard_min_doc_count`. :arg shard_size: Can be used to control the volumes of candidate terms produced by each shard. By default, `shard_size` will be automatically estimated based on the number of shards and the `size` parameter. :arg size: The number of buckets returned out of the overall terms list. significant_termsbackground_filterr^r)r chi_squarerqrrgndrrjlhrmutual_information percentagescript_heuristicp_valuerrrrrtypes.ChiSquareHeuristicrqrrUrglobal_ordinals_hashglobal_ordinals_low_cardinalityrrr'types.GoogleNormalizedDistanceHeuristicrrrurrrr types.MutualInformationHeuristicrtypes.PercentageScoreHeuristicrtypes.ScriptedHeuristicrztypes.PValueHeuristicrrrrc tjdid|d|d|d|d|d|d|d|d | d | d | d | d | d|d|d||dS)Nrrrqrrrrrrrrrrrrrrr'r)r=rrrqrrrrrrrrrrrrrrrrHs r4rzSignificantTerms.__init__ sV    // !z G *>  %    G  (-  21 "z .- G !4 3 "z #     r6)rPrQrRrrBr`rrrrrDrrr rrrWrXs@r4rr s..` Dfg.K:A   %  #8"7   G  (-  21 "z .- !4 3 "z ! "(-%     r6)rPrQrRrrBr`rrrrrDrrr rVrrrWrXs@r4rrQ s**X Dfg.K:A  %  G  (-  G (- *> "z % 6 !4 3 "z '@&? ! "6%     r6rIrJrKr"c$t|||SrMrrNs r4rOz Terms.result rr6)rPrQrRrrBrrr rDrrrrrrVr rrrOrWrXs@r4rrb s%%N D  -; 2dM123; 4#},-5; 6 E#223W]5KK L WU3(;#;TTU V   7; @nd38nmCDA; B#3 #56C; D#},-E; F$)})<#=G; HC&'I; Jc=()K; LM; ; ; ; ; ; z3-3S3Xc]33333333r6rc\eZdZdZdZeeddeedfdeedfde ffdZ xZ S) TimeSeriesa The time series aggregation queries data created using a time series index. This is typically data such as metrics or other data streams with a time component, and requires creating an index using the time series mode. :arg size: The maximum number of results to return. Defaults to `10000` if omitted. :arg keyed: Set to `true` to associate a unique string key with each bucket and returns the ranges as a hash rather than an array. time_seriesrr;rrr;rc @tjd||d|dS)Nrr'r)r=rr;rrHs r4rzTimeSeries.__init__ s/ :d%::6:::::r6) rPrQrRrrBrrrrVrrrWrXs@r4rr s   D +2,3 ;;;C&';T=() ;  ;;;;;;;;;;r6rc%eZdZdZdZeeeeeeeeeeeeeeeeddeedeee e fdfdee dfdeedeee e fdfd ee dfd ed ee e fdfd ee e d fee e fdfdee dfdeeee dfdfeeee dfdfee e fdfdee dee e fdfdeee dfeee dfdfdee dfdee dfdee dfdee ddfdee e ee dfdedee e fdfde f"fdZddd e d!ee fd"ZxZS)#TopHitsa A metric aggregation that returns the top matching documents per bucket. :arg docvalue_fields: Fields for which to return doc values. :arg explain: If `true`, returns detailed information about score computation as part of a hit. :arg fields: Array of wildcard (*) patterns. The request returns values for field names matching these patterns in the hits.fields property of the response. :arg from: Starting document offset. :arg highlight: Specifies the highlighter to use for retrieving highlighted snippets from one or more fields in the search results. :arg script_fields: Returns the result of one or more script evaluations for each hit. :arg size: The maximum number of top matching hits to return per bucket. Defaults to `3` if omitted. :arg sort: Sort order of the top matching hits. By default, the hits are sorted by the score of the main query. :arg _source: Selects the fields of the source that are returned. :arg stored_fields: Returns values for the specified stored fields (fields that use the `store` mapping option). :arg track_scores: If `true`, calculates and returns document scores, even if the scores are not used for sorting. :arg version: If `true`, returns document version as part of a hit. :arg seq_no_primary_term: If `true`, returns sequence number and primary term of the last modification of each hit. :arg field: The field on which to run the aggregation. :arg missing: The value to apply to documents that do not have a value. By default, documents without a value are ignored. :arg script: top_hits)docvalue_fieldsexplainrgr highlight script_fieldsrr_source stored_fields track_scoresversionseq_no_primary_termrrrrztypes.FieldAndFormatrrrgrrztypes.Highlightrztypes.ScriptFieldrrrrrztypes.SourceFilterrrrrrrrrrc tjdid|d|d|d|d|d|d|d|d | d | d | d | d | d|d|d||dS)Nrrrgrrrrrrrrrrrrrr'r)r=rrrgrrrrrrrrrrrrrrrHs r4rzTopHits.__init__ sL    +O G 6 %   i  (-    G (- & G !4 3 % G 6#     r6rIrJrKr"c$t|||SrM)rrNs r4rOzTopHits.resultEs4...r6)rPrQrRrrBrrrrrDrrVrr rrrrOrWrXs@r4rr s  D D .5 +2MT *1   3:.5:A@G?FGNG8 8 8  + ,htCH~.F U 8 t]*+ 8  + ,htCH~.F U 8 S-'(8 *DcNMIJ8  C,, -tCH~} L 8 C&'8  %0013FF G U5&9!9:t]*+?8 @#4#67A8 BS-}<=C8 DsCm;rs$ 322222PPPPPPPPPPPP(((((((((((::::::000000'''''' -1/8/8~c3h/C?@/8 U3<( )/8/8 /8/8/8/8d33333'72;333(L.L.L.L.L.gbkL.L.L.^     WR[#b'        s2w   IIIIIfRjIII87373737373r 737373t     #b'   8          F) ) ) ) ) c"g) ) ) X% % % % % 8B<% % % P% % % % % Xb\% % % P! ! ! ! ! ! ! ! H1 1 1 1 1  1 1 1 hQQQQQ QQQ4/ / / / / #b'/ / / dPPPPPc"gPPP0PPPPPBPPP0O O O O O VBZO O O d" " " " " (2," " " J . . . . .vbz . . .LLLLLr LLLB     HRL   B     HRL   DZ3Z3Z3Z3Z3F2JZ3Z3Z3z* * * * * r * * * Z     "   D' ' ' ' ' ' ' ' T! ! ! ! ! CG! ! ! H% % % % % (2,% % % P* * * * * s2w* * * ZVBZ4% % % % % fRj% % % P     B   D' ' ' ' ' #b'' ' ' T- - - - - &*- - - `. . . . . &*. . . b& & & & & c"g& & & R0 0 0 0 0 &*0 0 0 f- - - - - - - - ` # # # # #VBZ # # #H3H3H3H3H3r H3H3H3V?????fRj???2( ( ( ( ( vbz( ( ( V* * * * *  * * * Z# # # # # 3r7# # # LNNNNN#b'NNND     #b'   8         D- - - - - c"g- - - `     #b'   8         DAAAAAfRjAAA.##### ###+ + + + + Yr]+ + + \+ + + + + Yr]+ + + \- - - - - 9R=- - - `- - - - - 9R=- - - `- - - - - )B-- - - `, , , , ,  , , , ^/ / / / / x|/ / / d8 8 8 8 8 8 8 8 v.....VBZ...$. . . . .  . . . b . . . . .VBZ . . .0 0 0 0 0 c"g0 0 0 f/ / / / / #b'/ / / d$ $ $ $ $  $ $ $ N& & & & & F2J& & & R, , , , , r , , , ^) ) ) ) ) 3r7) ) ) X.....F2J...*     F2J   B : : : : :fRj : : : 1 1 1 1 1 SW1 1 1 h% % % % % "% % % Ps s s s s vbzs s s ls s s s s fRjs s s l     CG   8     (2,   B     #b'   B     #b'   8         Bh3h3h3h3h3F2Jh3h3h3V;;;;;;;;2`/`/`/`/`/c"g`/`/`/F88888CG8886. . . . . R. . . b     R   8+ + + + + #b'+ + + \'3'3'3'3'3VBZ'3'3'3'3'3r6