Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-core-base/io.airbyte.cdk.data

Package-level declarations

Types

AirbyteSchemaType

sealed interface AirbyteSchemaType

Union type which models the Airbyte field type schema.

data object AnyEncoder : JsonEncoder<Any>

ArrayAirbyteSchemaType

data class ArrayAirbyteSchemaType(val item: AirbyteSchemaType) : AirbyteSchemaType

data class ArrayDecoder<T>(val elementDecoder: JsonDecoder<T>) : JsonDecoder<List<T>>

data class ArrayEncoder<T>(val elementEncoder: JsonEncoder<T>) : JsonEncoder<List<T>>

BigDecimalCodec

data object BigDecimalCodec : JsonCodec<BigDecimal>

BigDecimalIntegerCodec

data object BigDecimalIntegerCodec : JsonCodec<BigDecimal>

data object BinaryCodec : JsonCodec<ByteBuffer>

data object BooleanCodec : JsonCodec<Boolean>

data object ByteCodec : JsonCodec<Byte>

CdcOffsetDateTimeCodec

data object CdcOffsetDateTimeCodec : JsonCodec<OffsetDateTime>

data object DoubleCodec : JsonCodec<Double>

data object FloatCodec : JsonCodec<Float>

data object IntCodec : JsonCodec<Int>

data object JsonBytesCodec : JsonCodec<ByteBuffer>

interface JsonCodec<T> : JsonEncoder<T> , JsonDecoder<T>

Combines a JsonEncoder and a JsonDecoder.

fun interface JsonDecoder<T>

Decodes a field value of type T from a JsonNode in an Airbyte state message.

fun interface JsonEncoder<T>

Encodes a field value of type T as a JsonNode for an Airbyte record or state message.

JsonStringCodec

data object JsonStringCodec : JsonCodec<String>

LeafAirbyteSchemaType

enum LeafAirbyteSchemaType : Enum<LeafAirbyteSchemaType> , AirbyteSchemaType

data object LocalDateCodec : JsonCodec<LocalDate>

LocalDateTimeCodec

data object LocalDateTimeCodec : JsonCodec<LocalDateTime>

data object LocalTimeCodec : JsonCodec<LocalTime>

data object LongCodec : JsonCodec<Long>

data object NullCodec : JsonCodec<Any?>

OffsetDateTimeCodec

data object OffsetDateTimeCodec : JsonCodec<OffsetDateTime>

OffsetTimeCodec

data object OffsetTimeCodec : JsonCodec<OffsetTime>

data object ShortCodec : JsonCodec<Short>

data object TextCodec : JsonCodec<String>

data object UrlCodec : JsonCodec<URL>