mapreduce

package
v0.0.0-...-6217932 Latest Latest
Warning

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

Go to latest
Published: Oct 31, 2016 License: GPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Main

func Main(mr MapReduceJob, options *Options)

Types

type MapReduce

type MapReduce struct {
	Db      services.Database
	Session services.Session
	Index   services.Index
	Storage services.Storage
	Task    services.TaskClient
	// contains filtered or unexported fields
}

func (*MapReduce) Emit

func (mr *MapReduce) Emit(emitter dmrgo.Emitter, key, value interface{})

func (*MapReduce) Init

func (mr *MapReduce) Init(options *Options)

func (*MapReduce) Unmarshal

func (mr *MapReduce) Unmarshal(key string, values []string, outKey, outVal interface{})

type MapReduceJob

type MapReduceJob interface {
	dmrgo.MapReduceJob

	Init(*Options)
}

type Options

type Options struct {
	NoDatabase    bool
	NoSession     bool
	HasIndex      bool
	HasStorage    bool
	HasTaskClient bool
}

Directories

Path Synopsis
Cleanup completed jobs.
Cleanup completed jobs.
Compute metadata statistics for the song database.
Compute metadata statistics for the song database.
Verifies that the index contents match what's stored in the database.
Verifies that the index contents match what's stored in the database.

Jump to

Keyboard shortcuts

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