Manage tables in Aiven for Apache Flink® applications
Aiven for Apache Flink® allows you to map source and target data structures as Flink tables and use transformation statements to reshape, filter or aggregate data. Some of the table operations include:
- Import existing tables
- Create tables
- Clone table definitions from other applications
- Edit tables
- Delete tables
Before performing any operation on a table in a Flink application, you must stop the application. To stop an application, go to the Applications from the left sidebar on your Aiven for Apache Flink® service, select the desired application from the list, and select Stop Deployment.
Add a new table
To add a new table to an application using the Aiven Console:
-
Select Applications from the left sidebar on your Aiven for Apache Flink service, and select the application to which you want to add a new table. Make sure the application deployment is stopped.
-
Select Create new version.
-
On the Create new version screen, go to the Add source tables or Add sink tables screen within your application.
-
Select Add new table to add a new table to your application.
noteIf you already have a sink table listed, you must delete it before adding a new one, only one sink table is allowed per job.
-
Select the Integrated service from the drop-down list in the Add new source table or Add new sink table screen, respectively.
-
In the Table SQL section, enter the statement that will create the table. The interactive query feature if the editor will prompt you for error or invalid queries.
-
Select Add table to complete the process.
Import an existing table
To import an existing table from another application:
-
In the Add source tables or Add sink tables screen, select Import existing table to import a table to your application.
noteIf you already have a sink table listed, you must delete it before importing a new one.
-
From the Import existing source table or Import existing sink table screen:
- Select the application from which to import the table.
- Select the version of the application.
- Select the table to import.
-
Select Next.
-
Verify the data on the Add new source table or Add new sink table screen and select Add table to complete the process.
Clone a table
To clone a table within an application:
-
In the Add source tables screen, locate the table to clone and click Clone next to it.
noteClone option is not available sink tables.
-
Select the Integrated service from the drop-down list.
-
In the Table SQL section, update the table name.
noteYou will not be able to add the table if there are errors within the statement.
-
Select Add table to complete the process.
Edit a table
To edit an existing table in an application:
- In the Add source tables or Add sink tables screen, locate the table to edit and click Edit next to it.
- Make the necessary changes to the table and select Save changes to confirm the changes.
Delete a table
To delete a table in an application:
- In the Add source tables or Add sink tables screen, locate the table to delete and click the Delete icon next to it.
- Confirm the deletion by selecting Confirm in the pop-up window.