检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
) //*****************************SQL model*********************************** // Insert data into the DLI data table sparkSession.sql("insert into css_table values(13, 'John'),(22, 'Bob')") // Read data from DLI data table val dataFrame = sparkSession.sql("
')") //*****************************DataFrame model*********************************** // Setting schema val attrTag1Location = new StructField("location", StringType) val attrTag2Name = new StructField("name", StringType) val attrTimestamp = new StructField("
Syntax 1 2 3 4 5 6 7 8 9 create table clickhouseSink ( attr_name attr_type (',' attr_name attr_type)* ) with ( 'connector.type' = clickhouse, 'connector.url' = '', 'connector.table' = '' ); Parameters Table 1 Parameter description Parameter Mandatory Default Value Data
or logback.xml) JAR packages for log output implementation (for example, log4j) The bucket for uploading custom configurations to OBS must be created under the master account.
Syntax 1 2 3 4 5 6 7 8 9 create table clickhouseSink ( attr_name attr_type (',' attr_name attr_type)* ) with ( 'type' = 'clickhouse', 'url' = '', 'table-name' = '' ); Parameter Description Table 2 Parameters Parameter Mandatory Default Value Data Type Description connector
