如何在flink中按照数据写入文件的顺序从文件数据创建数据流？

import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.core.fs.Path;
import org.apache.flink.api.common.io.FileInputFormat;
import org.apache.flink.api.common.io.TextInputFormat;
import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.api.java.DataSet;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class FileDataToDataStreamExample {
    public static void main(String[] args) throws Exception {
        // 创建批处理环境
        ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();

        // 创建文件输入格式
        FileInputFormat<Tuple2<Long, String>> inputFormat = new TextInputFormat(new Path("file:///path/to/input/file.txt"));
        TypeInformation<Tuple2<Long, String>> typeInfo = TypeInformation.of(new TypeHint<Tuple2<Long, String>>() {});
        inputFormat.setFilePath("file:///path/to/input/file.txt");

        // 从文件中读取数据集
        DataSet<Tuple2<Long, String>> dataSet = env.readFile(inputFormat, "file:///path/to/input/file.txt");

        // 对数据集进行转换和处理
        DataSet<Tuple2<Long, String>> processedDataSet = dataSet.map(tuple -> {
            // 在这里按照数据写入文件的顺序进行处理
            // 可以使用计数器等方式记录数据的顺序
            return tuple;
        });

        // 将处理后的数据集转换为数据流
        StreamExecutionEnvironment streamEnv = StreamExecutionEnvironment.getExecutionEnvironment();
        DataStream<Tuple2<Long, String>> dataStream = streamEnv.fromElements(processedDataSet.collect());

        // 输出数据流
        dataStream.print();

        // 执行任务
        streamEnv.execute("FileDataToDataStreamExample");
    }
}