File tree Expand file tree Collapse file tree 2 files changed +23
-0
lines changed Expand file tree Collapse file tree 2 files changed +23
-0
lines changed Original file line number Diff line number Diff line change @@ -278,6 +278,10 @@ class DiversifiedSampler(Bucket):
278
278
name = "diversified_sampler"
279
279
280
280
281
+ class RandomSampler (Bucket ):
282
+ name = "random_sampler"
283
+
284
+
281
285
class Composite (Bucket ):
282
286
name = "composite"
283
287
_param_defs = {
Original file line number Diff line number Diff line change @@ -383,3 +383,22 @@ def test_normalize_aggregation():
383
383
assert {
384
384
"normalize" : {"buckets_path" : "normalized" , "method" : "percent_of_sum" }
385
385
} == a .to_dict ()
386
+
387
+
388
+ def test_random_sampler_aggregation ():
389
+ a = aggs .RandomSampler (probability = 0.1 ).metric (
390
+ "price_percentiles" ,
391
+ "percentiles" ,
392
+ field = "price" ,
393
+ )
394
+
395
+ assert {
396
+ "random_sampler" : {
397
+ "probability" : 0.1 ,
398
+ },
399
+ "aggs" : {
400
+ "price_percentiles" : {
401
+ "percentiles" : {"field" : "price" },
402
+ },
403
+ },
404
+ } == a .to_dict ()
You can’t perform that action at this time.
0 commit comments