pandagg.node.agg.pipeline module

Pipeline aggregations: https://www.elastic.co/guide/en/elasticsearch/reference/2.3/search-aggregations-pipeline.html

class pandagg.node.agg.pipeline.AvgBucket(name, buckets_path, gap_policy=None, meta=None, aggs=None, **body)

Bases: pandagg.node.agg.abstract.Pipeline

KEY = 'avg_bucket'

VALUE_ATTRS = ['value']

class pandagg.node.agg.pipeline.BucketScript(name, script, buckets_path, gap_policy=None, meta=None, aggs=None, **body)

Bases: pandagg.node.agg.abstract.ScriptPipeline

KEY = 'bucket_script'

VALUE_ATTRS = ['value']

class pandagg.node.agg.pipeline.BucketSelector(name, script, buckets_path, gap_policy=None, meta=None, aggs=None, **body)

Bases: pandagg.node.agg.abstract.ScriptPipeline

KEY = 'bucket_selector'

VALUE_ATTRS = None

class pandagg.node.agg.pipeline.BucketSort(name, script, buckets_path, gap_policy=None, meta=None, aggs=None, **body)

Bases: pandagg.node.agg.abstract.ScriptPipeline

KEY = 'bucket_sort'

VALUE_ATTRS = None

class pandagg.node.agg.pipeline.CumulativeSum(name, buckets_path, gap_policy=None, meta=None, aggs=None, **body)

Bases: pandagg.node.agg.abstract.Pipeline

KEY = 'cumulative_sum'

VALUE_ATTRS = ['value']

class pandagg.node.agg.pipeline.Derivative(name, buckets_path, gap_policy=None, meta=None, aggs=None, **body)

Bases: pandagg.node.agg.abstract.Pipeline

KEY = 'derivative'

VALUE_ATTRS = ['value']

class pandagg.node.agg.pipeline.ExtendedStatsBucket(name, buckets_path, gap_policy=None, meta=None, aggs=None, **body)

Bases: pandagg.node.agg.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.agg.pipeline.MaxBucket(name, buckets_path, gap_policy=None, meta=None, aggs=None, **body)

Bases: pandagg.node.agg.abstract.Pipeline

KEY = 'max_bucket'

VALUE_ATTRS = ['value']

class pandagg.node.agg.pipeline.MinBucket(name, buckets_path, gap_policy=None, meta=None, aggs=None, **body)

Bases: pandagg.node.agg.abstract.Pipeline

KEY = 'min_bucket'

VALUE_ATTRS = ['value']

class pandagg.node.agg.pipeline.MovingAvg(name, buckets_path, gap_policy=None, meta=None, aggs=None, **body)

Bases: pandagg.node.agg.abstract.Pipeline

KEY = 'moving_avg'

VALUE_ATTRS = ['value']

class pandagg.node.agg.pipeline.PercentilesBucket(name, buckets_path, gap_policy=None, meta=None, aggs=None, **body)

Bases: pandagg.node.agg.abstract.Pipeline

KEY = 'percentiles_bucket'

VALUE_ATTRS = ['values']

class pandagg.node.agg.pipeline.SerialDiff(name, buckets_path, gap_policy=None, meta=None, aggs=None, **body)

Bases: pandagg.node.agg.abstract.Pipeline

KEY = 'serial_diff'

VALUE_ATTRS = ['value']

class pandagg.node.agg.pipeline.StatsBucket(name, buckets_path, gap_policy=None, meta=None, aggs=None, **body)

Bases: pandagg.node.agg.abstract.Pipeline

KEY = 'stats_bucket'

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

class pandagg.node.agg.pipeline.SumBucket(name, buckets_path, gap_policy=None, meta=None, aggs=None, **body)

Bases: pandagg.node.agg.abstract.Pipeline

KEY = 'sum_bucket'

VALUE_ATTRS = ['value']