2回答
我们正在尝试从EMR写入DSE图(cassandra)，并不断收到这些错误。我的JAR是一个带有byos依赖项的阴影jar。任何帮助都将不胜感激。:882) at org.apache.spark.rdd.RDD.iteratororg.apache.spark.rdd.<
浏览 20提问于2019-04-26得票数 0
1回答
spark 2.0兼容(datastax) cassandra 2.1.13吗？我已经在本地mac上安装了spark 2.1.0，还安装了scala 2.11.x。我正在尝试从安装了datastax 4.8.6 ( spark 1.4和cassandra 2.1.13)的服务器读取cassandra表。._import com.datastax.spark</em
浏览 1提问于2017-03-01得票数 0
我使用pyspark和cassandra，并使用cache()函数缓存数据。我想知道cassandra中的数据每次更新时，缓存是否会自动更新？
浏览 0提问于2015-08-21得票数 3
=4097
at org.apache.spark.rdd.RDD.partitions(RDD.scala:250)
at org.apache.spark.rdd.MapPartitio
浏览 1提问于2018-11-15得票数 0
$.fromCassandra(Schema.scala:241) [spark-cassandra-connector_2.10-1.4.1.jar:1.4.1]at com.datastax.spark.connector.<
浏览 1提问于2016-02-11得票数 0
1回答
我试图通过使用spark-cassandra-connector从cassandra获取数据，但在异常下获取数据。 at com.datastax.spark.connector.rdd.CassandraTableScanRDD.tokenFactory[spark-cass
浏览 5提问于2021-10-01得票数 2
回答已采纳
1回答
在给Cassandra表写信时，我得到以下关于写入的行数和所用时间的信息。从日志中，我可以看到它来自TableWriter类。如何在不调用RDD操作的情况下从Cassandra中找到相同的信息？2020-04-20 11:58:42 INFO com.datastax.spark.connector.writer.TableWriter.logInfo:35 - Wrote 24 rows代码将火花数据写入卡桑德拉表 .format("org.apa
浏览 8提问于2020-04-20得票数 0
我们有一个超过50列的Cassandra模式，我们通过使用Spark (数据帧而不是rdd)转换数据来将来自多个数据源的数据插入到其中。
我们遇到了许多墓碑的问题，因为我们的数据是稀疏的。我已经尝试过spark.cassandra.output.ignoreNulls=true，但它不工作。在cassandra中不写入空值的正确配置是什么？我正在使用zeppelin来运行我的spark代码并将数据推送到C*。
浏览 1提问于2019-08-26得票数 1
我为其中一个源集群指定了cassandra配置，如下所示：spark.cassandra.connection.host: spark.cassandra.auth.username:spark.cassandra.connection.ssl.cli
浏览 3提问于2019-11-07得票数 2
回答已采纳
我有一个下面的Cassandra表模式。ColumnA Primary KeyColumnC
ColumnD 现在，我有了一个Spark RDD，它的列排序为RDDColumnC、ColumnA、ColumnB、ColumnD 因此，当我写入Cassandra表时，我需要确保顺序是正确的。因此，我使用SomeColumns指定了列的排序 rdd.saveToCassandra(keyspace,table,SomeColumns("
浏览 10提问于2019-07-02得票数 0
回答已采纳
在检查了所有找到的源之后，datastax-spark-cassandra连接器支持在cassandra中使用scala和java中的rdd自动创建表。Spark版本: 2.4.7 Cassandra :最新docker镜像
Pyspark shell >> pyspark --packages anguenot/pyspark-cassandra:2.4.0,com.datastax.spark:spark-<
浏览 8提问于2021-03-03得票数 2
$.fromCassandra(Schema.scala:241) [spark-cassandra-connector_2.10-1.4.2.jar:1.4.2] at com.datastax.spark<
浏览 2提问于2016-05-03得票数 0
问:如何高效地将Spark DataFrame中包含值的列写入Cassanrda？我目前正在将Spark dataframe转换为RDD，并使用saveRdd来写入数据。spark.conf.set("spark.cassandra.output.ignoreNulls", "true")
spark.conf.get
浏览 0提问于2018-11-06得票数 2
" %% "spark-cassandra-connector" % "1.2.1",)
正如您所看到的，Spark版本是1.2.1 (而不是像许多其他问题那样
浏览 3提问于2015-06-09得票数 0
回答已采纳
我需要将一些少量数据写入spark应用程序中的cassandra表。数据不是RDD，它只是一个双精度值。如何在使用Java API的Spark应用程序中做到这一点？
谢谢你的任何提示。
浏览 0提问于2017-05-16得票数 0
Spark版本: 2.0.2.6 Cassandra版本: cqlsh 5.0.1 | Cassandra 3.11.0.1855 | DSE 5.1.3 | CQL spec 3.4.4 |本地协议v4我正在尝试从CSV读取并写入Cassandra Table。").setMaster("local[*]") sc.setLogLevel("ERROR")
val <
浏览 1提问于2017-09-30得票数 1
3回答
我想通过使用spark-cassandra-connector执行一个spark项目来连接卡桑德拉，如下所示：
val sc = new SparkContext("sparkat org.apache.<e
浏览 6提问于2014-12-04得票数 0
我试着比较卡桑德拉保存一个表和30,000条记录用于RDD和DataSet。我发现Dataset保存速度比RDD慢10倍。该表有4个分区键。=false
num-cpu-
浏览 0提问于2018-04-24得票数 0
我是Spark和Cassandra的新手在尝试提交spark作业时，我在连接到Cassandra时遇到错误。详细信息：Spark : 1.3.1 (build for hadoop 2.6 or later : spark-1.3.1-bin-hadoop2.6)Spark-Cassandra-Connector._
import org.apache.spark.Spar
浏览 6提问于2015-06-19得票数 5
我正在使用Datastax spark- Cassandra -connector来访问Cassandra中的一些数据。我的需求是将RDD与Cassandra表连接起来，获取结果并将其存储在hive表中。 我正在使用joinWithCassandraTable加入cassadra表。加入后，生成的RDD如下所示 com.datastax.spark.connector.rdd.CassandraJoinRDD[org.apache.spark<
浏览 20提问于2020-07-17得票数 0
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
