aggregations

Documentation

Index

• func By(by []string, input []*oproto.ValueStream) []*variable.Variable
• func CartesianProduct(input [][]string) [][]string
• func CartesianProductToVariable(input [][]string) []*variable.Variable
• func Max(by []string, input []*oproto.ValueStream) []*oproto.ValueStream
• func Mean(by []string, input []*oproto.ValueStream) []*oproto.ValueStream
• func Median(by []string, input []*oproto.ValueStream) []*oproto.ValueStream
• func Min(by []string, input []*oproto.ValueStream) []*oproto.ValueStream
• func Percentile(by []string, percentile float64, input []*oproto.ValueStream) []*oproto.ValueStream
• func StdDev(by []string, input []*oproto.ValueStream) []*oproto.ValueStream
• func Sum(by []string, input []*oproto.ValueStream) []*oproto.ValueStream

Functions

func By

func By(by []string, input []*oproto.ValueStream) []*variable.Variable

func CartesianProduct

func CartesianProduct(input [][]string) [][]string

func CartesianProductToVariable

func CartesianProductToVariable(input [][]string) []*variable.Variable

func Max

func Max(by []string, input []*oproto.ValueStream) []*oproto.ValueStream

Get the maximum of all values at a common time across streams

func Mean

func Mean(by []string, input []*oproto.ValueStream) []*oproto.ValueStream

Get the mean of all values at a common time across streams

func Median

func Median(by []string, input []*oproto.ValueStream) []*oproto.ValueStream

Get the median of all values at a common time across streams

func Min

func Min(by []string, input []*oproto.ValueStream) []*oproto.ValueStream

Get the minimum of all values at a common time across streams

func Percentile

func Percentile(by []string, percentile float64, input []*oproto.ValueStream) []*oproto.ValueStream

Get a particular percentile (provided in percentile) of all values at a common time across streams

func StdDev

func StdDev(by []string, input []*oproto.ValueStream) []*oproto.ValueStream

Get the standard deviation of all values at a common time across streams

func Sum

func Sum(by []string, input []*oproto.ValueStream) []*oproto.ValueStream

Get the total of all values at a common time across streams