我有点困惑于不同的演员在这个故事: PySpark，SparkSQL，卡桑德拉和火星雨-卡桑德拉连接器。在Scala中使用spark-shell，我可以做的很简单然后
import org.apache.spark.sql.cassandra
浏览 7提问于2016-02-28得票数 1
想要将cassandra添加到spark streaming "org.apache.spark" %% "spark-streaming"% sparkVersion, "com.datastax.
浏览 2提问于2015-11-07得票数 2
1回答
我试图使用Scala中的Spark查询Cassandra数据。._ .set("spark.cassandra.connection.host","**.*.**.***")
.set("spark.cassandra
浏览 0提问于2017-07-26得票数 0
回答已采纳
2回答
我正在尝试运行一个通过datastax的Cassandra连接器访问Cassandra的scala程序。2.10.4
1)将连接器JAR添加到火花-env.sh中。2)将连接器罐添加到火花-defaults.conf中。spark.executor.extraClassPath
浏览 3提问于2015-04-30得票数 1
回答已采纳
6回答
我试图在Spark1.1.0中使用。
我已经成功地从GitHub上的主分支构建了jar文件，并且已经获得了包含的演示程序。但是，当我试图将jar文件加载到spark-shell中时，我无法从com.datastax.spark.connector包中导入任何类。我尝试在--jars上使用spark-shell选项，并将包含jar文件的目录添加到Java中。这两个选项都不起作用。事实上，当我使用--jars选项时，日志
浏览 5提问于2014-09-14得票数 28
回答已采纳
我正在尝试构建spark-cassandra连接器，并遵循以下链接：链接中的下一步请求从git下载连接器并使用sbt进行构建。/spark-cassandra-connector
浏览 1提问于2015-11-04得票数 0
我正在尝试使用Spark-cassandra连接器连接到spark shell中的远程cassandra集群。但是它抛出了一些不寻常的错误。我做了spark-cassandra连接器的github页面上提到的通常的事情 $SPARK_HOME/bin/spark-shell --packages datastax:spark</em
浏览 0提问于2018-09-17得票数 3
我正在尝试以下几点：( 2)使用火花-卡桑德拉-连接器来连接后者；在github上找到。3)一旦我在DataFrame中拥有了DB数据，我应该能够转换成JavaRDD类型并推到Cassandra，如下所示：
4)简而言之: DB<---Spark---spark-cassandra-connector--->Ca
浏览 2提问于2015-05-06得票数 1
回答已采纳
1回答
我正在使用火花1.3，并能够创造火花环境。当我尝试使用CassandraSQL上下文访问Cassandra时。我得到了以下错误。线程"main“中的异常: org/apache/spark/sql/execution/SparkStrategies$CommandStrategy at org.apache.spark.sql.cassandra.CassandraSQLContext(CassandraSQL
浏览 8提问于2015-03-25得票数 2
回答已采纳
我们最近启动了使用Scala、Spark和Cassandra的大数据项目，而我对所有这些技术都是新手。我试图做一个简单的任务，写和读卡桑德拉表。如果我将属性名和列名都保留在小写或蛇形大小写(unserscores)中，我就能够做到这一点，但我希望在scala代码中使用camel大小写。是否有更好的方法来实现这一点，使用camel case格式在Scala和蛇案例在cassandra。我们正在使用
浏览 3提问于2016-10-22得票数 2
回答已采纳
我可以看到数据被打印到控制台，但是当它写到Cassandra作业失败时-spark-submit --packages org.apache.spark:spark-sql-kafka
浏览 6提问于2022-08-25得票数 1
回答已采纳
(PrefetchingResultSetIterator.scala:26) ~[spark-cassandra-connector_2.11-2.0.8.jar!/:2.0.8] at com.datastax.spark
浏览 0提问于2018-06-29得票数 0
我正在尝试建立我的第一个火花&卡桑德拉应用程序使用sbt。import com.datastax.spark.connector.cql.CassandraConnectorConf, dest.api_version, dest.bcash_consum
浏览 2提问于2017-04-12得票数 2
回答已采纳
我正在尝试使用spark执行一个简单的应用程序示例代码。使用spark submit执行作业。spark-submit --class "SimpleJob“--master spark://:7077 target/scala-2.10/simple-project_2.10-1.0.jar(Connection.scala:390)
at org.apache.spark.
浏览 2提问于2015-03-09得票数 0
1回答
我使用的是由datastax提供的火花卡桑德拉连接器1.1.0。我注意到了交互问题，我也不知道为什么会发生这样的事情:当我广播cassandra连接器并试图在执行器上使用它时，我正在接受异常，这意味着我的配置无效，不能在0.0.0连接到Cassandra。(RefCountedCache.scala:36)
at com.datastax.spark.connector.cql.RefCountedCache.acquire(RefCo
浏览 3提问于2015-07-18得票数 4
1回答
我使用的是spark 1.6.2和scala版本2.10.5。
但是，当我试图使用连接器从cassandra启动spark shell时，我得到了这个错误
如果我下载的连接器版本不正确，或者有其他问题，请帮助我。
浏览 0提问于2018-06-19得票数 0
下面是我迄今为止所做的事情: 1)安装了Cassandra 2.1.8版本，添加了lucene辅助索引。增加了测试数据。2)预建了火花1.4.1 3)我有星火卡桑德拉连接器罐。.class=‘class 1’&
浏览 7提问于2015-09-11得票数 0
scala和Python中的大量代码。这就是我所拥有的：import org.apache.spark.sql.Dataset;
hdfsDF.write().format("org.apache.spark.sql.<
浏览 10提问于2020-02-11得票数 0
我在使用spark-cassandra连接器时遇到以下错误：at org.apache.spark.rdd.RDD.iterator(RDD.scala:244)
at org.apache.spark.rdd.MapPartitionsRDD.compute", &qu
浏览 0提问于2015-06-02得票数 2
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号