Portability | portable |
---|---|
Stability | experimental |
Maintainer | Stefan Schmidt (stefanschmidt@web.de) |
Version : 0.1
- data SMapReduce
- class Debug mr => MapReduce mr where
- closeMapReduce :: mr -> IO ()
- getMySiteId :: mr -> IO SiteId
- getMapReduceType :: mr -> IO MapReduceType
- startControlling :: mr -> IO ()
- stopControlling :: mr -> IO ()
- isControlling :: mr -> IO Bool
- doSingleStep :: mr -> IO ()
- doMapReduceJob :: JobInfo -> mr -> IO JobResult
- doMapReduce :: ActionConfiguration a k1 v1 k2 v2 v3 v4 -> a -> [(k1, v1)] -> [FileId] -> Int -> Int -> Int -> Int -> TaskOutputType -> mr -> IO ([(k2, v4)], [FileId])
- data SMRConf
- defaultStandaloneConfig :: SMRConf
- newSMapReduce :: FileSystem -> ActionMap -> SMRConf -> IO SMapReduce
Datatypes
class Debug mr => MapReduce mr whereSource
closeMapReduce :: mr -> IO ()Source
getMySiteId :: mr -> IO SiteIdSource
prints the siteId of the MapReduce instance
getMapReduceType :: mr -> IO MapReduceTypeSource
get the Type of the MapReduce instance
startControlling :: mr -> IO ()Source
get the Controlling-Type (normal or singlestep) of the MapReduce instance
stopControlling :: mr -> IO ()Source
get the Controlling-Type (normal or singlestep) of the MapReduce instance
isControlling :: mr -> IO BoolSource
test, if Controller is running
doSingleStep :: mr -> IO ()Source
performs a single step of the controller (if mode is singlestep)
doMapReduceJob :: JobInfo -> mr -> IO JobResultSource
starts a MapReduce-Job (blocking while finished)
:: ActionConfiguration a k1 v1 k2 v2 v3 v4 | |
-> a | options |
-> [(k1, v1)] | input (Tuples) |
-> [FileId] | input (Files) |
-> Int | number of splitters |
-> Int | number of mappers |
-> Int | number of reducers |
-> Int | number of results |
-> TaskOutputType | type of the result (file of raw) |
-> mr | |
-> IO ([(k2, v4)], [FileId]) |
Configurations
Creation and Initialisation
newSMapReduce :: FileSystem -> ActionMap -> SMRConf -> IO SMapReduceSource