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

TriggerPartitionsCreatorFactorySupplier

@Singleton
@Primary
@Requires(property = "airbyte.connector.extract.jdbc.mode", value = "concurrent_with_cdc")
class TriggerPartitionsCreatorFactorySupplier<A : JdbcSharedState, S : JdbcStreamState<A>, P : JdbcPartition<S>>(factory: TriggerPartitionsCreatorFactory<A, S, P>) : PartitionsCreatorFactorySupplier<TriggerPartitionsCreatorFactory<A, S, P>>

Constructors

Link copied to clipboard
constructor(factory: TriggerPartitionsCreatorFactory<A, S, P>)

Functions

Link copied to clipboard
open override fun get(): TriggerPartitionsCreatorFactory<A, S, P>