Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/dgryski/dmrgo
/ types & classes
Types & classes
12 in github.com/dgryski/dmrgo
⨍
Functions
40
◇
Types & classes
12
Interface
Emitter
Emitter emits key/value pairs
emitter.go:15
Struct
JSONProtocol
JSONProtocol parse input/output values as JSON strings
proto.go:29
Struct
KeyValue
KeyValue is the primary type for interacting with Hadoop.
runners.go:19
Struct
MRWordCount
examples/wordcount.go:48
Interface
MapReduceJob
MapReduceJob is the interface expected by the job runner
runners.go:52
Interface
StreamProtocol
StreamProtocol is a set of routines for marshaling and unmarshaling key/value pairs from the input stream. Map Reduce jobs can define their own protoc
proto.go:17
Struct
TSVProtocol
TSVProtocol outputs keys as tab-separated lines
proto.go:63
Struct
WordCountProto
As example, just to show we can write our own custom protocols
examples/wordcount.go:19
Struct
mapperFile
runners.go:109
Struct
nullEmitter
data sink -- useful for benchmarking
emitter.go:50
Struct
partitionEmitter
emitter.go:41
Struct
printEmitter
emitter.go:20