Airbyte Kotlin Bulk CDK

1.0.2

bulk-cdk-toolkit-extract-trigger/io.airbyte.cdk/TriggerStreamState

TriggerStreamState

class TriggerStreamState(val sharedState: DefaultJdbcSharedState, val streamFeedBootstrap: StreamFeedBootstrap) : JdbcStreamState<DefaultJdbcSharedState>

Implementation of JdbcStreamState for Trigger-based CDC.

Constructors

TriggerStreamState

constructor(sharedState: DefaultJdbcSharedState, streamFeedBootstrap: StreamFeedBootstrap)

Properties

cursorUpperBound

open override var cursorUpperBound: JsonNode?

open override var fetchSize: Int?

fetchSizeOrDefault

open override val fetchSizeOrDefault: Int

isReadingFromTriggerTable

var isReadingFromTriggerTable: Boolean

open override val limit: Long

open override val sharedState: DefaultJdbcSharedState

open val stream: Stream

streamFeedBootstrap

open override val streamFeedBootstrap: StreamFeedBootstrap

Functions

open override fun reset()

updateLimitState

open override fun updateLimitState(fn: (LimitState) -> LimitState)

validatePartition

open fun validatePartition(partition: JdbcPartition<*>, jdbcConnectionFactory: JdbcConnectionFactory)