Airbyte Kotlin Bulk CDK

1.0.2

bulk-cdk-toolkit-legacy-task-load-db/io.airbyte.cdk.load.orchestration.db.direct_load_table

Package-level declarations

Types

AlterTableReport

data class AlterTableReport<Type>(val columnsToAdd: List<ColumnAdd<Type>>, val columnsToRemove: List<String>, val columnsToChangeType: List<ColumnChange<Type>>, val columnsToRetain: List<String>)

data class ColumnAdd<Type>(val name: String, val type: Type)

data class ColumnChange<Type>(val name: String, val originalType: Type, val newType: Type)

DefaultDirectLoadTableSqlOperations

open class DefaultDirectLoadTableSqlOperations(generator: DirectLoadSqlGenerator, handler: DatabaseHandler) : DirectLoadTableSqlOperations

DirectLoadInitialStatus

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

DirectLoadSqlGenerator

interface DirectLoadSqlGenerator

DirectLoadTableAppendStreamLoader

class DirectLoadTableAppendStreamLoader(val stream: DestinationStream, initialStatus: DirectLoadInitialStatus, realTableName: TableName, tempTableName: TableName, columnNameMapping: ColumnNameMapping, nativeTableOperations: DirectLoadTableNativeOperations, sqlTableOperations: DirectLoadTableSqlOperations, streamStateStore: StreamStateStore<DirectLoadTableExecutionConfig>) : StreamLoader

Stream loader implementation for append mode.

DirectLoadTableAppendTruncateStreamLoader

class DirectLoadTableAppendTruncateStreamLoader(val stream: DestinationStream, initialStatus: DirectLoadInitialStatus, realTableName: TableName, tempTableName: TableName, columnNameMapping: ColumnNameMapping, nativeTableOperations: DirectLoadTableNativeOperations, sqlTableOperations: DirectLoadTableSqlOperations, 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, nativeTableOperations: DirectLoadTableNativeOperations, sqlTableOperations: DirectLoadTableSqlOperations, streamStateStore: StreamStateStore<DirectLoadTableExecutionConfig>) : StreamLoader

Stream loader implementation for deduplication mode.

DirectLoadTableDedupTruncateStreamLoader

class DirectLoadTableDedupTruncateStreamLoader(val stream: DestinationStream, initialStatus: DirectLoadInitialStatus, realTableName: TableName, tempTableName: TableName, columnNameMapping: ColumnNameMapping, nativeTableOperations: DirectLoadTableNativeOperations, sqlTableOperations: DirectLoadTableSqlOperations, streamStateStore: StreamStateStore<DirectLoadTableExecutionConfig>, tempTableNameGenerator: TempTableNameGenerator) : StreamLoader

Stream loader implementation for deduplication + truncate mode.

DirectLoadTableExecutionConfig

data class DirectLoadTableExecutionConfig(val tableName: TableName)

DirectLoadTableNativeOperations

interface DirectLoadTableNativeOperations

Operations which aren't easily represented as a sequence of SQL statements.

DirectLoadTableSqlOperations

interface DirectLoadTableSqlOperations

Operations which can be handled by an underlying DatabaseHandler executing SQL statements from a DirectLoadSqlGenerator.

DirectLoadTableStatus

data class DirectLoadTableStatus(val isEmpty: Boolean)

DirectLoadTableWriter

class DirectLoadTableWriter(internalNamespace: String, names: TableCatalog, stateGatherer: DatabaseInitialStatusGatherer<DirectLoadInitialStatus>, destinationHandler: DatabaseHandler, nativeTableOperations: DirectLoadTableNativeOperations, sqlTableOperations: DirectLoadTableSqlOperations, streamStateStore: StreamStateStore<DirectLoadTableExecutionConfig>, tempTableNameGenerator: TempTableNameGenerator) : DestinationWriter