Go Glow 介绍
Glow 是使用 Go 编写的易用分布式计算系统，是 Hadoop Map
Reduce，Spark，Flint，Samza 等等的替代品。
Glow 的目标是提供一个库，可以在并行线程或者分布式集群机器中进行更简单计算。
安装：
go get github.com/chrislusf/glow go get github.com/chrislusf/glow/flow
简单示例：
package main
import (
"flag"
"strings"
"github.com/chrislusf/glow/flow"
)
func main() {
flag.Parse()
flow.New().TextFile(
"/etc/passwd", 3,
).Filter(func(line string) bool {
return !strings.HasPrefix(line, "#")
}).Map(func(line string, ch chan string) {
for _, token := range strings.Split(line, ":") {
ch <- token
}
}).Map(func(key string) int {
return 1
}).Reduce(func(x int, y int) int {
return x + y
}).Map(func(x int) {
println("count:", x)
}).Run()
}
Go Glow 官网
https://github.com/chrislusf/glow
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。
