我有以下Cassandra表模式：id text,我创建了scala应用程序来从cassandra中提取数据，在一些操作之后，将再次将数据更新到cassandra。}cassandra表中的数据行如下所示：
('testid',{'a1': '10', &#
浏览 7提问于2018-07-30得票数 0
回答已采纳
create table tbl_master_values ( user_dbid int, reg_dbid int, fields_value map<text,list<text>>, modified_date timestamp);InvalidRequest: code=2200 [Invalid query]
message="Non-frozen collections are
浏览 2提问于2016-01-27得票数 4
1回答
我试图使用scala case类来映射Cassandra表。Cassandra Table id_uuid uuid, type text,)
// This declaration will fail as "new
浏览 0提问于2014-11-23得票数 0
回答已采纳
1回答
关于卡桑德拉的分区钥匙我有个小问题。当我创建一个包含一个名为flxB的字段的表时，该字段的类型是UDT，如下所示： flux float, flux_error_prec smallint, system text我可以将字段flxB.flux放在分区键中吗
浏览 3提问于2017-06-13得票数 0
回答已采纳
1回答
我有一个卡夫卡的流媒体应用程序，我想知道是否有办法从地图函数中进行范围查询？我将来自kafka的信息按时间范围和键分组，然后根据这些时间范围和键，我想将cassandra中的数据提取到dstream中。:231)
at org.apache.spark.sql.cassandra.CassandraSQLContext.cassandraSql(CassandraSQLContext.scala:70(RDD.scala</e
浏览 2提问于2016-07-14得票数 3
回答已采纳
1回答
我目前正在开发一个Cassandra 3数据库，其中一个表中有一个列定义如下：当我必须更改给定一个映射键x的完整集合的值时问题是我需要在给定一个键的集合上插入一个值。但它会返回：
我做错了什么？有人知道如何以我需要的<
浏览 0提问于2017-12-14得票数 0
回答已采纳
2回答
卡桑德拉输入/输出火花
、、、
想象一下下面的感应器:一个星火应用程序(Java实现)正在使用Cassandra数据库来加载、转换到RDD并处理数据。此外，应用程序正在从数据库中冒出新数据，这些数据也是由自定义接收器处理的。流进程的输出存储在数据库中。实现是使用Spring与数据库的集成。"));
r
浏览 3提问于2014-06-27得票数 8
回答已采纳
我使用的是Scala版本2.10.5、Cassandra 3.0和Spark 1.6。我想将数据插入到cassandra中，所以我尝试了基本的示例
scala> val collection = sc.parallelize(Seq(("cat", 30), ("fox", 40)))Cassandra.So表中。", "keyspace" -> &qu
浏览 0提问于2016-12-21得票数 6
回答已采纳
我想通过同时映射来自文件和cassandra的输入来执行hadoop作业。有可能吗？这里有更多的提示来描述我的情况。数据格式相同。像这样的文件: key value1 value2 value3 ...
cassandra
浏览 2提问于2011-01-16得票数 0
我试图在映射cassandra表时使用java类来触发rdd，为此我面临的问题是cassandra无法创建查询来获取数据。根据这个链接，一个类必须是可序列化的，并且至少对于要映射的表的主键列有'getters‘和'setters’。因此，我已经创建了一个java类，为每个字段创建了公共getter和setter，将类映射到scala伙伴对象，并将其用于映射cassandra表，同时将数据检索到rd
浏览 0提问于2019-04-21得票数 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表。我在spark shell上运行以下代码
import or
浏览 1提问于2017-03-01得票数 0
2回答
我正在尝试运行一个通过datastax的Cassandra连接器访问Cassandra的scala程序。我得到了以下例外：4)在运行火花提交时使用同一问题
当我在IntelliJ上运行它时，程序运行得很好，但是当我组装它并使用火花提交运行胖罐子
浏览 3提问于2015-04-30得票数 1
回答已采纳
1回答
解析字符串中不同类型的txt
、、、、
我有带有半结构化数据的txt文件，我必须通过spark-cassandra在cassandra中编写它。但第一次我只在scala中解析了什么。我的代码：import scala.io.Source
val path = "somepath"listFiles()
for (file <
浏览 2提问于2017-01-15得票数 0
我正在尝试使用scala语言在spark中创建查询，数据在cassandra数据库中以表格的形式提供。在Cassandra表中，我有两个键，1)主键2)分区键CREATE TABLE A.B ( id2 text,当我对"value“进行同样的<
浏览 0提问于2017-10-25得票数 2
我试图在scala中使用一个main对象，但是SBT返回以下消息：[info] Packaging /Users/aironman/scala_cassandra_project_without_play:= Some(projectMainClass)这个项目的文件夹中有根文件夹中的build.sbt文件，另
浏览 3提问于2016-03-10得票数 1
回答已采纳
/
链接中的下一步请求从git下载连接器并使用sbt进行构建。[error] /home/naresh/Desktop/spark-cassandra-connector/spark-cassandra-connector/src/main/scala/org/apache/spark-cassandra-connector/src/main
浏览 1提问于2015-11-04得票数 0
我正在使用Datastax spark- Cassandra -connector来访问Cassandra中的一些数据。我的需求是将RDD与Cassandra表连接起来，获取结果并将其存储在hive表中。 我正在使用joinWithCassandraTable加入cassadra表。加入后，生成的RDD如下所示 com.datastax.spark.connector.rdd.CassandraJoinRDD[org
浏览 20提问于2020-07-17得票数 0
当我运行Spark作业(scala脚本)时，我得到以下错误：
16/03/08 10:22:03 INFO DAGScheduler:作业0失败:在JsonRDD.scala:57接受了15.051150s的异常:在线程"main“org.apache.spark.SparkException:由于阶段失败而中止的作业:阶段1.0中的任务1失败1次，最近的失败:在阶段1.0中丢失任务1
浏览 1提问于2016-03-08得票数 1
回答已采纳
我试图使用python Cassandra driver (cassandra-driver包版本3.14)中的对象映射器声明和创建(使用sync_table) Cassandra表，但我找不到在集合中定义冻结值的方法有没有办法使用对象映射器定义冻结，或者我必须手动编写一条CREATE TABLE语句来执行此操作，然后只使用对象映射器进行查询？
浏览 7提问于2018-08-13得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
