Re: Need Help/Code Examples with reading/writing Parquet File with Flink ?

Posted by Shuyi Chen on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Need-Help-Code-Examples-with-reading-writing-Parquet-File-with-Flink-tp19588p19589.html

AFA I remember, there is no ParquetInputFormat in Flink. But there is a JIRA logged and an attempt in this PR, but was never merged. We do have an internal implementation that is being used in our company, and we can contribute back to the community. 

+Peter, could we help check how we could contribute the ParquetInputFormat implementation back?

Also, FYI, if you want to read parquet with Flink SQL, here is the JIRA for adding ParquetTableSource.

On Tue, Apr 17, 2018 at 10:23 PM, sohimankotia <[hidden email]> wrote:

Hi ..

I have file in hdfs in format file.snappy.parquet . Can someone please
point/help with code example of reading parquet files .


-Sohi



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

--