bulk-cdk-toolkit-load-iceberg-parquet/io.airbyte.cdk.load.data.iceberg.parquet/IcebergNullOutOfRangeIntegers

IcebergNullOutOfRangeIntegers

class IcebergNullOutOfRangeIntegers(minValue: BigInteger = Long.MIN_VALUE.toBigInteger(), maxValue: BigInteger = Long.MAX_VALUE.toBigInteger()) : AirbyteValueIdentityMapper

Iceberg wants to write objects/unions as JSON strings, but arrays as strongly-typed. Therefore, we need to handle top-level ints, and arrays of ints, but should ignore ints inside objects, and ints inside unions.

Constructors

constructor(minValue: BigInteger = Long.MIN_VALUE.toBigInteger(), maxValue: BigInteger = Long.MAX_VALUE.toBigInteger())

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

mapInner

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

mapInteger

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

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): Pair<AirbyteValue, AirbyteValueIdentityMapper.Context>