Airbyte Kotlin Bulk CDK

0.1.92

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

UnionValueToDisjointRecord

class UnionValueToDisjointRecord : AirbyteValueIdentityMapper

Constructors

UnionValueToDisjointRecord

constructor()

Functions

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

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

mapArrayWithoutSchema

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

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

open 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 fun mapInteger(value: AirbyteValue, context: AirbyteValueIdentityMapper.Context): Pair<AirbyteValue, AirbyteValueIdentityMapper.Context>

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

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

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

mapObjectWithEmptySchema

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

mapObjectWithoutSchema

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

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

mapTimestampWithoutTimezone

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

mapTimestampWithTimezone

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

mapTimeWithoutTimezone

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

mapTimeWithTimezone

open 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>