xtdb-kafka/xtdb.kafka.connectsrc/DocsIndexer

DocsIndexer

class DocsIndexer(table: TableRef) : RecordIndexer

Constructors

Link copied to clipboard
constructor(table: TableRef)

Types

Link copied to clipboard
@Serializable
@SerialName(value = "!Docs")
data class Factory(val table: String) : RecordIndexer.Factory

Functions

Link copied to clipboard
open override fun close()
Link copied to clipboard
open suspend override fun indexRecords(records: List<SinkRecord>, txIndexer: TxIndexer)
Generated by Dokka
© 2026 Copyright