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

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

Description

Version : 0.1

Documentation

data MapReduceType Source

Constructors MRTMaster MRTWorker MRTClient MRTStandalone Instances Enum MapReduceType Eq MapReduceType Ord MapReduceType Show MapReduceType

class Debug mr => MapReduce mr where Source

Methods closeMapReduce :: mr -> IO () Source getMySiteId :: mr -> IO SiteId Source prints the siteId of the MapReduce instance getMapReduceType :: mr -> IO MapReduceType Source 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 Bool Source test, if Controller is running doSingleStep :: mr -> IO () Source performs a single step of the controller (if mode is singlestep) doMapReduceJob :: JobInfo -> mr -> IO JobResult Source starts a MapReduce-Job (blocking while finished) doMapReduce Source :: 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]) Instances MapReduce MasterPort MapReduce MasterData MapReduce SMapReduce MapReduce DMapReduce

Produced by Haddock version 2.6.1