flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: source binary file
Date Tue, 06 Oct 2015 09:21:47 GMT
Hi Lydia,

you need to implement a custom InputFormat to read binary files.
Usually you can extend the FileInputFormat.
The implementation depends a lot on your use case, for example whether each
binary file is read into a single or multiple records and how records are
delimited if there are more than one in records per file.

Best, Fabian

2015-10-06 11:04 GMT+02:00 Lydia Ickler <icklerly@googlemail.com>:

> Hi,
>
> how would I read a BinaryFile from HDFS with the Flink Java API?
>
> I can only find the Scala way…
>
> All the best,
> Lydia

Mime
View raw message