INSERT Statement # INSERT statements are used to add rows to a table. Run an INSERT statement # Java Single INSERT statement can be executed through the executeSql() method of the TableEnvironment. The executeSql() method for INSERT statement will submit a Flink job immediately, and return a TableResult instance which associates the submitted job. Multiple INSERT statements can be executed through the addInsertSql() method of the StatementSet which can be created by the TableEnvironment.| nightlies.apache.org
Apache Kafka SQL Connector # Scan Source: Unbounded Sink: Streaming Append Mode The Kafka connector allows for reading data from and writing data into Kafka topics. Dependencies # Only available for stable versions. The Kafka connector is not part of the binary distribution. See how to link with it for cluster execution here. How to create a Kafka table # The example below shows how to create a Kafka table:| nightlies.apache.org
Kafka Connect is a framework for data integration, and is part of Apache Kafka.| Writing to Apache Iceberg on S3 using Kafka Connect with Glue catalog