Hello everyone,
I am currently working on a project to extend the functionalities of SQL to
support more stream-computing features on Apache Flink which uses Calcite
to cope with SQL processing.
Currently the features provided by Calcite are not enough for my project
and I would like to know if there is a way to add custom grammar like
CREATE TABLE my_table (
id bigint,
user varchar(20)
) *PARAMS *(
connector 'kafka',
topic 'my_topic'
)
which uses something like *PARAMS *to define how to receive data from a
Kafka connector and treat it like a dynamic table as a data source to Flink.
Also, I would like to add features like "CREATE STREAM" statement in Amazon
Kinesis
<https://docs.aws.amazon.com/kinesisanalytics/latest/sqlref/sql-reference-create-stream.html>,
even though I know that this might be a tough task.
Since there is so little information about this on the Internet, I would
greatly appreciate it if someone of you could provide some hints or
anything useful.
Thank you : )
Sincerely,
Weike
