Functions — github.com/dgryski/dmrgo

CodeHub MCPcopy Create free account

hub / github.com/dgryski/dmrgo / functions

Functions40 in github.com/dgryski/dmrgo

⨍ Functions 40 ◇ Types & classes 12

↓ 7 callersMethodFlush

↓ 5 callersMethodClose

↓ 4 callersFunctionprimitiveToString

(v reflect.Value)

↓ 3 callersMethodEmit

(key string, value string)

↓ 3 callersFunctionmapper

run the mapping phase, calling the map routine on key/value pairs from the Reader The users' Map routine will write any key/value pairs generated to t

↓ 3 callersFunctionmapperFinal

run the cleanup phase for the mapper

↓ 3 callersFunctionnewPartitionEmitter

(partitions uint, template string)

↓ 3 callersFunctionnewPrintEmitter

(w *bufio.Writer)

↓ 2 callersMethodMap

(key string, value string, emitter Emitter)

↓ 2 callersMethodMarshalKV

MarshalKV turns a key/value pair into a KeyValue

↓ 2 callersMethodReduce

(key string, values []string, emitter Emitter)

↓ 2 callersFunctionisPrimitive

(k reflect.Kind)

↓ 2 callersFunctionreducer

run the reduce phase, calling the reduce routine on key/[]value read the Reader. We aggregate the values that have been mapped with the same key, then

↓ 1 callersMethodMapFinal

Called at the end of the Map phase

↓ 1 callersFunctionNewWordCount

(proto dmrgo.StreamProtocol)

examples/wordcount.go:55

↓ 1 callersMethodUnmarshalKVs

UnmarshalKV turns strings into their associated values. k should be a pointer to the destination value for the unmarshalled "key" vs should be a point

↓ 1 callersFunctionmapreduce

(mrjob MapReduceJob)

↓ 1 callersFunctionreadLineKeyValue

(br *bufio.Reader)

↓ 1 callersFunctionreadLineValue

(br *bufio.Reader)

(key string, value string)

(key string, value string)

(key string, value string)

FunctionIncrCounter

IncrCounter updates the given group/counter by 'amount'

Main runs the map reduce job passed in

(key string, value string, emitter dmrgo.Emitter)

examples/wordcount.go:63

(emitter dmrgo.Emitter)

examples/wordcount.go:89

MethodMarshalKV

MarshalKV implements the StreamProtocol interface

MethodMarshalKV

MarshalKV implements the StreamProtocol interface

MethodMarshalKV

(key interface{}, value interface{})

examples/wordcount.go:37

(key string, values []string, emitter dmrgo.Emitter)

examples/wordcount.go:94

FunctionStatusf

Statusf updates the Hadoop job status. The arguments are passed to fmt.Sprintf

FunctionStatusln

Statusln updates the Hadoop job status. The arguments are passed to fmt.Sprintln

MethodUnmarshalKVs

UnmarshalKVs implements the StreamProtocol interface

MethodUnmarshalKVs

UnmarshalKVs implements the StreamProtocol interface

MethodUnmarshalKVs

(key string, values []string, k interface{}, vs interface{})

examples/wordcount.go:21

examples/wordcount.go:110