thrill_kmeans_process.cpp

void Process(thrill::Context& ctx) {
    std::default_random_engine rng(std::random_device { } ());
    std::uniform_real_distribution<double> dist(0.0, 1000.0);
    // generate 100 random points using uniform distribution
    DIA<Point> points =
        Generate(
            ctx, /* size */ 100,
            [&](const size_t& /* index */) {
                return Point { dist(rng), dist(rng) };
            })
        .Cache();
    // print out the points
    points.Print("points");
}