Parquet sink

[Egor Mateshuk]

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. 

Regards,

Egor Mateshuk