Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-toolkit-load-avro/io.airbyte.cdk.load.data.avro

Package-level declarations

Types

AirbyteTypeToAvroSchema

class AirbyteTypeToAvroSchema

AirbyteValueToAvroRecord

class AirbyteValueToAvroRecord

AvroMapperPipelineFactory

class ~~AvroMapperPipelineFactory~~ : MapperPipelineFactory

Functions

fun ObjectValue.toAvroRecord(airbyteSchema: ObjectType, avroSchema: Schema): GenericRecord

fun ObjectType.toAvroSchema(stream: DestinationStream.Descriptor): Schema