Skip to main content

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
important

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:

  1. 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.

  2. Select Create new version.

  3. On the Create new version screen, go to the Add source tables or Add sink tables screen within your application.

  4. Select Add new table to add a new table to your application.

    note

    If you already have a sink table listed, you must delete it before adding a new one, only one sink table is allowed per job.

  5. Select the Integrated service from the drop-down list in the Add new source table or Add new sink table screen, respectively.

  6. 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.

  7. Select Add table to complete the process.

Import an existing table​

To import an existing table from another application:

  1. In the Add source tables or Add sink tables screen, select Import existing table to import a table to your application.

    note

    If you already have a sink table listed, you must delete it before importing a new one.

  2. 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.

  3. Select Next.

  4. 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:

  1. In the Add source tables screen, locate the table to clone and click Clone next to it.

    note

    Clone option is not available sink tables.

  2. Select the Integrated service from the drop-down list.

  3. In the Table SQL section, update the table name.

    note

    You will not be able to add the table if there are errors within the statement.

  4. Select Add table to complete the process.

Edit a table​

To edit an existing table in an application:

  1. In the Add source tables or Add sink tables screen, locate the table to edit and click Edit next to it.
  2. 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:

  1. In the Add source tables or Add sink tables screen, locate the table to delete and click the Delete icon next to it.
  2. Confirm the deletion by selecting Confirm in the pop-up window.