mapred

Documentation

Index

• type Listen
• type Open
• type Process
  • func New(parent, graphType, graphName string, conf []byte, def *graph.Definition, ...) *Process
  • func (p *Process) Run() error
  • func (p *Process) SetRing(r *schedule.Ring)
  • func (p *Process) Stop()
  • func (p *Process) String() string
• type Send

Types

type Listen

type Listen func(name string) (<-chan grid.Request, func() error, error)

type Open

type Open func(name string) (*storage.DB, error)

type Process

type Process struct {
	// contains filtered or unexported fields
}

Process for mapping and reducing.

func New

func New(parent, graphType, graphName string, conf []byte, def *graph.Definition, o Open, s Send, l Listen) *Process

New map and reduce process.

func (*Process) Run

func (p *Process) Run() error

Run process.

func (*Process) SetRing

func (p *Process) SetRing(r *schedule.Ring)

func (*Process) Stop

func (p *Process) Stop()

Stop mapping, reducing and triggering.

func (*Process) String

func (p *Process) String() string

String description of process.

type Send

type Send func(timeout time.Duration, receiver string, msg interface{}) (interface{}, error)