Documentation ¶
Index ¶
Constants ¶
View Source
const ( MapPhase JobPhase = 1 ReducePhase = 2 TmpFilePrefix = "mr-" FilePerm = 0755 )
View Source
const ( TeraGenNumber = 8 << 20 TerasortMapTaskNum = 10 TerasortReduceTaskNum = 10 StringLength = 8 - 1 )
system config
View Source
const (
DefaultBufferSize = 16 << 20
)
View Source
const (
WorkerChanSize = 200
)
Variables ¶
This section is empty.
Functions ¶
Types ¶
type DoTaskReply ¶
type DoTaskReply struct { }
type FileBuffer ¶
type FileBuffer struct {
// contains filtered or unexported fields
}
buffered IO
func NewFileBuffer ¶
func NewFileBuffer(filename string, align, size int) (*FileBuffer, error)
func (*FileBuffer) Destroy ¶
func (fb *FileBuffer) Destroy()
func (*FileBuffer) Get ¶
func (fb *FileBuffer) Get() ([]byte, error)
type Master ¶
type Master struct {
// contains filtered or unexported fields
}
func (*Master) RPCRegisterWorker ¶
func (m *Master) RPCRegisterWorker(args RegisterWorkerArg, reply *RegisterWorkerReply) error
type RegisterWorkerArg ¶
type RegisterWorkerArg struct {
Address string
}
type RegisterWorkerReply ¶
type RegisterWorkerReply struct { }
type SetConfigArg ¶
type SetConfigReply ¶
type SetConfigReply struct { }
type Worker ¶
type Worker struct {
// contains filtered or unexported fields
}
func (*Worker) RPCDoTask ¶
func (wk *Worker) RPCDoTask(args DoTaskArg, reply *DoTaskReply) error
do map task or do reduce task
func (*Worker) RPCSetConfig ¶
func (wk *Worker) RPCSetConfig(args SetConfigArg, reply *SetConfigReply) error
Click to show internal directories.
Click to hide internal directories.