koduki · October 10, 2016 13:07
diff --git a/a.java b/a.java
 List<Item> items = createItemList("Item", 100);
 bench("outer_join(df:bloadcast)", 5, () -> {
    long count = sc.parallelize(items)
            .map(x -> sleep(1))
            .count();
    System.out.println("finish: " + count);
 });
	List<Item> items = createItemList("Item", 100);
	bench("outer_join(df:bloadcast)", 5, () -> {
	long count = sc.parallelize(items)
	.map(x -> sleep(1))
	.count();
	System.out.println("finish: " + count);
	});