您可以从程序端执行此操作，如果您获得绑定语句的路由密钥（您必须使用准备好的语句），请通过元数据类找到它的副本，然后比较此主机是否在您可以从中获取的executioninfo中 ResultSet .

根据亚历克斯所说，我们可以做如下：
创建sparksession后，我们应该创建一个连接器：

import com.datastax.spark.connector.cql.CassandraConnector
val connector = CassandraConnector.apply(sparkSession.sparkContext.getConf)

现在我们可以定义一个preparedstatement并执行其余操作：

connector.withSessionDo(session => {

    val selectQuery = "select * from test where id=?"
    val prepareStatement = session.prepare(selectQuery)
    val protocolVersion = session.getCluster.getConfiguration.getProtocolOptions.getProtocolVersion
    // We have to explicitly bind the all of parameters that partition key is based on them, otherwise the routingKey will be null.
    val boundStatement = prepareStatement.bind(s"$id")
    val routingKey = boundStatement.getRoutingKey(protocolVersion, null)
    // We can get tha all of nodes that contains the row
    val replicas = session.getCluster.getMetadata.getReplicas("test", routingKey)
    val resultSet = session.execute(boundStatement)

    // We can get the node which gave us the row
    val host = resultSet.getExecutionInfo.getQueriedHost

    // Final step is to check whether the replicas contains the host or not!!!
    if (replicas.contains(host)) println("It works!")
  })

重要的是，我们必须显式地绑定分区键基于它们的所有参数（即，我们不能在select语句中设置它们的编码），否则routingkey将为null。