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

AirbyteValueProxy

Provides a universal view over raw data, agnostic of the serialization format. Fields are accessed with accessors that contain name, index, and type. The type indicates with method should be used.

Inheritors

AirbyteValueJsonlProxy

AirbyteValueProtobufProxy

Types

FieldAccessor

data class FieldAccessor(val index: Int, val name: String, val type: AirbyteType)

Functions

asJson

fun AirbyteValueProxy.asJson(orderedSchema: Array<AirbyteValueProxy.FieldAccessor>): ObjectNode

getBoolean

abstract fun getBoolean(field: AirbyteValueProxy.FieldAccessor): Boolean?

getDate

abstract fun getDate(field: AirbyteValueProxy.FieldAccessor): String?

getInteger

abstract fun getInteger(field: AirbyteValueProxy.FieldAccessor): BigInteger?

getJsonBytes

abstract fun getJsonBytes(field: AirbyteValueProxy.FieldAccessor): ByteArray?

getJsonNode

abstract fun getJsonNode(field: AirbyteValueProxy.FieldAccessor): JsonNode?

getNumber

abstract fun getNumber(field: AirbyteValueProxy.FieldAccessor): BigDecimal?

getString

abstract fun getString(field: AirbyteValueProxy.FieldAccessor): String?

getTimestampWithoutTimezone

abstract fun getTimestampWithoutTimezone(field: AirbyteValueProxy.FieldAccessor): String?

getTimestampWithTimezone

abstract fun getTimestampWithTimezone(field: AirbyteValueProxy.FieldAccessor): String?

getTimeWithoutTimezone

abstract fun getTimeWithoutTimezone(field: AirbyteValueProxy.FieldAccessor): String?

getTimeWithTimezone

abstract fun getTimeWithTimezone(field: AirbyteValueProxy.FieldAccessor): String?