id: 1 unit: public static void main() file: quickstart-flink/quickstart-apacheflink/apacheflinksql_demo/src/main/java/SocketWindowWordCount.java start line: 40 end line: 85 size: 35 LOC McCabe index: 4 number of parameters: 1 id: 2 unit: public static void main() file: quickstart-flink/quickstart-apacheflink/apacheflinksql_1.19/src/main/java/JavaFlinkSqlJob.java start line: 23 end line: 61 size: 35 LOC McCabe index: 1 number of parameters: 1 id: 3 unit: public static void main() file: quickstart-flink/quickstart-apacheflink/apacheflinksql_1.17/src/main/java/JavaFlinkSqlJob.java start line: 23 end line: 61 size: 34 LOC McCabe index: 1 number of parameters: 1 id: 4 unit: public static void main() file: quickstart-flink/quickstart-apacheflink/apacheflinksql_1.16/src/main/java/JavaFlinkSqlJob.java start line: 23 end line: 61 size: 34 LOC McCabe index: 1 number of parameters: 1 id: 5 unit: public static void main() file: quickstart-flink/quickstart-apacheflink/apacheflinksql_1.18/src/main/java/JavaFlinkSqlJob.java start line: 23 end line: 61 size: 34 LOC McCabe index: 1 number of parameters: 1 id: 6 unit: override def handle() file: quickstart-flink/quickstart-connector/src/main/scala/org/apache/streampark/flink/quickstart/connector/HBaseSourceApp.scala start line: 35 end line: 71 size: 33 LOC McCabe index: 9 number of parameters: 0 id: 7 unit: public static void main() file: quickstart-flink/quickstart-connector/src/main/java/org/apache/streampark/flink/quickstart/connector/MySQLJavaApp.java start line: 34 end line: 73 size: 30 LOC McCabe index: 2 number of parameters: 1 id: 8 unit: override def cancel() file: quickstart-flink/quickstart-connector/src/main/scala/org/apache/streampark/flink/quickstart/connector/MyDataSource.scala start line: 29 end line: 51 size: 18 LOC McCabe index: 3 number of parameters: 0 id: 9 unit: override def handle() file: quickstart-flink/quickstart-flinksql/flinksql_1.15/src/main/scala/org/apache/streampark/quickstart/flink/flinksql/MixinTableDataStreamJob.scala start line: 25 end line: 46 size: 17 LOC McCabe index: 1 number of parameters: 0 id: 10 unit: override def handle() file: quickstart-flink/quickstart-flinksql/flinksql_1.12/src/main/scala/org/apache/streampark/quickstart/flink/flinksql/MixinTableDataStreamJob.scala start line: 25 end line: 46 size: 17 LOC McCabe index: 1 number of parameters: 0 id: 11 unit: override def handle() file: quickstart-flink/quickstart-flinksql/flinksql_1.13/src/main/scala/org/apache/streampark/quickstart/flink/flinksql/MixinTableDataStreamJob.scala start line: 25 end line: 46 size: 17 LOC McCabe index: 1 number of parameters: 0 id: 12 unit: override def handle() file: quickstart-flink/quickstart-flinksql/flinksql_1.14/src/main/scala/org/apache/streampark/quickstart/flink/flinksql/MixinTableDataStreamJob.scala start line: 25 end line: 46 size: 17 LOC McCabe index: 1 number of parameters: 0 id: 13 unit: override def handle() file: quickstart-flink/quickstart-flinksql/flinksql_1.16/src/main/scala/org/apache/streampark/quickstart/flink/flinksql/MixinTableDataStreamJob.scala start line: 25 end line: 46 size: 17 LOC McCabe index: 1 number of parameters: 0 id: 14 unit: override def handle() file: quickstart-flink/quickstart-connector/src/main/scala/org/apache/streampark/flink/quickstart/connector/MongoSourceApp.scala start line: 32 end line: 50 size: 16 LOC McCabe index: 2 number of parameters: 0 id: 15 unit: override def handle() file: quickstart-flink/quickstart-connector/src/main/scala/org/apache/streampark/flink/quickstart/connector/HBaseSinkApp.scala start line: 35 end line: 61 size: 16 LOC McCabe index: 1 number of parameters: 0 id: 16 unit: override def cancel() file: quickstart-flink/quickstart-connector/src/main/scala/org/apache/streampark/flink/quickstart/connector/KafkaSinkApp.scala start line: 64 end line: 80 size: 15 LOC McCabe index: 3 number of parameters: 0 id: 17 unit: override def handle() file: quickstart-flink/quickstart-connector/src/main/scala/org/apache/streampark/flink/quickstart/connector/SideOutApp.scala start line: 35 end line: 57 size: 14 LOC McCabe index: 2 number of parameters: 0 id: 18 unit: override def cancel() file: quickstart-flink/quickstart-connector/src/main/scala/org/apache/streampark/flink/quickstart/connector/SideOutApp.scala start line: 87 end line: 102 size: 14 LOC McCabe index: 2 number of parameters: 0 id: 19 unit: public static void main() file: quickstart-flink/quickstart-datastream/datastream_1.16/src/main/java/org/apache/streampark/flink/quickstart/datastream/QuickStartJavaApp.java start line: 36 end line: 54 size: 13 LOC McCabe index: 1 number of parameters: 1 id: 20 unit: public static void main() file: quickstart-flink/quickstart-datastream/datastream_1.12/src/main/java/org/apache/streampark/flink/quickstart/datastream/QuickStartJavaApp.java start line: 35 end line: 53 size: 13 LOC McCabe index: 1 number of parameters: 1 id: 21 unit: public static void main() file: quickstart-flink/quickstart-datastream/datastream_1.15/src/main/java/org/apache/streampark/flink/quickstart/datastream/QuickStartJavaApp.java start line: 36 end line: 54 size: 13 LOC McCabe index: 1 number of parameters: 1 id: 22 unit: public static void main() file: quickstart-flink/quickstart-datastream/datastream_1.14/src/main/java/org/apache/streampark/flink/quickstart/datastream/QuickStartJavaApp.java start line: 36 end line: 54 size: 13 LOC McCabe index: 1 number of parameters: 1 id: 23 unit: public static void main() file: quickstart-flink/quickstart-datastream/datastream_1.13/src/main/java/org/apache/streampark/flink/quickstart/datastream/QuickStartJavaApp.java start line: 36 end line: 54 size: 13 LOC McCabe index: 1 number of parameters: 1 id: 24 unit: override def handle() file: quickstart-flink/quickstart-connector/src/main/scala/org/apache/streampark/flink/quickstart/connector/ClickHouseSinkApp.scala start line: 28 end line: 51 size: 13 LOC McCabe index: 1 number of parameters: 0 id: 25 unit: public static void main() file: quickstart-flink/quickstart-connector/src/main/java/org/apache/streampark/flink/quickstart/connector/KafkaJavaApp.java start line: 35 end line: 56 size: 13 LOC McCabe index: 1 number of parameters: 1 id: 26 unit: override def handle() file: quickstart-flink/quickstart-datastream/datastream_1.12/src/main/scala/org/apache/streampark/flink/quickstart/datastream/QuickStartApp.scala start line: 30 end line: 42 size: 12 LOC McCabe index: 1 number of parameters: 0 id: 27 unit: override def handle() file: quickstart-flink/quickstart-datastream/datastream_1.15/src/main/scala/org/apache/streampark/flink/quickstart/datastream/QuickStartApp.scala start line: 54 end line: 66 size: 12 LOC McCabe index: 1 number of parameters: 0 id: 28 unit: override def handle() file: quickstart-flink/quickstart-datastream/datastream_1.14/src/main/scala/org/apache/streampark/flink/quickstart/datastream/QuickStartApp.scala start line: 54 end line: 66 size: 12 LOC McCabe index: 1 number of parameters: 0 id: 29 unit: override def handle() file: quickstart-flink/quickstart-datastream/datastream_1.13/src/main/scala/org/apache/streampark/flink/quickstart/datastream/QuickStartApp.scala start line: 54 end line: 66 size: 12 LOC McCabe index: 1 number of parameters: 0 id: 30 unit: override def cancel() file: quickstart-flink/quickstart-connector/src/main/scala/org/apache/streampark/flink/quickstart/connector/InfluxDBSinkApp.scala start line: 69 end line: 82 size: 12 LOC McCabe index: 2 number of parameters: 0 id: 31 unit: override def handle() file: quickstart-flink/quickstart-connector/src/main/scala/org/apache/streampark/flink/quickstart/connector/InfluxDBSinkApp.scala start line: 34 end line: 49 size: 11 LOC McCabe index: 1 number of parameters: 0 id: 32 unit: override def handle() file: quickstart-flink/quickstart-connector/src/main/scala/org/apache/streampark/flink/quickstart/connector/JdbcSinkApp.scala start line: 28 end line: 53 size: 11 LOC McCabe index: 1 number of parameters: 0 id: 33 unit: override def handle() file: quickstart-flink/quickstart-connector/src/main/scala/org/apache/streampark/flink/quickstart/connector/HBaseRequestApp.scala start line: 32 end line: 47 size: 10 LOC McCabe index: 1 number of parameters: 0 id: 34 unit: public static void main() file: quickstart-flink/quickstart-connector/src/main/java/org/apache/streampark/flink/quickstart/connector/DorisJavaApp.java start line: 32 end line: 43 size: 10 LOC McCabe index: 1 number of parameters: 1 id: 35 unit: override def handle() file: quickstart-flink/quickstart-datastream/datastream_1.16/src/main/scala/org/apache/streampark/flink/quickstart/datastream/QuickStartApp.scala start line: 39 end line: 51 size: 9 LOC McCabe index: 1 number of parameters: 0 id: 36 unit: override def handle() file: quickstart-flink/quickstart-connector/src/main/scala/org/apache/streampark/flink/quickstart/connector/ES7SinkApp.scala start line: 32 end line: 42 size: 9 LOC McCabe index: 1 number of parameters: 0 id: 37 unit: public static void main() file: quickstart-flink/quickstart-connector/src/main/java/org/apache/streampark/flink/quickstart/connector/ClickhouseJavaApp.java start line: 30 end line: 49 size: 9 LOC McCabe index: 1 number of parameters: 1 id: 38 unit: public String toSql() file: quickstart-flink/quickstart-datastream/datastream_1.16/src/main/java/org/apache/streampark/flink/quickstart/datastream/JavaUser.java start line: 31 end line: 38 size: 8 LOC McCabe index: 1 number of parameters: 0 id: 39 unit: public String toSql() file: quickstart-flink/quickstart-datastream/datastream_1.12/src/main/java/org/apache/streampark/flink/quickstart/datastream/JavaUser.java start line: 27 end line: 34 size: 8 LOC McCabe index: 1 number of parameters: 0 id: 40 unit: public String toSql() file: quickstart-flink/quickstart-datastream/datastream_1.15/src/main/java/org/apache/streampark/flink/quickstart/datastream/JavaUser.java start line: 31 end line: 38 size: 8 LOC McCabe index: 1 number of parameters: 0 id: 41 unit: public String toSql() file: quickstart-flink/quickstart-datastream/datastream_1.14/src/main/java/org/apache/streampark/flink/quickstart/datastream/JavaUser.java start line: 31 end line: 38 size: 8 LOC McCabe index: 1 number of parameters: 0 id: 42 unit: public String toSql() file: quickstart-flink/quickstart-datastream/datastream_1.13/src/main/java/org/apache/streampark/flink/quickstart/datastream/JavaUser.java start line: 31 end line: 38 size: 8 LOC McCabe index: 1 number of parameters: 0 id: 43 unit: override def handle() file: quickstart-flink/quickstart-connector/src/main/scala/org/apache/streampark/flink/quickstart/connector/MySQLSourceApp.scala start line: 27 end line: 36 size: 8 LOC McCabe index: 2 number of parameters: 0 id: 44 unit: public static void main() file: quickstart-flink/quickstart-flinksql/flinksql_1.15/src/main/java/org/apache/streampark/quickstart/flink/flinksql/JavaFlinkSqlJob.java start line: 25 end line: 32 size: 7 LOC McCabe index: 1 number of parameters: 1 id: 45 unit: public static void main() file: quickstart-flink/quickstart-flinksql/flinksql_1.12/src/main/java/org/apache/streampark/quickstart/flink/flinksql/JavaFlinkSqlJob.java start line: 9 end line: 16 size: 7 LOC McCabe index: 1 number of parameters: 1 id: 46 unit: public static void main() file: quickstart-flink/quickstart-flinksql/flinksql_1.13/src/main/java/org/apache/streampark/quickstart/flink/flinksql/JavaFlinkSqlJob.java start line: 9 end line: 16 size: 7 LOC McCabe index: 1 number of parameters: 1 id: 47 unit: public static void main() file: quickstart-flink/quickstart-flinksql/flinksql_1.14/src/main/java/org/apache/streampark/quickstart/flink/flinksql/JavaFlinkSqlJob.java start line: 25 end line: 32 size: 7 LOC McCabe index: 1 number of parameters: 1 id: 48 unit: public static void main() file: quickstart-flink/quickstart-flinksql/flinksql_1.16/src/main/java/org/apache/streampark/quickstart/flink/flinksql/JavaFlinkSqlJob.java start line: 25 end line: 32 size: 7 LOC McCabe index: 1 number of parameters: 1 id: 49 unit: public static void main() file: quickstart-flink/quickstart-connector/src/main/java/org/apache/streampark/flink/quickstart/connector/HttpJavaApp.java start line: 30 end line: 36 size: 7 LOC McCabe index: 1 number of parameters: 1 id: 50 unit: override def handle() file: quickstart-flink/quickstart-connector/src/main/scala/org/apache/streampark/flink/quickstart/connector/KafkaSinkApp.scala start line: 32 end line: 37 size: 6 LOC McCabe index: 1 number of parameters: 0 id: 51 unit: override def handle() file: quickstart-flink/quickstart-connector/src/main/scala/org/apache/streampark/flink/quickstart/connector/HttpSinkApp.scala start line: 29 end line: 40 size: 5 LOC McCabe index: 1 number of parameters: 0 id: 52 unit: override def handle() file: quickstart-flink/quickstart-connector/src/main/scala/org/apache/streampark/flink/quickstart/connector/KafkaSourceApp.scala start line: 24 end line: 30 size: 5 LOC McCabe index: 1 number of parameters: 0 id: 53 unit: public WordWithCount() file: quickstart-flink/quickstart-apacheflink/apacheflinksql_demo/src/main/java/SocketWindowWordCount.java start line: 101 end line: 104 size: 4 LOC McCabe index: 1 number of parameters: 2 id: 54 unit: override def handle() file: quickstart-flink/quickstart-flinksql/flinksql_1.15/src/main/scala/org/apache/streampark/quickstart/flink/flinksql/FlinkSqlJob.scala start line: 23 end line: 28 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 55 unit: override def handle() file: quickstart-flink/quickstart-flinksql/flinksql_1.12/src/main/scala/org/apache/streampark/quickstart/flink/flinksql/FlinkSqlJob.scala start line: 22 end line: 27 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 56 unit: override def handle() file: quickstart-flink/quickstart-flinksql/flinksql_1.13/src/main/scala/org/apache/streampark/quickstart/flink/flinksql/FlinkSqlJob.scala start line: 22 end line: 27 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 57 unit: override def handle() file: quickstart-flink/quickstart-flinksql/flinksql_1.14/src/main/scala/org/apache/streampark/quickstart/flink/flinksql/FlinkSqlJob.scala start line: 23 end line: 28 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 58 unit: override def handle() file: quickstart-flink/quickstart-flinksql/flinksql_1.16/src/main/scala/org/apache/streampark/quickstart/flink/flinksql/FlinkSqlJob.scala start line: 23 end line: 27 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 59 unit: public String toString() file: quickstart-flink/quickstart-apacheflink/apacheflinksql_demo/src/main/java/SocketWindowWordCount.java start line: 107 end line: 109 size: 3 LOC McCabe index: 1 number of parameters: 0 id: 60 unit: public WordWithCount() file: quickstart-flink/quickstart-apacheflink/apacheflinksql_demo/src/main/java/SocketWindowWordCount.java start line: 98 end line: 99 size: 2 LOC McCabe index: 1 number of parameters: 0