JdbcPartitionCreatorFactorySupplier

@Singleton
@Requires(property = "airbyte.connector.extract.jdbc.mode", pattern = "^(sequential|concurrent)$")
class JdbcPartitionCreatorFactorySupplier<T : JdbcPartitionsCreatorFactory<A, S, P>, A : JdbcSharedState, S : JdbcStreamState<A>, P : JdbcPartition<S>>(val factory: T) : PartitionsCreatorFactorySupplier<T>

Constructors

Link copied to clipboard
constructor(factory: T)

Properties

Link copied to clipboard
val factory: T

Functions

Link copied to clipboard
open override fun get(): T