How to Iterate over results in Table API version 1.12.0

[Robert Cullen]

I’m using a query to gather results:

Table log_counts = tEnv.from("log_counts")
        .filter($("hostname").isNotNull()
                .and($("hostname").isNotEqual("")))
        .window(Tumble
                .over(lit(30).seconds())
                .on($("last_updated")).as("w"))
        .groupBy($("msg_id"), $("hostname"), $("w"))
        .select($("msg_id"),
                $("hostname"),
                $("msg_id").count().as("cnt"));

I’d like to iterate over the results but using this causes an error:

log_counts.execute().collect();

Has there been an update in how to traverse results?


Robert Cullen
240-475-4490