我们的使用是,我们希望使用flink流的去复制作业,它从源读取它的数据(kafka主题),并将独特的记录写入hdfs文件接收器。因此,我决定使用flink键状态流来实现去复制。toString) env.execute(applicationName)下面是使用flink的值状态进行去复制的代码with this key again }}
给定时间戳数据,我想计算过去4-6天的某些变量的中位数。过去1-3天的中位数可以由pd.pandas.DataFrame.rolling计算,但我找不到如何使用滚动来计算过去4-6天的中位数。6 days2 2011-014-6 days
6 2011-01-02 12:00:00 1.744812 NaN #