An IO to write to ClickHouse.
Writing to ClickHouse
To write to ClickHouse, use
write(String, String), which writes elements
PCollection. It's required that your ClickHouse cluster already has table you
are going to insert into.
Optionally, you can provide connection settings, for instance, specify insert block size with
ClickHouseIO.Write.withMaxInsertBlockSize(long), or configure number of retries with
Deduplication is performed by ClickHouse if inserting to ReplicatedMergeTree
table on top of
ReplicatedMergeTree. Without replication, inserting into regular MergeTree can produce
duplicates, if insert fails, and then successfully retries. However, each block is inserted
atomically, and you can configure block size with
Deduplication is performed using checksums of inserted blocks.
Mapping between Beam and ClickHouse types
Nullable row columns are supported through Nullable type in ClickHouse.
Nested rows should be unnested using
Select.flattenedSchema(). Type casting should be