[M      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~ portable experimental%Stefan Schmidt (stefanschmidt@web.de)MapAction on ByteStrings general MapAction MapAction on ByteStrings general MapAction SplitAction on ByteStrings  general SplitAction 3=the ActionEnvironment contains all data that might be needed E during an action. So far, it only keeps the current task data and : a reference to the global filesystem and the options. I This is a good place to implement counters for the map-reduce-system  or other stuff... 7+the result of the job, given by the master <Fthe job data, include the user-input and some additional control-data EBdefines a job, this is all data the user has to give to run a job Uthe job state _,the job id (should be unique in the system) `6the TaskData, contains all information to do the task othe task state v"which type (map, combine, reduce) |-the task id (should be unique in the system)   !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~}~|v{zyxwoutsrqplnm`abcdefghijk_U^]\[ZYXWVTOPQRSEFGHIJKLMN<=>?@ABCD:;7890/345621#$%&'()*+,-. !"     !" !"# $%&'()*+,-.$%&'()*+,-./012345645678989:;;<=>?@ABCD=>?@ABCDE FGHIJKLMNFGHIJKLMNOPQRSPQRSTU ^]\[ZYXWVVWXYZ[\]^_` abcdefghijkabcdefghijklnmmnoutsrqppqrstuv{zyxwwxyz{|}~~portable experimental%Stefan Schmidt (stefanschmidt@web.de)  6data, needed by the MapReduce-System to run the tasks a function for responding a creates a new TaskProcessor /add a filesystem-instance to the TaskProcessor 'adds an ActionMap to the TaskProcessor 2Lists all Actions with Name, Descrition and so on Lists all Names of the Actions ?adds a Task to the TaskProcessor, the execution might be later  5mark the task as error and invoke the reply function  9mark the task as completed and invoke the reply function  doing a map task portable experimental%Stefan Schmidt (stefanschmidt@web.de)Iget the JobIds, they can be filtered by JobState, if the filter is empty  all Jobs are returned. Kget the TaskIds, they can be filtered by JobId, TaskType and TaskState, if ? a filter is empty, this attribute is not taken into account 2adds a Job to the JobControllerData for execution newState oldState the send task doesn'0t block, because a timeout causes the whole job  controller to pause, we don' t want this portable experimental%Stefan Schmidt (stefanschmidt@web.de)-prints the siteId of the MapReduce instance 'get the Type of the MapReduce instance Jget the Controlling-Type (normal or singlestep) of the MapReduce instance Jget the Controlling-Type (normal or singlestep) of the MapReduce instance test, if Controller is running Aperforms a single step of the controller (if mode is singlestep) 1starts a MapReduce-Job (blocking while finished)  portable experimental%Stefan Schmidt (stefanschmidt@web.de)Lruns the user interface... just add an fileSystem an a fancy version-number portable experimental%Stefan Schmidt (stefanschmidt@web.de)portable experimental%Stefan Schmidt (stefanschmidt@web.de)portable experimental%Stefan Schmidt (stefanschmidt@web.de) portable experimental%Stefan Schmidt (stefanschmidt@web.de) portable experimental%Stefan Schmidt (stefanschmidt@web.de)Creates a new NodePort.  portable experimental%Stefan Schmidt (stefanschmidt@web.de) portable experimental%Stefan Schmidt (stefanschmidt@web.de)Creates a new ControllerPort  portable experimental%Stefan Schmidt (stefanschmidt@web.de)portable experimental%Stefan Schmidt (stefanschmidt@web.de) !"#$%%&'()**+,-../0123456789:;<==>?@@ABBCCDEFGHIJKKLMNOPQRSTTUVWXYZ[\]^_`abcddefghijklmnopqrstuvwxyz{|}~                                     Holumbus-MapReduce-0.0.1Holumbus.MapReduce.Types Holumbus.MapReduce.TaskProcessor Holumbus.MapReduce.JobControllerHolumbus.MapReduce.MapReduce Holumbus.MapReduce.UserInterfaceHolumbus.Standalone.SMapReduceHolumbus.Distribution.MasterHolumbus.Distribution.WorkerHolumbus.Distribution.Messages'Holumbus.Distribution.Worker.WorkerPort'Holumbus.Distribution.Master.MasterData'Holumbus.Distribution.Master.MasterPort'Holumbus.Distribution.Worker.WorkerData Holumbus.Distribution.DMapReduceReducePartitionReduceFunction ReduceMerge ReduceAction MapPartition MapFunction MapActionOptionsDecoder ActionMap ActionDataad_Namead_Infoad_Splitad_Map ad_Combine ad_ReduceReduceConfigurationrc_Merge rc_Function rc_Partition rc_Reader rc_WriterMapConfiguration mc_Function mc_Partition mc_Reader mc_WriterSplitConfiguration sc_Function sc_Reader sc_WriterActionConfigurationac_Nameac_Info ac_OptEncoder ac_OptDecoderac_InputEncoderac_OutputDecoderac_Splitac_Map ac_Combine ac_Reduce ActionInfo ActionName OutputWriter InputReaderActionEnvironment ae_TaskData ae_FileSystem JobResult jr_OutputJobResultContainerJobDatajd_JobIdjd_State jd_OutputMapjd_Info jd_startTime jd_endTime jd_ResultJobInfoji_Description ji_Optionji_SplitAction ji_MapActionji_CombineActionji_ReduceActionji_NumOfResultsji_Input JobActionja_Name ja_Outputja_Count OutputMapJobStateJSError JSFinished JSCompletedJSReduce JSCombineJSMapJSSplitJSIdle JSPlannedJobIdTaskDatatd_JobId td_TaskIdtd_Typetd_State td_Option td_PartValuetd_Input td_Output td_OutputType td_ActionTaskOutputTypeTOTFile TOTRawTuple TaskStateTSError TSFinished TSCompleted TSInProgress TSSendingTSIdleTaskTypeTTErrorTTReduce TTCombineTTMapTTSplitTaskId FunctionDataFileFunctionDataTupleFunctionDatagetNextTaskStategetNextJobStategetPrevJobStatefromJobStatetoTaskTypemkActionEnvironmentdefaultActionConfigurationdefaultSplitConfigurationdefaultMapConfigurationdefaultReduceConfigurationgetActionForTaskTypereadActionConfigurationcreateJobInfoFromConfigurationcreateListsFromJobResult TaskProcessorTaskResultFunctionprintTaskProcessornewTaskProcessorcloseTaskProcessorsetFileSystemToTaskProcessor setActionMapsetTaskCompletedHooksetTaskErrorHookstartTaskProcessorstopTaskProcessor listTaskIds getActionsgetActionNames startTaskstopTask stopAllTasks JobControllerTaskSendFunctionTaskSendResultTSRError TSRNotSendTSRSendprintJobControllernewJobControllercloseJobControllersetFileSystemToJobControllersetTaskSendHookstartJobControllerstopJobControllerisJobControllerRunningsingleStepJobControlling performJobsetTaskCompleted setTaskError MapReducecloseMapReduce getMySiteIdgetMapReduceTypestartControllingstopControlling isControlling doSingleStepdoMapReduceJob doMapReduce MapReduceType MRTStandalone MRTClient MRTWorker MRTMasterrunUISMRConf SMapReducedefaultStandaloneConfig newSMapReduce MasterClass closeMasterreceiveTaskCompletedreceiveTaskError WorkerClass closeWorkerWorkerResponseMessage WRspUnknown WRspErrorWRspGetActionNames WRspSuccessWorkerRequestMessage WReqUnknownWReqGetActionNamesWReqStopAllTasks WReqStopTask WReqStartTaskMasterResponseMessage MRspUnknown MRspError MRspResultMRspIsControlling MRspSuccessMasterRequestMessage MReqUnknownMReqPerformJobMReqSingleStepMReqIsControllingMReqStopControllingMReqStartControlling MReqTaskErrorMReqTaskCompletedWorkerId WorkerPort newWorkerPort MasterData newMaster MasterPort newMasterPortnewMasterPortFromServerPort WorkerData newWorker DMRClientConfclc_StreamName clc_SocketId DMRWorkerConfwoc_StreamName woc_SocketId DMRMasterConfmsc_StartControllingmsc_StreamNamemsc_PortNumber DMapReducedefaultMRMasterConfigdefaultMRWorkerConfigdefaultMRClientConfigmkMapReduceMastermkMapReduceWorkermkMapReduceClientBinaryReduceActionBinaryMapActionBinarySplitAction SplitActionTaskProcessorDatareportErrorTaskreportCompletedTask performTask getJobIds getTaskIdsaddJobisChangeTaskStateAllowedsendTaskHolumbus-Distribution-0.0.1.1Holumbus.Network.MessagesperformPortAction