Apache flink - 阅读后将文件移动到其他文件夹

我正在从目录中读取csv文件并进行一些处理。现在flink只选择该目录中的任何新文件并对其进行处理。这对我来说很好。

我陷入了两个问题：

我想记录flink已完成处理的文件名。
我想在flink完成处理后立即将处理过的文件移动到不同的文件夹。
我的代码片段是：

final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

org.apache.flink.core.fs.Path filePath = new org.apache.flink.core.fs.Path(feedFileFolderPath);

RowCsvInputFormat format = new RowCsvInputFormat(filePath, FetchTypeInformation.getTypeInformation());

DataStream inputStream = env.readFile(format, feedFileFolderPath, FileProcessingMode.PROCESS_CONTINUOUSLY,

            parseInt(folderLookupTime));