Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-core-load/io.airbyte.cdk.load.data/AirbyteValueDeepCoercingMapper

AirbyteValueDeepCoercingMapper

class AirbyteValueDeepCoercingMapper(recurseIntoObjects: Boolean, recurseIntoArrays: Boolean, recurseIntoUnions: Boolean) : AirbyteValueIdentityMapper

A mapper which coerces ALL values against the schema. This mapper MUST NOT be called after any mapper that returns non-native-JSON types (date, timestamp, etc.), or any mapper that causes the values to become misaligned with the schema (e.g. AirbyteSchemaNoopMapper + SchemalessValuesToJsonString).

If this mapper is included in a MapperPipeline, it SHOULD be preceded by a MergeUnions mapper. Not including this mapper may result in strange behavior when coercing union types.

This mapper performs common-sense type coercions. For example, it will promote IntegerValue to NumberValue, or parse StringValue to TimestampValue.

Constructors

AirbyteValueDeepCoercingMapper

constructor(recurseIntoObjects: Boolean, recurseIntoArrays: Boolean, recurseIntoUnions: Boolean)

Functions

open override fun map(value: AirbyteValue, schema: AirbyteType, changes: List<Meta.Change>): Pair<AirbyteValue, List<Meta.Change>>

open override fun mapArray(value: AirbyteValue, schema: ArrayType, context: AirbyteValueIdentityMapper.Context): Pair<AirbyteValue, AirbyteValueIdentityMapper.Context>

mapArrayWithoutSchema

open override fun mapArrayWithoutSchema(value: AirbyteValue, schema: ArrayTypeWithoutSchema, context: AirbyteValueIdentityMapper.Context): Pair<AirbyteValue, AirbyteValueIdentityMapper.Context>

open override fun mapBoolean(value: AirbyteValue, context: AirbyteValueIdentityMapper.Context): Pair<AirbyteValue, AirbyteValueIdentityMapper.Context>

open override fun mapDate(value: AirbyteValue, context: AirbyteValueIdentityMapper.Context): Pair<AirbyteValue, AirbyteValueIdentityMapper.Context>

Time types are only allowed to be strings on the wire, but can be Int/egerValue if passed through TimeStringToInteger.

fun mapInner(value: AirbyteValue, schema: AirbyteType, context: AirbyteValueIdentityMapper.Context): Pair<AirbyteValue, AirbyteValueIdentityMapper.Context>

open override fun mapInteger(value: AirbyteValue, context: AirbyteValueIdentityMapper.Context): Pair<AirbyteValue, AirbyteValueIdentityMapper.Context>

open fun mapNull(context: AirbyteValueIdentityMapper.Context): Pair<AirbyteValue, AirbyteValueIdentityMapper.Context>

open override fun mapNumber(value: AirbyteValue, context: AirbyteValueIdentityMapper.Context): Pair<AirbyteValue, AirbyteValueIdentityMapper.Context>

open override fun mapObject(value: AirbyteValue, schema: ObjectType, context: AirbyteValueIdentityMapper.Context): Pair<AirbyteValue, AirbyteValueIdentityMapper.Context>

mapObjectWithEmptySchema

open override fun mapObjectWithEmptySchema(value: AirbyteValue, schema: ObjectTypeWithEmptySchema, context: AirbyteValueIdentityMapper.Context): Pair<AirbyteValue, AirbyteValueIdentityMapper.Context>

mapObjectWithoutSchema

open override fun mapObjectWithoutSchema(value: AirbyteValue, schema: ObjectTypeWithoutSchema, context: AirbyteValueIdentityMapper.Context): Pair<AirbyteValue, AirbyteValueIdentityMapper.Context>

open override fun mapString(value: AirbyteValue, context: AirbyteValueIdentityMapper.Context): Pair<AirbyteValue, AirbyteValueIdentityMapper.Context>

mapTimestampWithoutTimezone

open override fun mapTimestampWithoutTimezone(value: AirbyteValue, context: AirbyteValueIdentityMapper.Context): Pair<AirbyteValue, AirbyteValueIdentityMapper.Context>

mapTimestampWithTimezone

open override fun mapTimestampWithTimezone(value: AirbyteValue, context: AirbyteValueIdentityMapper.Context): Pair<AirbyteValue, AirbyteValueIdentityMapper.Context>

mapTimeWithoutTimezone

open override fun mapTimeWithoutTimezone(value: AirbyteValue, context: AirbyteValueIdentityMapper.Context): Pair<AirbyteValue, AirbyteValueIdentityMapper.Context>

mapTimeWithTimezone

open override fun mapTimeWithTimezone(value: AirbyteValue, context: AirbyteValueIdentityMapper.Context): Pair<AirbyteValue, AirbyteValueIdentityMapper.Context>

open override fun mapUnion(value: AirbyteValue, schema: UnionType, context: AirbyteValueIdentityMapper.Context): Pair<AirbyteValue, AirbyteValueIdentityMapper.Context>

open fun mapUnknown(value: AirbyteValue, context: AirbyteValueIdentityMapper.Context): Pair<AirbyteValue, AirbyteValueIdentityMapper.Context>

fun nulledOut(schema: AirbyteType, context: AirbyteValueIdentityMapper.Context, reason: AirbyteRecordMessageMetaChange.Reason = Reason.DESTINATION_SERIALIZATION_ERROR): Pair<AirbyteValue, AirbyteValueIdentityMapper.Context>