override def handle()

in quickstart-flink/quickstart-connector/src/main/scala/org/apache/streampark/flink/quickstart/connector/KafkaSinkApp.scala [32:37]

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

  override def handle(): Unit = {
    val source = new BehaviorSource()
    val ds = context.addSource[Behavior](source).map(_.toString)
    ds.print()
    KafkaSink().sink(ds)
  }