ClickHouseSinkOptions
class ClickHouseSinkOptions @InternalWowApi constructor(val database: String = DEFAULT_DATABASE, val ddl: Ddl = Ddl.AUTO, val batchSize: Int = DEFAULT_BATCH_SIZE, val deduplicationWindow: Int = DEFAULT_DEDUPLICATION_WINDOW, val aggregates: Map<AggregateType, AggregateSinkOptions> = emptyMap())
The ClickHouse Sink's options.
database: where its tables are.
ddl: whether it creates, validates or leaves its tables (Ddl).
batchSize: the most records one
INSERTcarries.deduplicationWindow: the
non_replicated_deduplication_windowof the tables it creates: how many recent insert blocks each remembers, so that a retried insert (the sameref@versiontoken) is dropped.aggregates: per aggregate type, how its commits are kept; AggregateSinkOptions defaults else.
Fields may be added: Wow builds it from the host's configuration, so the constructor is internal to Wow.
Constructors
Link copied to clipboard
constructor(database: String = DEFAULT_DATABASE, ddl: Ddl = Ddl.AUTO, batchSize: Int = DEFAULT_BATCH_SIZE, deduplicationWindow: Int = DEFAULT_DEDUPLICATION_WINDOW, aggregates: Map<AggregateType, AggregateSinkOptions> = emptyMap())