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(buckets_path: str, gap_policy: Optional[typing_extensions.Literal['skip', 'insert_zeros', 'keep_values'][skip, insert_zeros, keep_values]] = None, **body)

Bases: pandagg.node.aggs.abstract.Pipeline

KEY = 'avg_bucket'

VALUE_ATTRS = ['value']

class pandagg.node.aggs.pipeline.BucketScript(script: pandagg.types.Script, buckets_path: str, gap_policy: Optional[typing_extensions.Literal['skip', 'insert_zeros', 'keep_values'][skip, insert_zeros, keep_values]] = None, **body)

Bases: pandagg.node.aggs.abstract.ScriptPipeline

KEY = 'bucket_script'

VALUE_ATTRS = ['value']

class pandagg.node.aggs.pipeline.BucketSelector(script: pandagg.types.Script, buckets_path: str, gap_policy: Optional[typing_extensions.Literal['skip', 'insert_zeros', 'keep_values'][skip, insert_zeros, keep_values]] = None, **body)

Bases: pandagg.node.aggs.abstract.ScriptPipeline

KEY = 'bucket_selector'

VALUE_ATTRS = []

class pandagg.node.aggs.pipeline.BucketSort(script: pandagg.types.Script, buckets_path: str, gap_policy: Optional[typing_extensions.Literal['skip', 'insert_zeros', 'keep_values'][skip, insert_zeros, keep_values]] = None, **body)

Bases: pandagg.node.aggs.abstract.ScriptPipeline

KEY = 'bucket_sort'

VALUE_ATTRS = []

class pandagg.node.aggs.pipeline.CumulativeSum(buckets_path: str, gap_policy: Optional[typing_extensions.Literal['skip', 'insert_zeros', 'keep_values'][skip, insert_zeros, keep_values]] = None, **body)

Bases: pandagg.node.aggs.abstract.Pipeline

KEY = 'cumulative_sum'

VALUE_ATTRS = ['value']

class pandagg.node.aggs.pipeline.Derivative(buckets_path: str, gap_policy: Optional[typing_extensions.Literal['skip', 'insert_zeros', 'keep_values'][skip, insert_zeros, keep_values]] = None, **body)

Bases: pandagg.node.aggs.abstract.Pipeline

KEY = 'derivative'

VALUE_ATTRS = ['value']

class pandagg.node.aggs.pipeline.ExtendedStatsBucket(buckets_path: str, gap_policy: Optional[typing_extensions.Literal['skip', 'insert_zeros', 'keep_values'][skip, insert_zeros, keep_values]] = None, **body)

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(buckets_path: str, gap_policy: Optional[typing_extensions.Literal['skip', 'insert_zeros', 'keep_values'][skip, insert_zeros, keep_values]] = None, **body)

Bases: pandagg.node.aggs.abstract.Pipeline

KEY = 'max_bucket'

VALUE_ATTRS = ['value']

class pandagg.node.aggs.pipeline.MinBucket(buckets_path: str, gap_policy: Optional[typing_extensions.Literal['skip', 'insert_zeros', 'keep_values'][skip, insert_zeros, keep_values]] = None, **body)

Bases: pandagg.node.aggs.abstract.Pipeline

KEY = 'min_bucket'

VALUE_ATTRS = ['value']

class pandagg.node.aggs.pipeline.MovingAvg(buckets_path: str, gap_policy: Optional[typing_extensions.Literal['skip', 'insert_zeros', 'keep_values'][skip, insert_zeros, keep_values]] = None, **body)

Bases: pandagg.node.aggs.abstract.Pipeline

KEY = 'moving_avg'

VALUE_ATTRS = ['value']

class pandagg.node.aggs.pipeline.PercentilesBucket(buckets_path: str, gap_policy: Optional[typing_extensions.Literal['skip', 'insert_zeros', 'keep_values'][skip, insert_zeros, keep_values]] = None, **body)

Bases: pandagg.node.aggs.abstract.Pipeline

KEY = 'percentiles_bucket'

VALUE_ATTRS = ['values']

class pandagg.node.aggs.pipeline.SerialDiff(buckets_path: str, gap_policy: Optional[typing_extensions.Literal['skip', 'insert_zeros', 'keep_values'][skip, insert_zeros, keep_values]] = None, **body)

Bases: pandagg.node.aggs.abstract.Pipeline

KEY = 'serial_diff'

VALUE_ATTRS = ['value']

class pandagg.node.aggs.pipeline.StatsBucket(buckets_path: str, gap_policy: Optional[typing_extensions.Literal['skip', 'insert_zeros', 'keep_values'][skip, insert_zeros, keep_values]] = None, **body)

Bases: pandagg.node.aggs.abstract.Pipeline

KEY = 'stats_bucket'

VALUE_ATTRS = ['count', 'min', 'max', 'avg', 'sum']

class pandagg.node.aggs.pipeline.SumBucket(buckets_path: str, gap_policy: Optional[typing_extensions.Literal['skip', 'insert_zeros', 'keep_values'][skip, insert_zeros, keep_values]] = None, **body)

Bases: pandagg.node.aggs.abstract.Pipeline

KEY = 'sum_bucket'

VALUE_ATTRS = ['value']