mr

package
v0.0.0-...-72d728a Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 15, 2020 License: BSD-2-Clause Imports: 1 Imported by: 0

README

mr GoDoc

Toy implementation of MapReduce.

Installation

% go get github.com/davidrjenni/lib/mr

Documentation

Overview

Package mr implements MapReduce using Go channels and Go routines.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Run

func Run(j Job, input []string) chan Tuple

Run runs a MapReduce job on the given input.

Types

type Job

type Job interface {
	Map(key, value string, out chan<- Tuple)
	Reduce(key string, values []string, out chan<- Tuple)
}

Job represents a MapReduce job.

type Tuple

type Tuple struct {
	First, Second string
}

Tuple holds two strings.

Directories

Path Synopsis
Command wc implements word count as MapReduce job.
Command wc implements word count as MapReduce job.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL