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

JdbcPartitionsCreatorFactory

abstract class JdbcPartitionsCreatorFactory<A : JdbcSharedState, S : JdbcStreamState<A>, P : JdbcPartition<S>>(val partitionFactory: JdbcPartitionFactory<A, S, P>) : PartitionsCreatorFactory

Base class for JDBC implementations of PartitionsCreatorFactory.

Inheritors

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
abstract fun partitionsCreator(partition: P): JdbcPartitionsCreator<A, S, P>