Versions in this module Expand all Collapse all v0 v0.8.5 Jul 1, 2015 v0.8.4 Jul 1, 2015 Changes in this version + func Map(job Job, jobName string, m materializeInfo, shard, modulos uint64) + func Materialize(in_repo, branch, commit, outRepo, jobDir string, shard, modulos uint64) error + func PrepJob(job Job, jobName string, m materializeInfo) error + func Reduce(job Job, jobName string, m materializeInfo, shard, modulos uint64) + func WaitJob(outRepo, branch, commit, job string) error + type Job struct + Cmd []string + CpuShares int + Image string + Input string + Limit int + Memory int + Parallel int + TimeOut int + Type string + type Proto int + const ProtoPfs + const ProtoS3
Go to main page