stats

Documentation

Index

• func ApproximateQuantiles[T any](s beam.Scope, c gleam.PCollection[T], less func(a, b T) bool, opt stats.Opts) gleam.PCollection[T]
• func ApproximateWeightedQuantiles[T any](s beam.Scope, c gleam.PCollection[T], less func(a, b T) bool, opt stats.Opts) gleam.PCollection[T]
• func Count[T any](s beam.Scope, c gleam.PCollection[T]) gleam.PCollection[gleam.KV[T, int]]
• func CountElms[T any](s beam.Scope, c gleam.PCollection[T]) gleam.PCollection[int]
• func Max[T Numeric](s beam.Scope, c gleam.PCollection[T]) gleam.PCollection[T]
• func MaxPerKey[A Numeric, B any](s beam.Scope, c gleam.PCollection[gleam.KV[A, B]]) gleam.PCollection[gleam.KV[A, B]]
• func Mean[T Numeric](s beam.Scope, c gleam.PCollection[T]) gleam.PCollection[T]
• func MeanPerKey[A Numeric, B any](s beam.Scope, c gleam.PCollection[gleam.KV[A, B]]) gleam.PCollection[gleam.KV[A, B]]
• func Min[T Numeric](s beam.Scope, c gleam.PCollection[T]) gleam.PCollection[T]
• func MinPerKey[A Numeric, B any](s beam.Scope, c gleam.PCollection[gleam.KV[A, B]]) gleam.PCollection[gleam.KV[A, B]]
• func Sum[T Numeric](s beam.Scope, c gleam.PCollection[T]) gleam.PCollection[T]
• func SumPerKey[A Numeric, B any](s beam.Scope, c gleam.PCollection[gleam.KV[A, B]]) gleam.PCollection[gleam.KV[A, B]]
• type Numeric

Functions

func ApproximateQuantiles

func ApproximateQuantiles[T any](s beam.Scope, c gleam.PCollection[T], less func(a, b T) bool, opt stats.Opts) gleam.PCollection[T]

func ApproximateWeightedQuantiles

func ApproximateWeightedQuantiles[T any](s beam.Scope, c gleam.PCollection[T], less func(a, b T) bool, opt stats.Opts) gleam.PCollection[T]

func Count

func Count[T any](s beam.Scope, c gleam.PCollection[T]) gleam.PCollection[gleam.KV[T, int]]

func CountElms

func CountElms[T any](s beam.Scope, c gleam.PCollection[T]) gleam.PCollection[int]

func Max

func Max[T Numeric](s beam.Scope, c gleam.PCollection[T]) gleam.PCollection[T]

func MaxPerKey

func MaxPerKey[A Numeric, B any](s beam.Scope, c gleam.PCollection[gleam.KV[A, B]]) gleam.PCollection[gleam.KV[A, B]]

func Mean

func Mean[T Numeric](s beam.Scope, c gleam.PCollection[T]) gleam.PCollection[T]

func MeanPerKey

func MeanPerKey[A Numeric, B any](s beam.Scope, c gleam.PCollection[gleam.KV[A, B]]) gleam.PCollection[gleam.KV[A, B]]

func Min

func Min[T Numeric](s beam.Scope, c gleam.PCollection[T]) gleam.PCollection[T]

func MinPerKey

func MinPerKey[A Numeric, B any](s beam.Scope, c gleam.PCollection[gleam.KV[A, B]]) gleam.PCollection[gleam.KV[A, B]]

func Sum

func Sum[T Numeric](s beam.Scope, c gleam.PCollection[T]) gleam.PCollection[T]

func SumPerKey

func SumPerKey[A Numeric, B any](s beam.Scope, c gleam.PCollection[gleam.KV[A, B]]) gleam.PCollection[gleam.KV[A, B]]

Types

type Numeric

type Numeric interface {
	constraints.Integer | constraints.Float
}