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

JdbcSequentialPartitionsCreatorFactory

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

Sequential 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>