Introduction to Flink SQL
DWS-connector can connect to 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 Tables, Result Tables, and Dimension Tables. The following table describes the mapping between DWS data types and Flink SQL data types during Flink SQL compilation.
| DWS | Flink SQL | Remarks |
|---|---|---|
| TINYINT | TINYINT | -- |
| SMALLINT | -- |
| INT | BINARY_INTEGER is used for Oracle compatibility. |
| BIGINT | -- |
| FLOAT | -- |
| DOUBLE | BINARY_DOUBLE is used for Oracle compatibility. |
| DECIMAL(p, s) | -- |
| BOOLEAN | -- |
| DATE | DATE | -- |
| TIME [(p)] [WITHOUT TIMEZONE] | TIME [(p)] [WITHOUT TIMEZONE] | -- |
| TIMESTAMP [(p)] [WITHOUT TIMEZONE] | TIMESTAMP [(p)] [WITHOUT TIMEZONE] | -- |
| TIMESTAMP [(p)] [WITH TIMEZONE] | TIMESTAMP_LTZ [(p)] | -- |
|
| -- |
|
| VARCHAR2 (n) and CLOB are used for Oracle compatibility. |
| BYTEA | BYTES | -- |
| -- |
| Not supported |
What is your overall rating for this page?
Thank you very much for your feedback. We will continue working to improve the documentation.See the reply and handling status in My Cloud VOC.
For any further questions, feel free to contact us through the chatbot.
Chatbot
