gomr:Golang的MapReduce框架

时间:2021-05-24 13:59:56
【文件属性】:
文件名称:gomr:Golang的MapReduce框架
文件大小:29KB
文件格式:ZIP
更新时间:2021-05-24 13:59:56
Go 核磁共振 GoMR是用于Go的超快速,超级简单,易于调试的mapreduce框架。 编写部署Mapreduce作业而无需处理JVM,进行调试,提高性能并在Go!中编写代码的目的! 一个例子 有关规范的单词计数mapreduce程序,请参见examples/wordcount/parallel 。 要构建,将cd进入目录并运行go build 。 然后,使用./parallel 运行。 入门 要为GoMR编写作业,我们首先需要创建和满足gomr.go找到的接口的对象。 即: type Mapper interface { Map ( in <- chan interface {}, out chan <- interface {}) } type Partitioner interface { Partition ( in <- chan interface {}
【文件预览】:
gomr-master
----.gitignore(29B)
----gomr.go(507B)
----pkg()
--------driver()
----net.go(2KB)
----input.go(2KB)
----examples()
--------count2cycles()
--------pagerank()
--------wordcount()
--------count2path()
--------count-triangles-dist()
--------wordcount-eval()
--------count-triangles()
--------wordcount-dist()
--------edge()
--------identity()
----README.md(1KB)
----chain.go(310B)
----distributed.go(3KB)
----local.go(3KB)
----DESIGN.md(472B)
----cmd()
--------gomr-genk8s()

网友评论