api

Documentation

Index

• type Job
• type JobResult
• type MrClient
  • func NewMrClient(consulAddress string) (*MrClient, error)
  • func (c *MrClient) Submit(job Job) (*JobResult, error)

Types

type Job

type Job struct {
	Name           string
	MapTasksNum    int32
	ReduceTasksNum int32
	Input          string
	MrImplDir      string
	GoBinPath      string
}

Job describes the map reduce job.

type JobResult

type JobResult struct {
	Status   string
	Result   string
	Duration time.Duration
}

JobResult holds info about the result of the submitted job.

type MrClient

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

MrClient holds information about the gomr client.

func NewMrClient

func NewMrClient(consulAddress string) (*MrClient, error)

NewMrClient constructs the instance of MrClient.

func (*MrClient) Submit

func (c *MrClient) Submit(job Job) (*JobResult, error)

Submit submits the job to gomr framework. It blocks until the job will be done.