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

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

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 11 2020, 15:25:28.