Hi,
我们在1.11已经支持了较完整的filesystem支持，并且支持分区。(csv,json,avro,parquet,orc)
对于灵活的read，争取在1.12完成。已经有issue了：
https://issues.apache.org/jira/browse/FLINK-17398
Best,
Jingsong Lee
On Fri, May 22, 2020 at 10:47 AM 阿华田 wrote:
> input_data = "hdfs://localhost:9002/tmp/match_bak/%s*[0-9]" %
> ('2018-07-16’)
input_data = "hdfs://localhost:9002/tmp/match_bak/%s*[0-9]" % ('2018-07-16’)
result = sc.textFile(input_data)
flink可以像spark一样正则读取hdfs目录下的文件吗？目前测试好像不行，如果不支持，最早什么版本会支持呢？
| |
王志华
|
|
a15733178...@163.com
|
签名由网易邮箱大师定制
