| pkg simplemr, method (*Identity) Map(*MR, string, interface{}) error |
| pkg simplemr, method (*Identity) Reduce(*MR, string, []interface{}) error |
| pkg simplemr, method (*MR) Cancel() |
| pkg simplemr, method (*MR) CancelCh() <-chan struct{} |
| pkg simplemr, method (*MR) Error() error |
| pkg simplemr, method (*MR) IsCancelled() bool |
| pkg simplemr, method (*MR) MapOut(string, ...interface{}) |
| pkg simplemr, method (*MR) ReduceOut(string, ...interface{}) |
| pkg simplemr, method (*MR) Run(<-chan *Record, chan<- *Record, Mapper, Reducer) error |
| pkg simplemr, type Identity struct |
| pkg simplemr, type MR struct |
| pkg simplemr, type MR struct, NumMappers int |
| pkg simplemr, type MR struct, Timeout time.Duration |
| pkg simplemr, type Mapper interface { Map } |
| pkg simplemr, type Mapper interface, Map(*MR, string, interface{}) error |
| pkg simplemr, type Record struct |
| pkg simplemr, type Record struct, Key string |
| pkg simplemr, type Record struct, Values []interface{} |
| pkg simplemr, type Reducer interface { Reduce } |
| pkg simplemr, type Reducer interface, Reduce(*MR, string, []interface{}) error |
| pkg simplemr, var ErrMRCancelled error |
