Introduction to Flink SQL

DWS-connector can connect to GaussDB(DWS) tables as a source table, result table, and dimension table for Flink jobs by implementing the DynamicTableSourceFactory and DynamicTableSinkFactory interfaces.

When used as the source table, DWS-Connector can push down limit and where conditions to the database for execution by implementing the SupportsLimitPushDown and SupportsFilterPushDown interfaces.

When DWS-Connector is used as the result table, the SQL syntax format may vary slightly in different Flink environments. The precise SQL syntax format is contingent upon the specific environment format.

For details, see Source Table, Result Table, and Dimension Table.