Versions in this module Expand all Collapse all v0 v0.0.4 Nov 21, 2023 v0.0.3 Nov 18, 2023 Changes in this version + func AsMap[In any, K comparable, V any](prevStage stages.Stage[In], mapFunc functions.MapFunc[In, types.Tuple[K, V]], ...) (*map[K]V, error) + func AsMultiMap[In any, K comparable, V any](prevStage stages.Stage[In], mapFunc functions.MapFunc[In, types.Tuple[K, V]], ...) (*map[K][]V, error) + func AsSlice[In any](prevStage stages.Stage[In], confs ...configs.StageConfig) (*[]In, error) + func AvgComplexType[In types.ComplexNumber](prevStage stages.Stage[In], confs ...configs.StageConfig) (*complex128, error) + func Avg[In types.Number](prevStage stages.Stage[In], confs ...configs.StageConfig) (*float64, error) + func Count[In any](prevStage stages.Stage[In], confs ...configs.StageConfig) (*int64, error) + func DistinctCount[In comparable](prevStage stages.Stage[In], confs ...configs.StageConfig) (*int64, error) + func Distinct[In comparable](prevStage stages.Stage[In], confs ...configs.StageConfig) (*[]In, error) + func ForEach[In any](prevStage stages.Stage[In], forEachFunc functions.ForEachFunc[In], ...) error + func GroupBy[In any, K comparable](prevStage stages.Stage[In], groupByFunc functions.MapFunc[In, K], ...) (*map[K][]In, error) + func Max[In types.Number](prevStage stages.Stage[In], confs ...configs.StageConfig) (*In, error) + func Min[In types.Number](prevStage stages.Stage[In], confs ...configs.StageConfig) (*In, error) + func Reduce[In any](prevStage stages.Stage[In], reduceFunc functions.ReduceFunc[In], ...) (*In, error) + func SortDesc[In cmp.Ordered](prevStage stages.Stage[In], confs ...configs.StageConfig) (*[]In, error) + func Sort[In cmp.Ordered](prevStage stages.Stage[In], confs ...configs.StageConfig) (*[]In, error) + func SumComplexType[In types.ComplexNumber](prevStage stages.Stage[In], confs ...configs.StageConfig) (*In, error) + func Sum[In types.Number](prevStage stages.Stage[In], confs ...configs.StageConfig) (*In, error)