clean up scripts, update README

.gitignore

@@ -13,4 +13,5 @@ metals.sbt
 .scala-build
 .ammonite/*
 *.jar
-*checkpoint
+*checkpoint
+sink-table

README.md

@@ -52,13 +52,13 @@ We suggest to remove the official `flink-scala` and `flink-streaming-scala` depe
 
 ## Examples
 
-There is a wide range of [code examples](https://github.com/flink-extended/flink-scala-api/tree/master/examples) to introduce you to flink-scala-api, both using Scala scripts and multimodule applications. These examples include:
+There is a wide range of [code examples](https://github.com/flink-extended/flink-scala-api/tree/master/modules/examples) to introduce you to flink-scala-api, both using Scala scripts and multimodule applications. These examples include:
 
 - Flink jobs built using Scala 3 with Ammonite and Scala CLI;
 - A complete application for fraud detection;
-- Examples using datastream and table APIs;
-- Simple jobs developed interactively via Jupyter notebooks;
-- Word count reading texts from  a web socket;
+- Examples using Datastream and Table APIs;
+- Simple job developed interactively via Jupyter notebooks;
+- Word count reading text from a web socket;
 - Example usage of DataGen connector and Kafka sink;
 - And more;
 

modules/examples/src/scripts/debug-sql.sc → modules/examples/scripts/debug-sql.sc

@@ -1,21 +1,20 @@
-import $ivy.`io.findify::flink-scala-api:1.15-2`
+import $ivy.`org.flinkextended::flink-scala-api:1.18.1_1.1.6`
 
-import $ivy.`org.apache.flink:flink-clients_2.12:1.14.6`
+import $ivy.`org.apache.flink:flink-clients:1.18.1`
 
-// import $ivy.`org.apache.flink:flink-streaming-java_2.12:1.14.6`
-import $ivy.`org.apache.flink:flink-streaming-scala_2.12:1.14.6`
+import $ivy.`org.apache.flink:flink-streaming-scala_2.12:1.18.1`
 
-import $ivy.`org.apache.flink:flink-table-api-java:1.14.6`
-import $ivy.`org.apache.flink:flink-table-api-java-bridge_2.12:1.14.6`
-import $ivy.`org.apache.flink:flink-table-runtime_2.12:1.14.6`
-import $ivy.`org.apache.flink:flink-table-planner_2.12:1.14.6`
+import $ivy.`org.apache.flink:flink-table-api-java:1.18.1`
+import $ivy.`org.apache.flink:flink-table-api-java-bridge:1.18.1`
+import $ivy.`org.apache.flink:flink-table-runtime:1.18.1`
+import $ivy.`org.apache.flink:flink-table-planner_2.12:1.18.1`
 
 import org.apache.flink.table.api._
 import org.apache.flink.table.api.bridge.java.StreamTableEnvironment
 import org.apache.flink.connector.datagen.table.DataGenConnectorOptions
 
-import io.findify.flink.api._
-import io.findify.flinkadt.api._
+import org.apache.flinkx.api._
+import org.apache.flinkx.api.serializers._
 
 import java.lang.{Long => JLong}
 

modules/examples/src/scripts/flink-amm.sc → modules/examples/scripts/flink-amm.sc

@@ -17,24 +17,10 @@ import org.apache.flink.api.serializers._
 
 import _root_.java.lang.{Long => JLong}
 
-val env = StreamExecutionEnvironment.getExecutionEnvironment
-val tEnv = StreamTableEnvironment.create(env.getJavaEnv)
+val env      = StreamExecutionEnvironment.getExecutionEnvironment
+val tEnv     = StreamTableEnvironment.create(env.getJavaEnv)
 val settings = EnvironmentSettings.newInstance().inStreamingMode().build()
-val table = TableEnvironment.create(settings)
-
-
-// table.createTemporaryTable(
-//   "SourceTable",
-//   TableDescriptor
-//     .forConnector("datagen")
-//     .schema(
-//       Schema.newBuilder
-//         .column("BookId", DataTypes.INT())
-//         .build
-//     )
-//     .option(DataGenConnectorOptions.ROWS_PER_SECOND, new JLong(1))
-//     .build
-// )
+val table    = TableEnvironment.create(settings)
 
 val tableDescriptor = TableDescriptor
   .forConnector("faker")

modules/examples/src/scripts/flink-scala-cli.scala → modules/examples/scripts/flink-scala-cli.scala

@@ -1,5 +1,5 @@
-//> using dep "org.flinkextended::flink-scala-api:1.17.1_1.1.0"
-//> using dep "org.apache.flink:flink-clients:1.17.1"
+//> using dep "org.flinkextended::flink-scala-api:1.18.1_1.1.6"
+//> using dep "org.apache.flink:flink-clients:1.18.1"
 
 import org.apache.flinkx.api.*
 import org.apache.flinkx.api.serializers.*

modules/examples/src/scripts/gen-csv-file.sc → modules/examples/scripts/gen-csv-file.sc

@@ -1,9 +1,9 @@
-//> using dep "org.flinkextended::flink-scala-api:1.17.2_1.1.2"
-//> using dep "org.apache.flink:flink-clients:1.17.1"
-//> using dep "org.apache.flink:flink-csv:1.17.1"
-//> using dep "org.apache.flink:flink-connector-files:1.17.1"
-//> using dep "org.apache.flink:flink-table-runtime:1.17.1"
-//> using dep "org.apache.flink:flink-table-planner-loader:1.17.1"
+//> using dep "org.flinkextended::flink-scala-api:1.18.1_1.1.6"
+//> using dep "org.apache.flink:flink-clients:1.18.1"
+//> using dep "org.apache.flink:flink-csv:1.18.1"
+//> using dep "org.apache.flink:flink-connector-files:1.18.1"
+//> using dep "org.apache.flink:flink-table-runtime:1.18.1"
+//> using dep "org.apache.flink:flink-table-planner-loader:1.18.1"
 
 import org.apache.flink.table.api._
 import org.apache.flink.connector.datagen.table.DataGenConnectorOptions

modules/examples/src/scripts/gen-kafka-data.sc → modules/examples/scripts/gen-kafka-data.sc

@@ -1,10 +1,10 @@
-//> using dep "org.flinkextended::flink-scala-api:1.17.2_1.1.2"
-//> using dep "org.apache.flink:flink-clients:1.17.1"
-//> using dep "org.apache.flink:flink-csv:1.17.1"
-//> using dep "org.apache.flink:flink-connector-files:1.17.1"
-//> using dep "org.apache.flink:flink-connector-kafka:1.17.1"
-//> using dep "org.apache.flink:flink-table-runtime:1.17.1"
-//> using dep "org.apache.flink:flink-table-planner-loader:1.17.1"
+//> using dep "org.flinkextended::flink-scala-api:1.18.1_1.1.6"
+//> using dep "org.apache.flink:flink-clients:1.18.1"
+//> using dep "org.apache.flink:flink-csv:1.18.1"
+//> using dep "org.apache.flink:flink-connector-files:1.18.1"
+//> using dep "org.apache.flink:flink-connector-kafka:3.0.2-1.18"
+//> using dep "org.apache.flink:flink-table-runtime:1.18.1"
+//> using dep "org.apache.flink:flink-table-planner-loader:1.18.1"
 
 import org.apache.flink.table.api._
 import org.apache.flink.connector.datagen.table.DataGenConnectorOptions

modules/examples/src/scripts/hybrid-source.sc → modules/examples/scripts/hybrid-source.sc

@@ -1,8 +1,8 @@
-//> using dep "org.flinkextended::flink-scala-api:1.17.2_1.1.2"
-//> using dep "org.apache.flink:flink-clients:1.17.1"
-//> using dep "org.apache.flink:flink-csv:1.17.1"
-//> using dep "org.apache.flink:flink-connector-files:1.17.1"
-//> using dep "org.apache.flink:flink-connector-kafka:1.17.1"
+//> using dep "org.flinkextended::flink-scala-api:1.18.1_1.1.6"
+//> using dep "org.apache.flink:flink-clients:1.18.1"
+//> using dep "org.apache.flink:flink-csv:1.18.1"
+//> using dep "org.apache.flink:flink-connector-files:1.18.1"
+//> using dep "org.apache.flink:flink-connector-kafka:3.0.2-1.18"
 
 import org.apache.flinkx.api.*
 import org.apache.flinkx.api.serializers.*