{ 
[A,C:Type]. 
[n:
]. 
[B:
n + 2 
 Type].
  
[ds:k:
n + 2 
 dataflow(A;bag(B[k]))]. 
[F:k:
n + 2 
 bag(B[k]) 
 C].
    (better-parallel-dataflow(
     n + 2;ds;
     F)
    = better-parallel-dataflow(
      n + 1;
k.if (k =
 0)
               then better-parallel-dataflow(
                    2;ds;
                    
s.bag-merge(s 0;s 1))
               else ds (k + 1)
               fi
      
g.(F 
          (
k.if (k =
 0) then fst(bag-separate(g 0))
              if (k =
 1) then snd(bag-separate(g 0))
              else g (k - 1)
              fi )))) }
{ Proof }
Definitions occuring in Statement : 
better-parallel-dataflow: better-parallel-dataflow, 
dataflow: dataflow(A;B), 
eq_int: (i =
 j), 
ifthenelse: if b then t else f fi , 
int_seg: {i..j
}, 
nat:
, 
uall:
[x:A]. B[x], 
so_apply: x[s], 
pi1: fst(t), 
pi2: snd(t), 
apply: f a, 
lambda:
x.A[x], 
function: x:A 
 B[x], 
subtract: n - m, 
add: n + m, 
natural_number: $n, 
universe: Type, 
equal: s = t
Definitions : 
pair: <a, b>, 
fpf: a:A fp-> B[a], 
strong-subtype: strong-subtype(A;B), 
ge: i 
 j , 
less_than: a < b, 
uimplies: b supposing a, 
product: x:A 
 B[x], 
and: P 
 Q, 
uiff: uiff(P;Q), 
subtype_rel: A 
r B, 
implies: P 
 Q, 
false: False, 
not:
A, 
le: A 
 B, 
limited-type: LimitedType, 
prop:
, 
parallel-dataflow: parallel-dataflow, 
set: {x:A| B[x]} , 
real:
, 
grp_car: |g|, 
subtype: S 
 T, 
all:
x:A. B[x], 
int:
, 
axiom: Ax, 
subtract: n - m, 
pi2: snd(t), 
bag-separate: Error :bag-separate, 
pi1: fst(t), 
bag-merge: Error :bag-merge, 
eq_int: (i =
 j), 
ifthenelse: if b then t else f fi , 
lambda:
x.A[x], 
natural_number: $n, 
add: n + m, 
better-parallel-dataflow: better-parallel-dataflow, 
member: t 
 T, 
nat:
, 
universe: Type, 
isect:
x:A. B[x], 
uall:
[x:A]. B[x], 
so_lambda: 
x.t[x], 
equal: s = t, 
bag: Error :bag, 
so_apply: x[s], 
apply: f a, 
int_seg: {i..j
}, 
function: x:A 
 B[x], 
dataflow: dataflow(A;B), 
Auto: Error :Auto, 
CollapseTHEN: Error :CollapseTHEN, 
RepeatFor: Error :RepeatFor, 
upto: upto(n), 
map: map(f;as), 
top: Top, 
sqequal: s ~ t, 
data-stream: data-stream(P;L), 
list: type List, 
void: Void, 
rationals:
, 
true: True, 
squash:
T, 
deq: EqDecider(T), 
ma-state: State(ds), 
fpf-cap: f(x)?z, 
minus: -n, 
refl: Refl(T;x,y.E[x; y]), 
sym: Sym(T;x,y.E[x; y]), 
trans: Trans(T;x,y.E[x; y]), 
equiv_rel: EquivRel(T;x,y.E[x; y]), 
so_lambda: 
x y.t[x; y], 
filter: filter(P;l), 
permutation: permutation(T;L1;L2), 
sq_type: SQType(T), 
sq_stable: SqStable(P), 
IdLnk: IdLnk, 
Id: Id, 
append: as @ bs, 
locl: locl(a), 
Knd: Knd, 
lt_int: i <z j, 
le_int: i 
z j, 
bfalse: ff, 
btrue: tt, 
eq_atom: x =a y, 
null: null(as), 
set_blt: a <
 b, 
grp_blt: a <
 b, 
infix_ap: x f y, 
dcdr-to-bool: [d]
, 
bl-all: (
x
L.P[x])_b, 
bl-exists: (
x
L.P[x])_b, 
b-exists: (
i<n.P[i])_b, 
eq_type: eq_type(T;T'), 
eq_atom: eq_atom$n(x;y), 
qeq: qeq(r;s), 
q_less: q_less(r;s), 
q_le: q_le(r;s), 
deq-member: deq-member(eq;x;L), 
deq-disjoint: deq-disjoint(eq;as;bs), 
deq-all-disjoint: deq-all-disjoint(eq;ass;bs), 
eq_id: a = b, 
eq_lnk: a = b, 
bimplies: p 

 q, 
band: p 
 q, 
bor: p 
q, 
bnot: 
b, 
unit: Unit, 
bool:
, 
or: P 
 Q, 
guard: {T}, 
l_member: (x 
 l), 
assert:
b, 
quotient: x,y:A//B[x; y], 
decide: case b of inl(x) => s[x] | inr(y) => t[y], 
suptype: suptype(S; T), 
p-outcome: Outcome, 
lelt: i 
 j < k, 
MaAuto: Error :MaAuto, 
union: left + right, 
fpf-dom: x 
 dom(f), 
intensional-universe: IType, 
inr: inr x , 
inl: inl x , 
int_eq: if a=b  then c  else d, 
corec: corec(T.F[T]), 
SplitOn: Error :SplitOn, 
Try: Error :Try
Lemmas : 
subtype_base_sq, 
bool_subtype_base, 
btrue_wf, 
bfalse_wf, 
unit_wf, 
intensional-universe_wf, 
eq_int_eq_true, 
subtype_rel_self, 
nat_properties, 
int_seg_properties, 
eq_int_wf, 
ifthenelse_wf, 
Error :bag-merge_wf, 
subtype_rel_wf, 
bool_wf, 
uiff_transitivity, 
eqtt_to_assert, 
assert_of_eq_int, 
assert_wf, 
eqff_to_assert, 
assert_of_bnot, 
not_functionality_wrt_uiff, 
bnot_wf, 
pi1_wf_top, 
permutation_wf, 
quotient_wf, 
equiv_rel_wf, 
trans_wf, 
sym_wf, 
refl_wf, 
true_wf, 
squash_wf, 
Error :bag-separate_wf, 
subtype_rel_simple_product, 
pi2_wf, 
top_wf, 
member_wf, 
parallel-data-stream, 
data-stream_wf, 
le_wf, 
false_wf, 
not_wf, 
dataflow-extensionality, 
upto_wf, 
map_wf, 
better-parallel-data-stream, 
uall_wf, 
nat_wf, 
int_seg_wf, 
dataflow_wf, 
Error :bag_wf, 
parallel-bag-dataflow-recode, 
better-parallel-dataflow_wf, 
parallel-dataflow_wf
\mforall{}[A,C:Type].  \mforall{}[n:\mBbbN{}].  \mforall{}[B:\mBbbN{}n  +  2  {}\mrightarrow{}  Type].  \mforall{}[ds:k:\mBbbN{}n  +  2  {}\mrightarrow{}  dataflow(A;bag(B[k]))].
\mforall{}[F:k:\mBbbN{}n  +  2  {}\mrightarrow{}  bag(B[k])  {}\mrightarrow{}  C].
    (better-parallel-dataflow(
      n  +  2;ds;
      F)
    =  better-parallel-dataflow(
        n  +  1;\mlambda{}k.if  (k  =\msubz{}  0)
                          then  better-parallel-dataflow(
                                    2;ds;
                                    \mlambda{}s.bag-merge(s  0;s  1))
                          else  ds  (k  +  1)
                          fi  ;
        \mlambda{}g.(F 
                (\mlambda{}k.if  (k  =\msubz{}  0)  then  fst(bag-separate(g  0))
                        if  (k  =\msubz{}  1)  then  snd(bag-separate(g  0))
                        else  g  (k  -  1)
                        fi  ))))
Date html generated:
2011_08_10-AM-08_23_35
Last ObjectModification:
2011_06_18-AM-08_32_55
Home
Index