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

withAirbyteMeta

fun AirbyteType.withAirbyteMeta(flatten: Boolean = false): ObjectType
fun Pair<AirbyteValue, List<Meta.Change>>.withAirbyteMeta(stream: DestinationStream, emittedAtMs: Long, flatten: Boolean = false, extractedAtAsTimestampWithTimezone: Boolean = false, airbyteRawId: UUID): ObjectValue