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

CdcPartitionsCreatorDebeziumOperations

interface CdcPartitionsCreatorDebeziumOperations<T : Comparable<T>>

Inheritors

Functions

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

Maps an incumbent OpaqueStateValue into a DebeziumWarmStartState.

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(offset: DebeziumOffset): T

Extracts the WAL position from a DebeziumOffset.