X-Git-Url: http://git.megacz.com/?p=sbp.git;a=blobdiff_plain;f=src%2Fedu%2Fberkeley%2Fsbp%2Futil%2FTopologicalBag.java;fp=src%2Fedu%2Fberkeley%2Fsbp%2Futil%2FTopologicalBag.java;h=259560260e602efd057bfc41fb16f59c57ffaec6;hp=9a18eef7fa98eda82d0bc51d6b33b8732748403b;hb=d6269a7a0a5b3fe84e75725deaac560117ffc26e;hpb=61a641445b4f0916427804a6168b87fcde977abf diff --git a/src/edu/berkeley/sbp/util/TopologicalBag.java b/src/edu/berkeley/sbp/util/TopologicalBag.java index 9a18eef..2595602 100644 --- a/src/edu/berkeley/sbp/util/TopologicalBag.java +++ b/src/edu/berkeley/sbp/util/TopologicalBag.java @@ -135,7 +135,7 @@ public class TopologicalBag implements MapBag,V>, VisitableMap< } } - public VisitableMap optimize() { + public VisitableMap optimize(final Functor f) { ArrayList min_ = new ArrayList(); ArrayList max_ = new ArrayList(); ArrayList v_ = new ArrayList(); @@ -157,16 +157,14 @@ public class TopologicalBag implements MapBag,V>, VisitableMap< final Object[][] v = new Object[size][]; v_.toArray(v); return new VisitableMap() { public boolean contains(K k) { - IntegerMappable im = (IntegerMappable)k; - int asint = im.toInt(); + int asint = f.invoke(k); for(int i=0; i= asint && v[i].length > 0) return true; return false; } public void invoke(K k, Invokable ivbc, B b, C c) { - IntegerMappable im = (IntegerMappable)k; - int asint = im.toInt(); + int asint = f.invoke(k); for(int i=0; i= asint) { Object[] arr = v[i];