Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-core-load/io.airbyte.cdk.load.table.directload

Package-level declarations

Types

DirectLoadInitialStatus

data class DirectLoadInitialStatus(val realTable: DirectLoadTableStatus?, val tempTable: DirectLoadTableStatus?) : DatabaseInitialStatus

DirectLoadTableAppendStreamLoader

class DirectLoadTableAppendStreamLoader(val stream: DestinationStream, initialStatus: DirectLoadInitialStatus, realTableName: TableName, tempTableName: TableName, columnNameMapping: ColumnNameMapping, schemaEvolutionClient: TableSchemaEvolutionClient, tableOperationsClient: TableOperationsClient, streamStateStore: StreamStateStore<DirectLoadTableExecutionConfig>) : StreamLoader

Stream loader implementation for append mode.

DirectLoadTableAppendTruncateStreamLoader

class DirectLoadTableAppendTruncateStreamLoader(val stream: DestinationStream, initialStatus: DirectLoadInitialStatus, realTableName: TableName, tempTableName: TableName, columnNameMapping: ColumnNameMapping, schemaEvolutionClient: TableSchemaEvolutionClient, tableOperationsClient: TableOperationsClient, streamStateStore: StreamStateStore<DirectLoadTableExecutionConfig>) : StreamLoader

Stream loader implementation for append + truncate mode.

DirectLoadTableDedupStreamLoader

class DirectLoadTableDedupStreamLoader(val stream: DestinationStream, initialStatus: DirectLoadInitialStatus, realTableName: TableName, tempTableName: TableName, columnNameMapping: ColumnNameMapping, schemaEvolutionClient: TableSchemaEvolutionClient, tableOperationsClient: TableOperationsClient, streamStateStore: StreamStateStore<DirectLoadTableExecutionConfig>) : StreamLoader

Stream loader implementation for deduplication mode.

DirectLoadTableDedupTruncateStreamLoader

class DirectLoadTableDedupTruncateStreamLoader(val stream: DestinationStream, initialStatus: DirectLoadInitialStatus, realTableName: TableName, tempTableName: TableName, columnNameMapping: ColumnNameMapping, schemaEvolutionClient: TableSchemaEvolutionClient, tableOperationsClient: TableOperationsClient, streamStateStore: StreamStateStore<DirectLoadTableExecutionConfig>, tempTableNameGenerator: TempTableNameGenerator) : StreamLoader

Stream loader implementation for deduplication + truncate mode.

DirectLoadTableExecutionConfig

data class DirectLoadTableExecutionConfig(val tableName: TableName)

DirectLoadTableStatus

data class DirectLoadTableStatus(val isEmpty: Boolean)