Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-toolkit-extract-cdc/io.airbyte.cdk.read.cdc/CdcPartitionReaderDebeziumOperations

CdcPartitionReaderDebeziumOperations

interface CdcPartitionReaderDebeziumOperations<T : Comparable<T>>

Inheritors

DebeziumOperations

Functions

deserializeRecord

abstract fun deserializeRecord(key: DebeziumRecordKey, value: DebeziumRecordValue, stream: Stream): DeserializedRecord?

Transforms a DebeziumRecordKey and a DebeziumRecordValue into a DeserializedRecord.

abstract fun findStreamName(key: DebeziumRecordKey, value: DebeziumRecordValue): String?

Identifies the null of the stream that this event belongs to, if applicable.

findStreamNamespace

abstract fun findStreamNamespace(key: DebeziumRecordKey, value: DebeziumRecordValue): String?

Identifies the namespace of the stream that this event belongs to, if applicable.

abstract fun position(recordValue: DebeziumRecordValue): T?

Tries to extract the WAL position from a DebeziumRecordValue.

abstract fun position(sourceRecord: SourceRecord): T?

Tries to extract the WAL position from a SourceRecord.

abstract fun serializeState(offset: DebeziumOffset, schemaHistory: DebeziumSchemaHistory?): OpaqueStateValue

Maps a Debezium state to an OpaqueStateValue.