Rolling sink parquet/Avro output

Posted by bdas77 on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Rolling-sink-parquet-Avro-output-tp11123.html

Hi There ,

Does any have Rolling sink parquet/Avro writer reference ??. I'm seeing some issue given stream is handle at rolling sink and I don't see much option overrideĀ  or even open at subclass . I could resolve the same with a custom rolling sink writer, just wondering if any one has done similar or something out there , please correct me if I'm missing anything here.

~Biswajit

Thank you
~/Das