Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-toolkit-extract-trigger/io.airbyte.cdk/TriggerPartitionFactory

TriggerPartitionFactory

@Primary

@Singleton

class TriggerPartitionFactory(val sharedState: DefaultJdbcSharedState, val handler: CatalogValidationFailureHandler, val selectQueryGenerator: SelectQueryGenerator, config: TriggerTableConfig) : JdbcPartitionFactory<DefaultJdbcSharedState, TriggerStreamState, TriggerPartition>

Constructors

TriggerPartitionFactory

constructor(sharedState: DefaultJdbcSharedState, handler: CatalogValidationFailureHandler, selectQueryGenerator: SelectQueryGenerator, config: TriggerTableConfig)

Properties

val handler: CatalogValidationFailureHandler

selectQueryGenerator

val selectQueryGenerator: SelectQueryGenerator

open override val sharedState: DefaultJdbcSharedState

Functions

open override fun create(streamFeedBootstrap: StreamFeedBootstrap): TriggerPartition?

open override fun split(unsplitPartition: TriggerPartition, opaqueStateValues: List<OpaqueStateValue>): List<TriggerPartition>

open override fun streamState(streamFeedBootstrap: StreamFeedBootstrap): TriggerStreamState