Spark Cassandra Connector有这个功能 SPARKC-25 。您可以使用值创建任意RDD,然后将其用作从Cassandra表获取数据的密钥源。或者换句话说 - 将任意RDD加入Cassandra RDD。在您的情况下,任意RDD将包括具有不同负载均衡器值的4个元组。看着那(这 文件 了解更多信息。 SCC 1.2最近已经发布,它可能与Spark 1.1兼容(它专为Spark 1.2设计)。