override def handle()

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

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

  override def handle(): Unit = {

    context.sql("my_flinksql")

  }