Hi, Does anyone have an example of working Parquet Sink for Flink DataStreaming API? In Flink 1.1 a new RollingSink with custom writers was released. According to [FLINK-3637] it was done to allow working with ORC and Parquet formats. Maybe someone has already used it for Parquet? I’ve found an example for DataSet API here: https://github.com/FelixNeutatz/parquet-flinktacular <https://github.com/FelixNeutatz/parquet-flinktacular>.
Regards, Egor Mateshuk
