.ORC file reading from Apache Flink +SCALA

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

.ORC file reading from Apache Flink +SCALA

Ajay Kumar
Hi Team,

I am struggling to read .ORC file as a source from Apache flink.
Unfortunately there is no reach reference over internet also,

Appreciate your help !

Thanks in advance !

Regards
Ajay
Reply | Threaded
Open this post in threaded view
|

Re: .ORC file reading from Apache Flink +SCALA

Marta Paes Moreira
Hi, Ajay.

*Note:* in the future, please send this type of questions to the user
mailing list instead ([hidden email])!

Which API and Flink version are you using? The documentation/JavaDocs have
information on how to read Orc files (and other bulk-encoded formats) using
the DataStream API [1] and the Table API/SQL [2]. For the DataStream API, I
didn't find any examples using Scala, but you should be able to derive an
implementation from the snippet in this [3] Jira ticket.

If you still struggle with your implementation after referencing to that,
please provide some more details on the issue you're facing.

Marta

[1]
https://ci.apache.org/projects/flink/flink-docs-master/api/java/org/apache/flink/orc/package-summary.html
[2]
https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/connectors/formats/orc.html
[3] https://issues.apache.org/jira/browse/FLINK-16646

On Sun, Sep 27, 2020 at 7:06 PM Ajay Kumar <[hidden email]> wrote:

> Hi Team,
>
> I am struggling to read .ORC file as a source from Apache flink.
> Unfortunately there is no reach reference over internet also,
>
> Appreciate your help !
>
> Thanks in advance !
>
> Regards
> Ajay
>