我们的使用是,我们希望使用flink流的去复制作业,它从源读取它的数据(kafka主题),并将独特的记录写入hdfs文件接收器。因此,我决定使用flink键状态流来实现去复制。toString) env.execute(applicationName)下面是使用flink的值状态进行去复制的代码with this key again }}
例如,系列4,5,6,7被编写为4-7。我的目标是扩展这个字符串,使所有数字都由comas分隔(4-7应该变成4,5,6,7)。我做了什么,s="4092-4093,4095-4097,4104,4107,4111,4125-4127"如何将4-7类型的模式替换为字符串中的4,5,6,7?我在Mac OS X 10.11.3上使用Terminal 2.6.1 (361.1)