AFA I remember, there is no ParquetInputFormat in Flink. But there is a JIRA <https://issues.apache.org/jira/browse/FLINK-7243> logged and an attempt in this PR <https://github.com/godfreyhe/flink/pull/4/files>, 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 <https://issues.apache.org/jira/browse/FLINK-2169> for adding ParquetTableSource. On Tue, Apr 17, 2018 at 10:23 PM, sohimankotia <sohimanko...@gmail.com> 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/ > -- "So you have to trust that the dots will somehow connect in your future."
