Module mr

Map Reduce functions this is part of the dht node.

Copyright © 2007-2013 Zuse Institute Berlin

Version: $Id$

Authors: Jan Fajerski (fajerski@informatik.hu-berlin.de).

Description

Map Reduce functions this is part of the dht node

Data Types

bulk_message()

bulk_message() = {mr,
                  job,
                  mr_state:jobid(),
                  MasterId :: rt_chord:key(),
                  Client :: comm:mypid(),
                  mr_state:job_description(),
                  mr_state:data()}
               | {mr,
                  next_phase_data,
                  mr_state:jobid(),
                  comm:mypid(),
                  mr_state:data()}

message()

message() = {bulk_distribute,
             uid:global_uid(),
             intervals:interval(),
             bulk_message(),
             Parents :: [comm:mypid(), ...]}
          | {mr,
             phase_results,
             mr_state:jobid(),
             comm:message(),
             intervals:interval()}
          | {mr,
             next_phase_data_ack,
             {mr_state:jobid(),
              reference(),
              intervals:interval()},
             intervals:interval()}
          | {mr, next_phase, mr_state:jobid()}
          | {mr, terminate_job, mr_state:jobid()}

Function Index

neighborhood_succ_crash/5
neighborhood_succ_crash_filter/3
on/2
work_on_phase/3

Function Details

on/2

on(Msg :: message(), State :: dht_node_state:state()) ->
      dht_node_state:state()

work_on_phase/3

work_on_phase(JobId :: mr_state:jobid(),
              State :: mr_state:state(),
              Round :: pos_integer()) ->
                 mr_state:state()

neighborhood_succ_crash_filter/3

neighborhood_succ_crash_filter(Old :: nodelist:neighborhood(),
                               New :: nodelist:neighborhood(),
                               X3 :: rm_loop:reason()) ->
                                  boolean()

neighborhood_succ_crash/5

neighborhood_succ_crash(Pid :: comm:mypid(),
                        X2 ::
                            {string(),
                             mr_state:jobid(),
                             rt_chord:key(),
                             comm:mypid()},
                        Old :: nodelist:neighborhood(),
                        New :: nodelist:neighborhood(),
                        Reason :: rm_loop:reason()) ->
                           ok


Generated by EDoc, Sep 12 2019, 16:35:08.