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

JdbcPartitionFactory

@DefaultImplementation(value = DefaultJdbcPartitionFactory::class)
interface JdbcPartitionFactory<A : JdbcSharedState, S : JdbcStreamState<A>, P : JdbcPartition<S>>

Encapsulates database-specific logic turning OpaqueStateValue into JdbcPartition.

Inheritors

Properties

Link copied to clipboard
abstract val sharedState: A

The state shared by all partitions. Includes global resources.

Functions

Link copied to clipboard
abstract fun create(streamFeedBootstrap: StreamFeedBootstrap): P?

Deserializes the current OpaqueStateValue and creates a JdbcPartition instance corresponding to all remaining unread data in the Stream, if any; null otherwise.

Link copied to clipboard
abstract fun split(unsplitPartition: P, opaqueStateValues: List<OpaqueStateValue>): List<P>

Subdivides the unsplitPartition by splitting at the opaqueStateValues, if possible.

Link copied to clipboard
abstract fun streamState(streamFeedBootstrap: StreamFeedBootstrap): S

Get or create the JdbcStreamState for a Stream.