所以我必须创建一个4-1和9-3在每一行的文件。在那之后,我需要对每个数字做减法。我已经做了一些事情,但是只有第2行的结果。所以在izrazi.txt中是我的输入4-1和9-3,所以我在izlaz.txt中的输出必须是4-1 =3,在新行9-3 =6
with open('izrazi.txt','w') as f:
我们的使用是,我们希望使用flink流的去复制作业,它从源读取它的数据(kafka主题),并将独特的记录写入hdfs文件接收器。因此,我决定使用flink键状态流来实现去复制。toString) env.execute(applicationName)下面是使用flink的值状态进行去复制的代码with this key again }}