连接Apache Spark和Cassandra以进行集群查询
我使用DataStax Spark连接器来填充Cassandra集群并处理不同作业中的数据（由于Spark对流处理的某些不支持的操作，例如双重聚合）。所以我 ...
无法通过spark scala程序验证cassandra集群
请建议我解决以下问题，或建议我采用任何不同的方法来实现我的问题陈述。我从某个地方获取数据并将其插入每天的cassandra然后我......
如何在任务或作业完成后立即在控制台（Spark Shell或Spark提交作业）上收集这些指标。我们使用Spark将数据从Mysql加载到Cassandra并且它非常庞大（例如：〜...
我正在尝试使用spark来处理一个大的cassandra表（大约4.02亿个条目和84列）但是我得到了不一致的结果。最初的要求是从这里复制一些列...
将从joinWithCassandraTable获取的CassandraRow转换为DataFrame
case class SourcePartition（id：String，host：String，bucket：Int）joinedRDDs = partitions.joinWithCassandraTable（“db_name”，“table_name”）joinedRDDs.values.foreach（println）我必须使用...
我们需要对Cassandra数据库执行分析和报告。以下是我们迄今已确定的方法。 1）在cassandra顶部使用火花。缺点：我们会严重...
无法启动bin / dse spark-sql。文件不例外/ tmp / hive
我试图在DSE cassandra上运行以下命令： - dse $ bin / dse spark-sql它给出以下错误： - 2018-05-24 16:59:41 [main] ERROR oasdDseSparkSubmitBootstrapper - 无法启动或.. 。