override def handle()

in quickstart-flink/quickstart-flinksql/flinksql_1.13/src/main/scala/org/apache/streampark/quickstart/flink/flinksql/FlinkSqlJob.scala [22:27]

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

  override def handle(): Unit = {
    /**
     * 一行胜千言
     */
    context.sql("my_flinksql")
  }