У меня есть схема, связанная с таблицей, которую нужно создать, полученной из слитного реестра схем в следующем коде:
private val avroSchema = schemaRegistryClient.getLatestSchemaMetadata("topicName").getSchema
private var sparkSchema = SchemaConverters.toSqlType(new Schema.Parser().parse(avroSchema))
sparkSchema=sparkSchema.dataType.asInstanceOf[StructType]
Теперь я пытаюсь определить таблицу дельта-озера, структура которой имеет видна основе этой схемы. Однако я не уверен, как поступить так же. Любая помощь приветствуется.