回复： FileInputFormat 使用问题

Sat, 20 Jun 2020 01:38:47 -0700 

解决了  
| |
阿华田
|
|
a15733178...@163.com
|
签名由网易邮箱大师定制


在2020年06月18日 17:56，john<506269...@qq.com> 写道：
嗨，找到问题了吗？我也遇到了

2020年6月1日 下午2:48，阿华田 <a15733178...@163.com> 写道：

//初始化任务参数
ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
FileInputFormat fileInputFormat = new TextInputFormat(new 
Path("hdfs://arc/success_fid_flow <hdfs://arc/success_fid_flow>"));
fileInputFormat.setNestedFileEnumeration(true);
//过滤掉条件为true
fileInputFormat.setFilesFilter(new 
RegexExcludePathAndTimeFilter("2020-05-24","2020-05-24"));
DataSet<String> source =env.createInput(fileInputFormat);
source.output(new HdfsTrainSinktest());

回复