This repository is no longer maintained. The project has been transfered to the QuestDB organization and it's maintained there.
Apache Flink Table & SQL Connector for QuestDB
Apache Flink Sink for QuestDB via ILP protocol.
- Start local QuestDB
- Start install and start Apache Flink
- Start Apache Flink SQL Console
- 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'
)- Insert an item into the table created in the previous step:
insert into questTable (a, b) values (42, 'foobar');- Flink should create a table
flink_tablein QuestDB and eventually insert a new row into it.
TODO: Connector installation!