mapreduce

package

v0.1.2 Latest Latest Go to latest Published: Nov 8, 2023 License: MIT Imports: 4 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrCancelWithNil  = errors.New("mapreduce cancelled with nil")
	ErrReduceNoOutput = errors.New("reduce not writing value")
)

func MapReduce[T, U, V any](gen GenerateFunc[T], mapper MapperFunc[T, U], reducer ReducerFunc[U, V], opts ...Option) (V, error)

type GenerateFunc[T any] func(source chan<- T)

GenerateFunc 执行生成的函数

type MapFunc[T, U any] func(item T, writer Writer[U])

MapFunc Map的具体方法函数

type MapperFunc[T, U any] func(item T, writer Writer[U], cancel func(err error))

MapperFunc 执行map的函数

type Option func(opts *mapReduceOptions)

Option 可选择的选择

type ReduceFunc[T, U any] func(item T, writer Writer[U])

ReduceFunc Reduce的具体函数方法

type ReducerFunc[U, V any] func(pipe <-chan U, writer Writer[V], cancel func(err error))

ReducerFunc 执行reduce的函数

type Writer[T any] interface {
	Write(v T)
}