avn service flink
beta¶
Here you’ll find the full list of commands for avn service flink
.
Manage an Apache Flink® table¶
avn service flink table create
¶
Creates a new Aiven for Apache Flink table.
Parameter |
Information |
---|---|
|
The name of the service |
|
The ID of the integration to use to locate the source/sink table/topic. The integration ID can be found with the integration-list command |
|
The Flink table name |
|
The Aiven for Apache Kafka® topic to be used as source/sink (Only for Kafka integrations) |
|
The Flink connector type for Apache Kafka; possible values are |
|
The Apache Kafka message key format; possible values are |
|
The list of fields to be used as Key for the message |
|
The Apache Kafka message value format; possible values are |
|
The Apache Kafka consumer starting offset; possible values are |
|
The Aiven for PostgreSQL® table name to be used as source/sink (Only for PostgreSQL integrations) |
|
A column from the table schema to use as Flink table partition definition |
|
Creates the Flink table based on the definition of another existing Flink table |
Example: Create a Flink table named KAlert
with:
alert
as source Apache Kafka topickafka
as connector typejson
as value and key data formatthe field
node
as keyearliest-offset
as starting offsetcpu FLOAT, node INT, cpu_percent INT, occurred_at TIMESTAMP_LTZ(3)
as SQL schemaab8dd446-c46e-4979-b6c0-1aad932440c9
as integration IDflink-devportal-demo
as service name
avn service flink table create flink-devportal-demo ab8dd446-c46e-4979-b6c0-1aad932440c9 \
--table-name KAlert \
--kafka-topic alert \
--kafka-connector-type kafka \
--kafka-key-format json \
--kafka-key-fields node \
--kafka-value-format json \
--kafka-startup-mode earliest-offset \
--schema-sql "cpu FLOAT, node INT, cpu_percent INT, occurred_at TIMESTAMP_LTZ(3)"
avn service flink table delete
¶
Deletes an existing Aiven for Apache Flink table.
Parameter |
Information |
---|---|
|
The name of the service |
|
The ID of the table to delete |
Example: Delete the Flink table with ID 8b8ac2fe-b6eb-46bc-b327-fb4b84d27276
belonging to the Aiven for Flink service flink-devportal-demo
.
avn service flink table delete flink-devportal-demo 8b8ac2fe-b6eb-46bc-b327-fb4b84d27276
avn service flink table get
¶
Retrieves the definition of an existing Aiven for Apache Flink table.
Parameter |
Information |
---|---|
|
The name of the service |
|
The ID of the table to retrieve |
Example: Retrieve the definition of the Flink table with ID 8b8ac2fe-b6eb-46bc-b327-fb4b84d27276
belonging to the Aiven for Flink service flink-devportal-demo
.
avn service flink table get flink-devportal-demo 8b8ac2fe-b6eb-46bc-b327-fb4b84d27276
avn service flink table list
¶
Lists all the Aiven for Apache Flink tables in a selected service.
Parameter |
Information |
---|---|
|
The name of the service |
Example: List all the Flink tables available in the Aiven for Flink service flink-devportal-demo
.
avn service flink table list flink-devportal-demo
An example of avn service flink table list
output:
INTEGRATION_ID TABLE_ID TABLE_NAME
==================================== ==================================== ==========
ab8dd446-c46e-4979-b6c0-1aad932440c9 acb601d7-2000-4076-ae58-563aa7d9ab5a KAlert
Manage a Flink job¶
avn service flink job create
¶
Creates a new Aiven for Apache Flink job.
Parameter |
Information |
---|---|
|
The name of the service |
|
Name of the Flink job |
|
List of Flink tables IDs to use as source/sink. Table IDs can be found using the list command |
|
Flink job SQL statement |
Example: Create a Flink job named JobExample
with:
KCpuIn
(with idcac53785-d1b5-4856-90c8-7cbcc3efb2b6
) andKAlert
(with id54c2f4e6-a446-4d62-8dc9-2b81179c6f43
) as source/sink tablesINSERT INTO KAlert SELECT * FROM KCpuIn WHERE cpu_percent > 70
as SQL statementflink-devportal-demo
as service name
avn service flink job create flink-devportal-demo JobExample \
--table-ids cac53785-d1b5-4856-90c8-7cbcc3efb2b6 54c2f4e6-a446-4d62-8dc9-2b81179c6f43 \
--statement "INSERT INTO KAlert SELECT * FROM KCpuIn WHERE cpu_percent > 70"
avn service flink job cancel
¶
Cancels an existing Aiven for Apache Flink job.
Parameter |
Information |
---|---|
|
The name of the service |
|
The ID of the job to delete |
Example: Cancel the Flink job with ID 8b8ac2fe-b6eb-46bc-b327-fb4b84d27276
belonging to the Aiven for Flink service flink-devportal-demo
.
avn service flink job cancel flink-devportal-demo 8b8ac2fe-b6eb-46bc-b327-fb4b84d27276
avn service flink job get
¶
Retrieves the definition of an existing Aiven for Apache Flink job.
Parameter |
Information |
---|---|
|
The name of the service |
|
The ID of the table to retrieve |
Example: Retrieve the definition of the Flink job with ID 8b8ac2fe-b6eb-46bc-b327-fb4b84d27276
belonging to the Aiven for Flink service flink-devportal-demo
.
avn service flink table get flink-devportal-demo 8b8ac2fe-b6eb-46bc-b327-fb4b84d27276
An example of avn service flink job get
output:
JID NAME STATE START-TIME END-TIME DURATION ISSTOPPABLE MAXPARALLELISM
================================ ========== ======= ============= ======== ======== =========== ==============
b63c78c70033e00afa84de9029257e31 JobExample RUNNING 1633336792083 -1 423503 false 96
avn service flink job list
¶
Lists all the Aiven for Apache Flink jobs in a selected service.
Parameter |
Information |
---|---|
|
The name of the service |
Example: List all the Flink jobs available in the Aiven for Flink service flink-devportal-demo
.
avn service flink jobs list flink-devportal-demo
An example of avn service flink job list
output:
ID STATUS
================================ =======
b63c78c70033e00afa84de9029257e31 RUNNING