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

[sohimankotia]

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/

[Shuyi Chen]

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/

--

[Jörn Franke]

You can use the corresponding HadoopInputformat within Flink

> On 18. Apr 2018, at 07:23, 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/