⚠️ Deprecation Notice ⚠️

This repository is no longer maintained. The project has been transfered to the QuestDB organization and it's maintained there.

flink-connector-questdb

Apache Flink Table & SQL Connector for QuestDB

Apache Flink Sink for QuestDB via ILP protocol.

Example

1. Start local QuestDB
2. Start install and start Apache Flink
3. Start Apache Flink SQL Console
4. Create a dynamic table in Flink SQL Console:

CREATE TABLE questTable (a BIGINT NOT NULL, b STRING) WITH (
'connector'='questdb',
'host'='localhost',
'table'='flink_table'
)

5. Insert an item into the table created in the previous step:

insert into questTable (a, b) values (42, 'foobar');

6. Flink should create a table flink_table in QuestDB and eventually insert a new row into it.

TODO: Connector installation!