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

CdcPartitionsCreatorDebeziumOperations

interface CdcPartitionsCreatorDebeziumOperations<T : PartiallyOrdered<T>>

Inheritors

Types

Link copied to clipboard
object Companion

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.

Link copied to clipboard
open fun runStartup(offset: DebeziumOffset)

Run optional startup hook if it hasn't already been run

Link copied to clipboard
open fun startup(offset: DebeziumOffset)

Optional startup hook.