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

TimeStringToInteger

class TimeStringToInteger : AirbyteValueIdentityMapper

NOTE: To keep parity with the old avro/parquet code, we will always first try to parse the value as with timezone, then fall back to without. But in theory we should be more strict.

Constructors

TimeStringToInteger

constructor()

Functions

map

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

mapArray

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>

mapBoolean

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

mapDate

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.

mapInner

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

mapInteger

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

mapNull

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

mapNumber

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

mapObject

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>

mapString

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

mapUnion

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

mapUnknown

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

nulledOut

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