bulk-cdk-core-load/io.airbyte.cdk.load.schema.defaults/NoopTableSchemaMapper

NoopTableSchemaMapper

@Singleton

@Secondary

class NoopTableSchemaMapper : TableSchemaMapper

Default schema mapper that performs no transformations on names or types.

For destinations that don't do schema munging in the new paradigm.

Constructors

NoopTableSchemaMapper

constructor()

Functions

colsConflict

open fun colsConflict(a: String, b: String): Boolean

Determines if two column names conflict according to destination-specific rules. By default, performs case-insensitive comparison. Override for different conflict detection logic.

toColumnName

open override fun toColumnName(name: String): String

Transforms a column name from the input schema to comply with destination naming conventions. This may include handling special characters, case transformations, or length limitations.

toColumnType

open override fun toColumnType(fieldType: FieldType): ColumnType

Converts an Airbyte field type to the corresponding destination-specific column type. This handles mapping of data types from Airbyte's type system to the destination database's type system.

toFinalSchema

open fun toFinalSchema(tableSchema: StreamTableSchema): StreamTableSchema

Performs any final transformations on the complete table schema before it's used in the destination. By default, returns the schema unchanged. Override to apply destination-specific schema modifications.

toFinalTableName

open override fun toFinalTableName(desc: DestinationStream.Descriptor): TableName

Converts a stream descriptor to the final destination table name.

toTempTableName

open override fun toTempTableName(tableName: TableName): TableName

Generates a temporary table name based on the provided final table name. Temporary tables are typically used before data is moved to final tables to avoid data downtime.