Overview

This section describes the Flink open source SQL 1.12 syntax supported by DLI. For details about the parameters and examples, see the syntax description.

Creating Tables

Table 1 Syntax for creating tables

Classification	Function
Creating a source table	DataGen Source Table
	GaussDB(DWS) Source Table
	HBase Source Table
	JDBC Source Table
	Kafka Source Table
	MySQL CDC Source Table
	Postgres CDC Source Table
	Redis Source Table
	Upsert Kafka Source Table
Creating a result table	BlackHole Result Table
	ClickHouse Result Table
	GaussDB(DWS) Result Table
	Elasticsearch Result Table
	HBase Result Table
	JDBC Result Table
	Kafka Result Table
	Print Result Table
	Redis Result Table
	Upsert Kafka Result Table
Creating a dimension table	GaussDB(DWS) Dimension Table
	HBase Dimension Table
	JDBC Dimension Table
	Redis Dimension Table
Format	Avro
	Canal
	Confluent Avro
	CSV
	Debezium
	JSON
	Maxwell
	Raw

last updated: 2025-02-13 16:25 UTC - commit: 17367e42c9c12af57bae86cbe2bad77e571dc82c