Flink ColumnStats

[Flavio Pompermaier]

Hi all,

I've seen that recently there was an ongoing effort about Flink ColumnStats but I can't find a Flink job that computes Flink table stats, I found only a code that does the conversion from Hive catalog.

Is there any Flink utility I can call to compute them on a Table?

We've tried to implement a specific job at https://github.com/okkam-it/flink-descriptive-stats/blob/master/src/main/java/jar/ProfileJob.java that works on a DataSet but we didn't get any feedback about it..is there any better way to achieve this?

Best,

Flavio