Thanks Ufuk, I'm already using the recursive traversal feature.

On Mon, Mar 21, 2016 at 8:39 AM, Ufuk Celebi <u...@apache.org> wrote:

> If you want all sub directories under data/2016/01, then this could help:
> https://ci.apache.org/projects/flink/flink-docs-master/apis/batch/index.html#recursive-traversal-of-the-input-path-directory
>
> On Mon, Mar 21, 2016 at 11:35 AM, Fabian Hueske <fhue...@gmail.com> wrote:
>
>> Hi,
>>
>> no, this is currently not supported. However, I agree this would be a
>> very valuable addition to the FileInputFormat.
>> Would you mind opening a JIRA issue with your suggestions?
>>
>> Until this is added to Flink, it can be implemented as a custom
>> InputFormat based on FileInputFormat by overriding the createInputSplits()
>> method.
>>
>> Best, Fabian
>>
>> 2016-03-21 0:11 GMT+01:00 Sourigna Phetsarath <gna.phetsar...@teamaol.com
>> >:
>>
>>> All,
>>>
>>> Do any of the Flink Data Sources support comma separated directories
>>> with wildcards?
>>>
>>> For example:
>>>
>>> env.readFile("/data/2016/01/01/*/*,/data/2016/01/02/*/*,
>>> /data/2016/01/03/*/*")
>>>
>>>
>>> Thanks in advance for any help that you can provide.
>>> --
>>>
>>>
>>> *Gna Phetsarath*System Architect // AOL Platforms // Data Services //
>>> Applied Research Chapter
>>> 770 Broadway, 5th Floor, New York, NY 10003
>>> o: 212.402.4871 // m: 917.373.7363
>>> vvmr: 8890237 aim: sphetsarath20 t: @sourigna
>>>
>>> * <http://www.aolplatforms.com>*
>>>
>>
>>
>


-- 


*Gna Phetsarath*System Architect // AOL Platforms // Data Services //
Applied Research Chapter
770 Broadway, 5th Floor, New York, NY 10003
o: 212.402.4871 // m: 917.373.7363
vvmr: 8890237 aim: sphetsarath20 t: @sourigna

* <http://www.aolplatforms.com>*

Reply via email to