liufangliang created BAHIR-234:
----------------------------------
Summary: add ClickHouse Connector for Flink
Key: BAHIR-234
URL: https://issues.apache.org/jira/browse/BAHIR-234
Project: Bahir
Issue Type: New Feature
Components: Flink Streaming Connectors
Affects Versions: Flink-1.0
Reporter: liufangliang
[ClickHouse website : https://clickhouse.tech/|https://clickhouse.tech/]
ClickHouse is a column-oriented database management system (DBMS) for online
analytical processing of queries (OLAP)
we can add flink connector for ClickHouse，including Streaming Implement &
Table API & SQL.
CREATE TABLE test (
d BIGINT,
s VARCHAR(10)
) WITH (
'connector.properties.bootstrap.servers'='localhost:9092',
'connector.properties.group.id'='testclickhouse',
'connector.properties.zookeeper.connect'='localhost:2181',
'connector.startup-mode'='latest-offset',
'connector.topic'='flinksql',
'connector.type'='kafka',
'connector.version'='universal',
'format.type'='json',
'format.derive-schema' = 'true',
'update-mode'='append'
);
CREATE TABLE test2 (
usrname STRING,
size BIGINT
) WITH (
'connector.type'='clickhouse',
'connector.version'='1',
'connector.property-version'='1',
'connector.address'='localhost:8123',
'connector.database'='test',
'connector.table'='insert_test',
'connector.username'='admin',
'connector.password'='admin',
'connector.commit.batch.size'='1',
'connector.commit.padding'='2000',
'connector.commit.retry.attempts'='3',
'connector.commit.retry.interval'='3000',
'connector.commit.ignore.error'='FALSE'
);
insert into test2 select s as usrname ,d as size from test ;
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
