我是scala/spark新手。我继承了一个旧代码，我已经对它进行了重构，并试图使用它从“锡拉”检索数据。代码如下所示：

val TEST_QUERY = s"SELECT user_id FROM test_table WHERE name = ? AND id_type = 'test_type';"

var selectData = List[Row]()
dataRdd.foreachPartition {
  iter => {
    // Build up a cluster that we can connect to
    // Start a session with the cluster by connecting to it.
    val cluster = ScyllaConnector.getCluster(clusterIpString, scyllaPreferredDc, scyllaUsername, scyllaPassword)
    var batchCounter = 0

    val session = cluster.connect(tableConfig.keySpace)
    val preparedStatement: PreparedStatement = session.prepare(TEST_QUERY)

    iter.foreach {
      case (test_name: String) => {
        // Get results
        val testResults = session.execute(preparedStatement.bind(test_name))
        if (testResults != null){
          val testResult = testResults.one()
          if(testResult != null){
            val user_id = testResult.getString("user_id")
            selectData ::= Row(user_id, test_name)
          }
        }
      }
    }
    session.close()
    cluster.close()
  }
}

println("Head is =======> ")
println(selectData.head)

由于 selectedData 列表为空，尽管其中有与select语句匹配的数据。我觉得我这样做是不正确的，但不能找出什么需要改变，以得到这个固定，所以任何帮助是非常感谢。
ps：我使用一个列表来保存结果的整个想法是这样我就可以使用这个列表来创建一个Dataframe。如果你能给我指出正确的方向，我将不胜感激。