override def cancel()

in quickstart-flink/quickstart-connector/src/main/scala/org/apache/streampark/flink/quickstart/connector/InfluxDBSinkApp.scala [69:82]

• 12 lines of code
• 2 McCabe index (conditional complexity)

  override def cancel(): Unit = this.isRunning = false

  val random = new Random()

  override def run(ctx: SourceFunction.SourceContext[Weather]): Unit = {
    while (isRunning) {
      val temperature = random.nextInt(100)
      val humidity = random.nextInt(30)
      val area = List("北", "上", "广", "深")(random.nextInt(4))
      val altitude = random.nextInt(10000)
      val order = Weather(temperature, humidity, area, altitude)
      ctx.collect(order)
    }
  }