mapreduce

Documentation

Index

• func Main(mr MapReduceJob, options *Options)
• type MapReduce
  • func (mr *MapReduce) Emit(emitter dmrgo.Emitter, key, value interface{})
  • func (mr *MapReduce) Init(options *Options)
  • func (mr *MapReduce) Unmarshal(key string, values []string, outKey, outVal interface{})
• type MapReduceJob
• type Options

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
}