override def handle()

in quickstart-flink/quickstart-connector/src/main/scala/org/apache/streampark/flink/quickstart/connector/HttpSinkApp.scala [29:40]

• 5 lines of code
• 1 McCabe index (conditional complexity)

  override def handle(): Unit = {

    /**
     * source
     */
    val source = context.addSource(new MyDataSource)
      .map(x => s"http://www.qq.com?id=${x.userId}")

    // sink
    new HttpSink(context).get(source)

  }