退订
Px New <15701181132mr@gmail.com> 于2024年7月16日周二 22:52写道：
> 通过老的API 也就是 InputFormatSourceFunction、InputFormat
> 实现了一版，但发现第一批文件(任务启动时也已存在的文件)会正常处理，但我新上传文件后，这里一直为空，有解决思路吗？请问
>
> [image: image.png]
>
> 或者有其他实现 ftp 目录实时读取的实现吗？尽可能满足
> 1. 实时读取 ftp 文件
> 2. 支持持续监测目录及递归子目录与文件3.
> 3. 支持并行读取以及大文件的
通过老的API 也就是 InputFormatSourceFunction、InputFormat
实现了一版，但发现第一批文件(任务启动时也已存在的文件)会正常处理，但我新上传文件后，这里一直为空，有解决思路吗？请问
[image: image.png]
或者有其他实现 ftp 目录实时读取的实现吗？尽可能满足
1. 实时读取 ftp 文件
2. 支持持续监测目录及递归子目录与文件3.
3. 支持并行读取以及大文件的切分
4. 文件种类可能有 json、txt、zip 等，支持读取不同类型文件内的数据
5. 支持断点续传以及状态的保存
