Holumbus-MapReduce-0.1.0: a distributed MapReduce framework Source code Contents Index

Holumbus.MapReduce.JobController Portability portable Stability experimental Maintainer Stefan Schmidt (stefanschmidt@web.de)

Contents Creation and Destruction Job Controller performing MapReduce-Jobs handling Task-Responses

Description

Version : 0.1

Synopsis

data TaskSendResult = TSRSend | TSRNotSend | TSRError type TaskSendFunction = TaskData -> IO TaskSendResult type JobController = MVar JobControllerData printJobController :: JobController -> IO String newJobController :: IO JobController closeJobController :: JobController -> IO () setFileSystemToJobController :: FileSystem -> JobController -> IO () setTaskSendHook :: TaskSendFunction -> JobController -> IO () startJobController :: JobController -> IO () stopJobController :: JobController -> IO () isJobControllerRunning :: JobController -> IO Bool singleStepJobControlling :: JobController -> IO () performJob :: JobInfo -> JobController -> IO JobResult setTaskCompleted :: JobController -> TaskData -> IO () setTaskError :: JobController -> TaskData -> IO ()

Documentation

data TaskSendResult Source

Constructors TSRSend TSRNotSend TSRError Instances Enum TaskSendResult Eq TaskSendResult Ord TaskSendResult Show TaskSendResult

type TaskSendFunction = TaskData -> IO TaskSendResult Source

type JobController = MVar JobControllerData Source

printJobController :: JobController -> IO String Source

Creation and Destruction

newJobController :: IO JobController Source

closeJobController :: JobController -> IO () Source

setFileSystemToJobController :: FileSystem -> JobController -> IO () Source

setTaskSendHook :: TaskSendFunction -> JobController -> IO () Source

Job Controller

startJobController :: JobController -> IO () Source

stopJobController :: JobController -> IO () Source

isJobControllerRunning :: JobController -> IO Bool Source

singleStepJobControlling :: JobController -> IO () Source

performing MapReduce-Jobs

performJob :: JobInfo -> JobController -> IO JobResult Source

handling Task-Responses

setTaskCompleted :: JobController -> TaskData -> IO () Source

setTaskError :: JobController -> TaskData -> IO () Source

Produced by Haddock version 2.6.1