bulk-cdk-toolkit-legacy-task-loader/io.airbyte.cdk.load.data/UnknownType

UnknownType

data class UnknownType(val schema: JsonNode) : AirbyteType

Constructors

Link copied to clipboard
constructor(schema: JsonNode)

Properties

Link copied to clipboard
open val isArray: Boolean = false
Link copied to clipboard
open val isObject: Boolean = false
Link copied to clipboard
val schema: JsonNode

Functions

Link copied to clipboard
open fun asColumns(): LinkedHashMap<String, FieldType>

Utility method for database/warehouse destinations, which assume that the top-level schema is an object.

Link copied to clipboard
fun AirbyteType.collectUnknownPaths(currentPath: String = ""): Set<String>
Link copied to clipboard
fun AirbyteType.computeUnknownColumnChanges(): List<Meta.Change>

This function exists so that our tests can easily mock a DestinationStream, while still getting a real value for unknownColumnChanges.

Link copied to clipboard