Copyright © 2012 Zuse Institute Berlin
Version: $Id$
Authors: Jan Fajerski (fajerski@zib.de).
client_key() = [unicode_char()]
data() = data_list() | data_ets()
data_ets() = db_ets:db()
data_list() = [{rt_chord:key(), string(), term()}]
data in ets table has the same format
delta_phase() = {PhaseNr :: pos_integer(), fun_term(), Input :: data_list(), ToWorkOn :: intervals:interval(), WorkingOn :: intervals:interval()}
erl_fun() = {map, erlanon, fun((Arg :: {client_key(), term()}) -> Res :: [{client_key(), term()}])} | {reduce, erlanon, fun((Arg :: [{client_key(), term()}]) -> Res :: [{client_key(), term()}])}
ets_phase() = {PhaseNr :: pos_integer(), fun_term(), Input :: data_ets(), ToWorkOn :: intervals:interval(), WorkingOn :: intervals:interval()}
fun_term() = erl_fun() | js_fun()
job_description() = {[fun_term(), ...], [option()]}
jobid() = [0..255, ...]
js_fun() = {map | reduce, jsanon, binary()}
option() = {tag, atom()}
phase() = ets_phase() | delta_phase()
state() = #state{jobid = jobid(), client = comm:mypid() | false, master_id = rt_chord:key(), phases = [phase(), ...], options = [option()], acked = intervals:interval()}
unicode_char() = 0..55295 | 57344..65533 | 65536..1114111
get(State :: state(), Key :: client) -> comm:mypid() | false
new(JobId :: jobid(), Client :: comm:mypid(), Master :: rt_chord:key(), InitalData :: data_list(), X5 :: job_description(), Interval :: intervals:interval()) -> state()
is_last_phase(State :: state(), Round :: pos_integer()) -> boolean()
is_acked_complete(State :: state()) -> boolean()
set_acked(State :: state(), NewInterval :: intervals:interval()) -> state()
interval_processing(State :: state(), Interval :: intervals:interval(), Round :: pos_integer()) -> state()
interval_processed(State :: state(), Interval :: intervals:interval(), Round :: pos_integer()) -> state()
interval_empty(State :: state(), Interval :: intervals:interval(), Round :: pos_integer()) -> state()
add_data_to_phase(State :: state(), NewData :: data_list(), Interval :: intervals:interval(), Round :: pos_integer()) -> state()
accumulate_data(Data :: [{client_key(), term()}], List :: data()) -> data()
clean_up(State :: state()) -> [true]
get_slide_delta(State :: state(), SlideInterval :: intervals:interval()) -> {state(), state()}
tester_is_valid_funterm(X1 :: fun_term()) -> boolean()
tester_create_valid_funterm(X1 :: erlanon | jsanon, MoR :: map | reduce) -> fun_term()
Generated by EDoc, Sep 12 2019, 16:35:03.