sylph
sylph copied to clipboard
add clickhouse-sink support
create sink table flink2ck( key varchar, message varchar, event_time date ) with( type = 'ideal.sylph.plugins.clickhouse.ClickHouseSink', userName = 'default', password ='default', bulkSize = 20000 -- 默认20000 url = 'jdbc:clickhouse://localhost:9000', query = 'insert into flink2ck values(?,?,?)' );
Very looking forward to