You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Egor Mateshuk <eg...@ya.ru> on 2016/08/29 11:49:35 UTC

Parquet sink

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