| Portability | portable |
|---|---|
| Stability | experimental |
| Maintainer | Stefan Schmidt (stefanschmidt@web.de) |
Holumbus.MapReduce.JobController
Description
Version : 0.1
- 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 |
type TaskSendFunction = TaskData -> IO TaskSendResultSource
type JobController = MVar JobControllerDataSource
Creation and Destruction
Job Controller
performing MapReduce-Jobs
performJob :: JobInfo -> JobController -> IO JobResultSource
handling Task-Responses
setTaskCompleted :: JobController -> TaskData -> IO ()Source
setTaskError :: JobController -> TaskData -> IO ()Source