bulk-cdk-toolkit-extract-jdbc/io.airbyte.cdk.read/JdbcConcurrentPartitionsCreatorFactory

JdbcConcurrentPartitionsCreatorFactory

@Singleton
@Secondary
@Requires(property = "airbyte.connector.extract.jdbc.mode", value = "concurrent")
class JdbcConcurrentPartitionsCreatorFactory<A : JdbcSharedState, S : JdbcStreamState<A>, P : JdbcPartition<S>>(partitionFactory: JdbcPartitionFactory<A, S, P>) : JdbcPartitionsCreatorFactory<A, S, P>

Concurrent JDBC implementation of PartitionsCreatorFactory.

Constructors

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

Properties

Link copied to clipboard

Functions

Link copied to clipboard
open override fun make(feedBootstrap: FeedBootstrap<*>): PartitionsCreator?
Link copied to clipboard
open override fun partitionsCreator(partition: P): JdbcPartitionsCreator<A, S, P>