StreamSinks

The sinks of one destination, one per published stream: the subscription that writes the stream of aggregate in context is named <processor>.<aggregate> and writes through sinkOf. close closes what they share, after the node has stopped.

Properties

Link copied to clipboard
abstract val processor: String

The name the sink subscriptions take, before the aggregate's: wow.clickhouse-sink say.

Functions

Link copied to clipboard
open override fun close()
Link copied to clipboard
abstract fun sinkOf(context: String, aggregate: String): Sink

The sink of the stream context publishes of aggregate.