当struct类型的struct字段与spark scala中的特定值匹配时，从结构数组中检索struct

import org.apache.spark.sql.{SparkSession, Row}
import org.apache.spark.sql.functions._

// 创建SparkSession
val spark = SparkSession.builder()
  .appName("Struct Array Retrieval")
  .master("local")
  .getOrCreate()

// 创建示例数据
val data = Seq(
  Row(Seq(Row("John", 25), Row("Jane", 30))),
  Row(Seq(Row("Bob", 35), Row("Alice", 40)))
)

// 定义结构的schema
val schema = new StructType()
  .add("people", ArrayType(new StructType()
    .add("name", StringType)
    .add("age", IntegerType)))

// 创建DataFrame
val df = spark.createDataFrame(spark.sparkContext.parallelize(data), schema)

// 定义特定值
val specificValue = Row("John", 25)

// 使用filter函数检索struct
val result = df.filter(array_contains($"people", specificValue))

// 显示结果
result.show()