pandagg.node.aggs.pipeline module¶
Pipeline aggregations: https://www.elastic.co/guide/en/elasticsearch/reference/2.3/search-aggregations-pipeline.html
-
class
pandagg.node.aggs.pipeline.
AvgBucket
(name, buckets_path, gap_policy=None, meta=None, **body)[source]¶ Bases:
pandagg.node.aggs.abstract.Pipeline
-
KEY
= 'avg_bucket'¶
-
VALUE_ATTRS
= ['value']¶
-
-
class
pandagg.node.aggs.pipeline.
BucketScript
(name, script, buckets_path, gap_policy=None, meta=None, **body)[source]¶ Bases:
pandagg.node.aggs.abstract.ScriptPipeline
-
KEY
= 'bucket_script'¶
-
VALUE_ATTRS
= ['value']¶
-
-
class
pandagg.node.aggs.pipeline.
BucketSelector
(name, script, buckets_path, gap_policy=None, meta=None, **body)[source]¶ Bases:
pandagg.node.aggs.abstract.ScriptPipeline
-
KEY
= 'bucket_selector'¶
-
VALUE_ATTRS
= None¶
-
-
class
pandagg.node.aggs.pipeline.
BucketSort
(name, script, buckets_path, gap_policy=None, meta=None, **body)[source]¶ Bases:
pandagg.node.aggs.abstract.ScriptPipeline
-
KEY
= 'bucket_sort'¶
-
VALUE_ATTRS
= None¶
-
-
class
pandagg.node.aggs.pipeline.
CumulativeSum
(name, buckets_path, gap_policy=None, meta=None, **body)[source]¶ Bases:
pandagg.node.aggs.abstract.Pipeline
-
KEY
= 'cumulative_sum'¶
-
VALUE_ATTRS
= ['value']¶
-
-
class
pandagg.node.aggs.pipeline.
Derivative
(name, buckets_path, gap_policy=None, meta=None, **body)[source]¶ Bases:
pandagg.node.aggs.abstract.Pipeline
-
KEY
= 'derivative'¶
-
VALUE_ATTRS
= ['value']¶
-
-
class
pandagg.node.aggs.pipeline.
ExtendedStatsBucket
(name, buckets_path, gap_policy=None, meta=None, **body)[source]¶ Bases:
pandagg.node.aggs.abstract.Pipeline
-
KEY
= 'extended_stats_bucket'¶
-
VALUE_ATTRS
= ['count', 'min', 'max', 'avg', 'sum', 'sum_of_squares', 'variance', 'std_deviation', 'std_deviation_bounds']¶
-
-
class
pandagg.node.aggs.pipeline.
MaxBucket
(name, buckets_path, gap_policy=None, meta=None, **body)[source]¶ Bases:
pandagg.node.aggs.abstract.Pipeline
-
KEY
= 'max_bucket'¶
-
VALUE_ATTRS
= ['value']¶
-
-
class
pandagg.node.aggs.pipeline.
MinBucket
(name, buckets_path, gap_policy=None, meta=None, **body)[source]¶ Bases:
pandagg.node.aggs.abstract.Pipeline
-
KEY
= 'min_bucket'¶
-
VALUE_ATTRS
= ['value']¶
-
-
class
pandagg.node.aggs.pipeline.
MovingAvg
(name, buckets_path, gap_policy=None, meta=None, **body)[source]¶ Bases:
pandagg.node.aggs.abstract.Pipeline
-
KEY
= 'moving_avg'¶
-
VALUE_ATTRS
= ['value']¶
-
-
class
pandagg.node.aggs.pipeline.
PercentilesBucket
(name, buckets_path, gap_policy=None, meta=None, **body)[source]¶ Bases:
pandagg.node.aggs.abstract.Pipeline
-
KEY
= 'percentiles_bucket'¶
-
VALUE_ATTRS
= ['values']¶
-
-
class
pandagg.node.aggs.pipeline.
SerialDiff
(name, buckets_path, gap_policy=None, meta=None, **body)[source]¶ Bases:
pandagg.node.aggs.abstract.Pipeline
-
KEY
= 'serial_diff'¶
-
VALUE_ATTRS
= ['value']¶
-
-
class
pandagg.node.aggs.pipeline.
StatsBucket
(name, buckets_path, gap_policy=None, meta=None, **body)[source]¶ Bases:
pandagg.node.aggs.abstract.Pipeline
-
KEY
= 'stats_bucket'¶
-
VALUE_ATTRS
= ['count', 'min', 'max', 'avg', 'sum']¶
-
-
class
pandagg.node.aggs.pipeline.
SumBucket
(name, buckets_path, gap_policy=None, meta=None, **body)[source]¶ Bases:
pandagg.node.aggs.abstract.Pipeline
-
KEY
= 'sum_bucket'¶
-
VALUE_ATTRS
= ['value']¶
-