Flink 状态 |检查最后一个数据是第一个数据

Question

使用Flink State如何查看最后一个数据是第一个数据

  override def flatMap(value: myData, out: Collector[(String, Double, Double)]): Unit = {
    val lastValue = lastValueState.value()
    val diff = (value.item_data-lastValue).abs
    if (diff > Threshold)
      out.collect((value.item_id,lastValue,value.item_data))

    lastValueState.update(value.item_data)
  }

Answer 1

ValueState#value() returns 如果之前没有为当前范围内的键存储任何内容（对应于当前正在处理的 value 的键），则为 null。

Flink 状态 |检查最后一个数据是第一个数据

Flink State | check last data is the first data

apache-flink