broker/ru.sydis.broker.implementations.streams

Package-level declarations

Types

Link copied to clipboard
class BaseMessageStream<K, V>

Реализация топологии конвеера обработчиков

Link copied to clipboard
open class BaseSinkProcessor<K, V : Any>(broker: MessageBroker<K, V>, topic: String) : Processor<K, V>
Link copied to clipboard
class BaseSourceProcessor<K : Any, V : Any>(brokerProps: Map<String, Any>, topic: String, keyClass: Class<K>, valClass: Class<V>) : SourceProcessor<K, V>
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open class PartitionedSourceProcessor<K : Any, V : Any>(brokerProps: Map<String, Any>, topic: String, pCount: Int = 1, pSplitter: String = "", keyClass: Class<K>, valClass: Class<V>, checkProcessing: ICheckProcessing = object : ICheckProcessing { override fun check(): Boolean { return true } }) : SourceProcessor<K, V>
Link copied to clipboard
data class StreamRecord<K, V>(val key: K, val value: V, val ts: Long = System.currentTimeMillis())