This is issue is to add Calcite as a dialect for SQL, and Flink Table API as a DBAPI provider. The aim is to enable relational algebra on query conditions of streams.
The difference in dialect is mainly the following (the following applies to Flink):
Data Type: STRING, BYTES, RAW, TIME(p) WITHOUT TIME ZONE, TIME(p) WITH LOCAL TIME ZONE, TIMESTAMP(p) WITHOUT TIME ZONE, TIMESTAMP(p) WITH LOCAL TIME ZONE, ARRAY, MULTISET, ROW are not supported
This is issue is to add
Calcite
as a dialect forSQL
, andFlink Table API
as a DBAPI provider. The aim is to enable relational algebra on query conditions of streams.The difference in dialect is mainly the following (the following applies to Flink):
STRING, BYTES, RAW, TIME(p) WITHOUT TIME ZONE, TIME(p) WITH LOCAL TIME ZONE, TIMESTAMP(p) WITHOUT TIME ZONE, TIMESTAMP(p) WITH LOCAL TIME ZONE, ARRAY, MULTISET, ROW
are not supportedThe difference in feature is mainly the following (the following applies to Flink):
CREATE TABLE
stage matters