Updated on 2025-03-06 GMT+08:00

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.

For details, see Source Table and Dimension Table.