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

TriggerPartitionsCreatorFactory

@Singleton
@Requires(property = "airbyte.connector.extract.jdbc.mode", value = "concurrent_with_cdc")
class TriggerPartitionsCreatorFactory<A : JdbcSharedState, S : JdbcStreamState<A>, P : JdbcPartition<S>>(val partitionFactory: JdbcPartitionFactory<A, S, P>, val config: TriggerTableConfig, val deleteQuerier: DeleteQuerier) : PartitionsCreatorFactory

Concurrent JDBC implementation of PartitionsCreatorFactory. Support trigger based CDC only

Constructors

Link copied to clipboard
constructor(partitionFactory: JdbcPartitionFactory<A, S, P>, config: TriggerTableConfig, deleteQuerier: DeleteQuerier)

Properties

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard

Functions

Link copied to clipboard
open override fun make(feedBootstrap: FeedBootstrap<*>): PartitionsCreator?