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

Package-level declarations

Types

Link copied to clipboard
@DefaultImplementation(value = JdbcDeleteQuerier::class)
interface DeleteQuerier

Interface for executing delete queries against a database.

Link copied to clipboard
@Singleton
class JdbcDeleteQuerier(jdbcConnectionFactory: JdbcConnectionFactory) : DeleteQuerier

Default implementation of DeleteQuerier for JDBC connections.

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
class TriggerCursorIncrementalPartition(val selectQueryGenerator: SelectQueryGenerator, val streamState: TriggerStreamState, config: TriggerTableConfig, val cursor: Field, val triggerCdcPartitionState: TriggerCdcPartitionState? = null, val cursorLowerBound: JsonNode, val isLowerBoundIncluded: Boolean, cursorUpperBound: JsonNode?) : TriggerCursorPartition

Trigger-based implementation of a JdbcPartition for a cursor incremental partition. These are always splittable.

Link copied to clipboard
sealed class TriggerCursorPartition : TriggerSplittablePartition, JdbcCursorPartition<TriggerStreamState>

Default implementation of a JdbcPartition for a splittable partition involving cursor columns.

Link copied to clipboard
class TriggerNonResumablePartitionReader<P : JdbcPartition<*>>(partition: P, config: TriggerTableConfig, val deleteQuerier: DeleteQuerier) : TriggerPartitionReader<P>

Trigger-based implementation of PartitionReader which reads the partition in its entirety.

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
abstract class TriggerPartitionReader<P : JdbcPartition<*>>(val partition: P, config: TriggerTableConfig) : UnlimitedTimePartitionReader

Base class for Trigger-based CDC implementations of PartitionReader using JDBC.

Link copied to clipboard
class TriggerPartitionsCreator<A : JdbcSharedState, S : JdbcStreamState<A>, P : JdbcPartition<S>>(val partition: P, val partitionFactory: JdbcPartitionFactory<A, S, P>, val config: TriggerTableConfig, val deleteQuerier: DeleteQuerier) : PartitionsCreator

Concurrent Trigger-based implementation of PartitionsCreator.

Link copied to clipboard
@Singleton
@Requires(property = "airbyte.connector.extract.jdbc.mode", value = "concurrent_with_cdc")
class TriggerPartitionsCreatorFactory<A : JdbcSharedState, S : JdbcStreamState<A>, P : JdbcPartition<S>>(val partitionFactory: JdbcPartitionFactory<A, S, P>, val config: TriggerTableConfig, val deleteQuerier: DeleteQuerier) : PartitionsCreatorFactory

Concurrent JDBC implementation of PartitionsCreatorFactory. Support trigger based CDC only

Link copied to clipboard
@Singleton
@Primary
@Requires(property = "airbyte.connector.extract.jdbc.mode", value = "concurrent_with_cdc")
class TriggerPartitionsCreatorFactorySupplier<A : JdbcSharedState, S : JdbcStreamState<A>, P : JdbcPartition<S>>(factory: TriggerPartitionsCreatorFactory<A, S, P>) : PartitionsCreatorFactorySupplier<TriggerPartitionsCreatorFactory<A, S, P>>
Link copied to clipboard
sealed class TriggerSplittablePartition : TriggerPartition, JdbcSplittablePartition<TriggerStreamState>

Base class for trigger-based implementations of JdbcPartition for splittable partitions.

Link copied to clipboard
class TriggerSplittableSnapshotPartition(val selectQueryGenerator: SelectQueryGenerator, val streamState: TriggerStreamState, config: TriggerTableConfig, primaryKey: List<Field>, val triggerCdcPartitionState: TriggerCdcPartitionState? = null, val lowerBound: List<JsonNode>?, val upperBound: List<JsonNode>?) : TriggerSplittablePartition

Default implementation of a JdbcPartition for a splittable snapshot partition.

class TriggerSplittableSnapshotWithCursorPartition(val selectQueryGenerator: SelectQueryGenerator, val streamState: TriggerStreamState, config: TriggerTableConfig, primaryKey: List<Field>, val triggerCdcPartitionState: TriggerCdcPartitionState? = null, val lowerBound: List<JsonNode>?, val upperBound: List<JsonNode>?, val cursor: Field, cursorUpperBound: JsonNode?) : TriggerCursorPartition

Trigger-based implementation of a JdbcPartition for a splittable snapshot partition preceding a cursor-based incremental sync.

Link copied to clipboard
class TriggerStreamState(val sharedState: DefaultJdbcSharedState, val streamFeedBootstrap: StreamFeedBootstrap) : JdbcStreamState<DefaultJdbcSharedState>

Implementation of JdbcStreamState for Trigger-based CDC.

Link copied to clipboard
class TriggerStreamStateValue(val primaryKey: Map<String, JsonNode> = mapOf(), val cursors: Map<String, JsonNode> = mapOf())
Link copied to clipboard
abstract class TriggerTableConfig

Trigger table related constants, schema etc. Trigger table naming convention: TRIGGER_TABLE_PREFIX + + .

Link copied to clipboard
sealed class TriggerUnsplittablePartition : TriggerPartition

Base class for trigger-based implementations of JdbcPartition for unsplittable partitions.

Link copied to clipboard
class TriggerUnsplittableSnapshotPartition(val selectQueryGenerator: SelectQueryGenerator, val streamState: TriggerStreamState, config: TriggerTableConfig) : TriggerUnsplittablePartition

Trigger-based implementation of a JdbcPartition for an unsplittable snapshot partition.

class TriggerUnsplittableSnapshotWithCursorPartition(val selectQueryGenerator: SelectQueryGenerator, val streamState: TriggerStreamState, val cursor: Field, config: TriggerTableConfig) : TriggerUnsplittablePartition, JdbcCursorPartition<TriggerStreamState>

Trigger-based implementation of a JdbcPartition for an unsplittable snapshot partition preceding a cursor-based incremental sync.