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

DefaultJdbcPartitionFactory

@Singleton
class DefaultJdbcPartitionFactory(val sharedState: DefaultJdbcSharedState, val handler: CatalogValidationFailureHandler, val selectQueryGenerator: SelectQueryGenerator) : JdbcPartitionFactory<DefaultJdbcSharedState, DefaultJdbcStreamState, DefaultJdbcPartition>

Default implementation of JdbcPartitionFactory.

Constructors

Link copied to clipboard
constructor(sharedState: DefaultJdbcSharedState, handler: CatalogValidationFailureHandler, selectQueryGenerator: SelectQueryGenerator)

Properties

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open override val sharedState: DefaultJdbcSharedState

The state shared by all partitions. Includes global resources.

Functions

Link copied to clipboard
open override fun create(streamFeedBootstrap: StreamFeedBootstrap): DefaultJdbcPartition?

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
open override fun split(unsplitPartition: DefaultJdbcPartition, opaqueStateValues: List<OpaqueStateValue>): List<DefaultJdbcPartition>

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

Link copied to clipboard
open override fun streamState(streamFeedBootstrap: StreamFeedBootstrap): DefaultJdbcStreamState

Get or create the JdbcStreamState for a Stream.