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

DebeziumOperations

interface DebeziumOperations<T : Comparable<T>> : CdcPartitionsCreatorDebeziumOperations<T> , CdcPartitionReaderDebeziumOperations<T>

Deprecated

Implement the two interfaces separately

Stateless connector-specific Debezium operations.

Functions

Link copied to clipboard
Link copied to clipboard
abstract fun deserializeState(opaqueStateValue: OpaqueStateValue): DebeziumWarmStartState

Maps an incumbent OpaqueStateValue into a DebeziumWarmStartState.

Link copied to clipboard
abstract fun findStreamName(key: DebeziumRecordKey, value: DebeziumRecordValue): String?

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

Link copied to clipboard
abstract fun findStreamNamespace(key: DebeziumRecordKey, value: DebeziumRecordValue): String?

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

Link copied to clipboard
abstract fun generateColdStartOffset(): DebeziumOffset

Synthesizes a DebeziumColdStartingState when no incumbent OpaqueStateValue is available.

Link copied to clipboard
abstract fun generateColdStartProperties(streams: List<Stream>): Map<String, String>

Generates Debezium properties for use with a DebeziumColdStartingState.

Link copied to clipboard
abstract fun generateWarmStartProperties(streams: List<Stream>): Map<String, String>

Generates Debezium properties for use with a ValidDebeziumWarmStartState.

Link copied to clipboard
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 position(offset: DebeziumOffset): T

Extracts the WAL position from a DebeziumOffset.

Link copied to clipboard
abstract fun serializeState(offset: DebeziumOffset, schemaHistory: DebeziumSchemaHistory?): OpaqueStateValue

Maps a Debezium state to an OpaqueStateValue.