JdbcPartitionsCreator

abstract class JdbcPartitionsCreator<A : JdbcSharedState, S : JdbcStreamState<A>, P : JdbcPartition<S>>(val partition: P, val partitionFactory: JdbcPartitionFactory<A, S, P>) : PartitionsCreator

Base class for JDBC implementations of PartitionsCreator.

Inheritors

Constructors

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

Types

Link copied to clipboard

Calling close releases the resources acquired for the JdbcPartitionsCreator.

Properties

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard

Functions

Link copied to clipboard
fun <T> collectSample(recordMapper: (ObjectNode) -> T): Sample<T>

Collects a sample of rows in the unsplit partition.

Link copied to clipboard
Link copied to clipboard
open override fun releaseResources()
Link copied to clipboard
abstract suspend fun run(): List<PartitionReader>