代码拉取完成,页面将自动刷新
cp clickhouse-jdbc-0.2.4.jar /flink/lib
cp flink-connector-jdbc_2.11-1.11.1.jar /flink/lib
cp guava-19.0.jar /flink/lib
%flink.conf
flink.yarn.appName zeppelin-test-ch
flink.execution.jars /Users/lucas/IdeaProjects/microi/flink-microi-conn/clickhouse/target/clickhouse-1.0-SNAPSHOT.jar
%flink.ssql
DROP TABLE IF EXISTS ch;
CREATE TABLE ch (
id String,
name String,
age String,
create_date Date
) WITH (
'connector' = 'clickhouse',
'url' = 'jdbc:clickhouse://172.16.8.164:8123,172.16.8.165:8123,172.16.8.166:8123/dc2', -- 可配置集群地址,写入时随机选择连接写入,不会一直使用一个连接写入
'table-name' = 'user_name',
'username' = 'default',
'password' = '',
'format' = 'json'
);
%flink.ssql(type=update)
select * from ch;
%flink.ssql(type=update)
insert into ch
select '8' as id, '3' as name, '4' as age, cast('2020-01-03' as DATE) as create_date
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。