如何在cassandra Scala中更新Phantom中的表
在Cassandra Scala中更新Phantom中的表，可以按照以下步骤进行操作：
- 引入必要的依赖： 在项目的构建文件中，添加必要的依赖，包括Cassandra驱动和Phantom库。
- 创建表模型：
使用Phantom框架，定义一个继承自
com.outworkers.phantom.dsl.Table的表模型类。在该类中定义表的结构和字段。 - 创建连接： 在应用程序中，创建一个Cassandra连接对象，连接到Cassandra集群。
- 创建数据访问对象(DAO)： 在表模型类中，创建一个数据访问对象(DAO)，用于执行与表相关的操作，包括插入、查询和更新。
- 更新表数据：
使用DAO对象中的更新方法，根据需要更新表中的数据。在Phantom中，可以使用
update方法来更新表的记录。 - 示例代码：
- 示例代码：
- 上述示例中，首先定义了一个名为
MyTable的表模型，包含id、name和age三个字段。然后创建了一个Cassandra连接对象，并定义了数据访问对象dao。最后，使用dao.update方法更新表中符合条件的记录的name字段为指定值。 - 对于更复杂的更新操作，可以根据具体情况使用Phantom框架提供的更多更新方法和操作符。
- Cassandra是一个高度可扩展且高性能的分布式数据库，适用于大规模数据存储和处理场景，特别适合于需要高度可用性和横向扩展性的应用。腾讯云提供的相关产品是分布式数据库TDSQL-C，它是基于Cassandra的高性能、高可扩展性的分布式数据库服务，适用于海量结构化和非结构化数据存储与查询场景。
- 更多关于TDSQL-C的信息和产品介绍，可以访问腾讯云官方网站：TDSQL-C产品介绍
- 注意：上述答案中未提及亚马逊AWS、Azure、阿里云、华为云、天翼云、GoDaddy、Namecheap、Google等云计算品牌商，根据要求直接给出答案内容。
相关·内容
1回答
我正在尝试使用phantom来处理我的Cassandra，这是我学习如何使用phantom的示例(感谢Thiago)
我可以成功地运行'SongTest‘。
但是我在scala主对象中运行database.create遇到了一些麻烦。“scalatest”中的相同代码已成功运行。但是在我的scala主对象中，它失败了。这是我的源代码
package com.cassandra.phantom.modeling
import com.cassandra.phantom.modeling.database._
import com.cassandra.phantom.modeling.
浏览 2提问于2017-03-28得票数 2
我使用的是Scala_2.11.7、Apache Cassasndra_3.9和Phantom-dsl_2.6.1。当我使用phantom从Cassandra检索数据时，phantom总是在Future中返回数据。但是我想要同步的结果。有没有办法使用phantom从cassandra同步检索数据？
浏览 23提问于2018-06-03得票数 0
我正在构建一个简单的Scala应用程序，它使用Scala的Phantom DSL驱动程序将数据存储在Cassandra中。Cassandra的一个好特性是，您可以进行部分更新，即只要提供键列，就不必为表中的所有其他列提供值。Cassandra将根据键将数据合并到您现有的记录中。
不幸的是，这似乎不适用于幻影DSL。我有一个有几个列的表，我希望能够做一个更新，只为键和其中一个数据列指定值，并让Cassandra像往常一样将其合并到记录中，同时保持该记录的所有其他数据列不变。
但是，如果不在insert/update语句中指定值，则Phantom DSL会用null覆盖现有列。
有人知道解决这个问
浏览 4提问于2016-05-06得票数 0
回答已采纳
1回答
我想更新Cassandra中的一个字段，它使用幻影scala进行索引，如下所示：
this.update.where(_.id eqs folderId)
.and(_.owner eqs owner)
.modify(_.parent setTo parentId)
父字段是表中的索引字段。但是，在编译代码时不允许操作，编译异常如下：
[error] C:\User\src\main\scala\com\autodesk\platform\columbus\cassandra\DataItem.scala:161: could not find implicit va
浏览 4提问于2015-06-11得票数 2
回答已采纳
我对phantom非常陌生，并且对scala和cassandra有基本的了解。所以我正在尝试使用phantom做简单的crud示例，所以我在google上看了几个示例。最后，我以this示例作为结束。但是我运行这段代码并不像这个项目自述文件所说的那样。我刚刚创建了一个intellij项目，并且有如下的主类。 import org.creative.document.dao.impl.{PhantomConnectorExample}
import org.creative.document.database.SongsDatabase
import org.creative.document
浏览 32提问于2019-03-14得票数 0
1回答
我正在尝试使用Google来实现一个实时推荐系统。我已经使用Kafka、Apache和Cassandra构建了引擎，但是我想使用Cloud Pub/Sub、Cloud Dataflow和Cloud Bigtable在Scala中创建相同的引擎。
到目前为止，在Cassandra中，由于我在Apache操作期间多次读写，我实现了以下连接器MyDatabase.scala，该连接器启动与数据库的单例连接，并使用该连接在螺栓内使用来自Kafka喷口的流数据读取和更新用户表。我为Cassandra使用了Phantom Scala API驱动程序。
MyDatabase.scala
import sca
浏览 1提问于2018-02-05得票数 1
最近，我开始处理大量的数据，这些数据也需要经过正常的事务处理。
选择Cassandra，我的数据模型使用动态列。我理解使用CQL可以修改表，插入或查询列以获得所需的数据。
但是，我在为Cassandra使用带有Scala的Phantom客户端，并阅读了我无法找到一种方法来编写或查询动态列家族的文档。
假设我们使用case类，那么如何使用Scala中的Cassandra动态列呢？
浏览 4提问于2015-10-05得票数 6
回答已采纳
在我的Cassandra键空间中，我有一个主提供表和另外三个相同表的副本，面向不同的查询参数，如下所示：
offer (primary key offer_id) (... some attributes)
offer_by_product (primary key product_id, offer_id) (... some attributes)
offer_by_seller (primary key seller_id, offer_id) (... some attributes)
offer_by_sku (primary key sku_id, offer_id) (... s
浏览 6提问于2015-06-23得票数 1
回答已采纳
2回答
我正在尝试使用幻象scala驱动程序连接到cassandra数据库(使用scala 2.11.2)
我在他们的博客上关注了这篇文章：
(注意在github上只有phantom-dsl jar在2.11中编译，我不知道是不是有问题？)
我只有一个对幻影的依赖
<dependency>
<groupId>com.websudos</groupId>
<artifactId>phantom-dsl_2.11</artifactId>
<version>1.2.7</v
浏览 4提问于2014-12-16得票数 5
如何在Cassandra中实现写大量记录(例如2000000条)的最佳性能？我在我的项目中使用了Scala、Datastax驱动程序和phantom。如何在数据库中高效地插入这些记录？
浏览 2提问于2018-10-23得票数 1
最近正在尝试迁移到最新的phantom版本2.24.8。我创建了一个虚拟项目，但遇到了一些我无法解决的问题。下面是我的代码：
import com.outworkers.phantom.connectors.{CassandraConnection, ContactPoints}
import com.outworkers.phantom.database.Database
import scala.concurrent.Future
import com.outworkers.phantom.dsl._
case class Test(id: String, timestamp: Str
浏览 1提问于2018-07-26得票数 0
0回答
在我的Scala项目中，我使用phantom-sbt插件来启动嵌入式Cassandra。问题是，这个插件非常冗长--所有的cassandra日志都会写入stdout。
我在phantom github页面上看到，他们正在使用log4j来配置所有记录器。但它似乎不起作用(至少对我来说)。我已经将log4j.xml中的所有记录器都设置为“ERROR”，但没有任何效果。
我应该如何更改所有cassandra记录器的日志级别？
浏览 1提问于2016-07-01得票数 3
回答已采纳
对卡桑德拉来说是全新的。尝试使用phantom-dsl初始化Cassandra中的数据库。我收到了这条错误消息。
*** RUN ABORTED ***
java.lang.AssertionError: assertion failed: no symbol could be loaded from class com.datastax.driver.core.Cluster in package core with name Cluster and classloader sun.misc.Launcher$AppClassLoader@279f2327
at scala.refl
浏览 1提问于2017-01-16得票数 0
我有来自SparkStreaming的数据流。我需要对其进行处理，最后希望将数据存储在Cassandra中。所以，之前我试着使用SparkCassandra连接器。但它不提供对workers上的SparkStreaming上下文对象的访问。因此，我必须使用单独的cassandra-scala驱动程序。因此，我最终选择了。现在，我的问题是我已经在cassnandra中定义了列族。那么，如何从scala执行select和update查询呢？
我已经阅读了这些文档，但是我不明白为什么我们需要在客户端(scala代码)给出表的定义。为什么我们不能只给Keyspace，ClusterPoints和Col
浏览 10提问于2016-09-15得票数 0
在phantom-dsl版本1.12.2中，当使用RootConnector方式连接到Cassandra集群时，在完成与Cassandra的对话后关闭/关闭/清理资源的机制是什么？
浏览 0提问于2015-11-10得票数 0
我正在使用outworkers幻影scala库开发cassandra数据库的“写”端。
"read“端位于一个不同的微服务中，负责创建密钥空间和共享表。
然而，“写”方面确实有一些“划痕工作”表，这些表是它需要创建的内部关注点。
我已经找到了如何使用"autoinit=false“禁用键空间的自动创建，但我还没有找到如何禁用数据库中单个表的自动创建。我只想连接到这些表，检查它们是否存在，然后在不引发创建的情况下给它们写信。
任何指导都很感激。我使用com.outWorker:phantom-*：2.39.0和scala 2.11.12
浏览 3提问于2020-06-10得票数 4
1回答
我们在项目中使用以下依赖项。
val cassandraConnector = "com.datastax.spark" %% "spark-cassandra-connector" % "2.0.0"
val sparkSql = "org.apache.spark" % "spark-sql_2.11" % "2.2.0"
val phantomDsl = "com.outworkers" % "phantom-dsl_2.11" % "2.15.5
浏览 0提问于2017-11-16得票数 1
回答已采纳
我试图扩展我的应用程序，以包括另一个Cassandra表，用于存储每个块中包含的事务。
我试图保持代码片段的简洁性和相关性。如果需要进一步的代码上下文，请告诉我。
phantomVersion = "1.22.0" cassandraVersion = "2.1.4"
在下面列出的代码中，我得到了以下编译错误。深刻的见解受到极大的赞赏。
[error] /home/dan/projects/open-blockchain/scanner/src/main/scala/org/dyne/danielsan/openblockchain/data/databa
浏览 0提问于2016-08-09得票数 1
回答已采纳
我正在使用幻影连接到Apache Cassandra，并希望在运行时配置连接器，例如，我希望解析一些配置文件，提取Cassandra数据库的列表，并以某种方式将其传递给我的Database对象。
我跟随在Database和我的服务之间增加了一层DatabaseProvider。因此，我可以提供如下静态DatabaseProvider：
object ProdConnector {
val connector = ContactPoints(Seq("dev-cassndr.containers"), 9042)
.keySpace("test")
}
浏览 14提问于2018-02-27得票数 0
我一直在开发一个同时需要定期写入和大量读取的应用程序。
应用程序存储了几个文本列，这些列的大小不是很大，其中的映射是表中最大的列。
在Scala (下面是Datastax Java驱动程序)中使用Phantom-DSL时，我的应用程序在数据大小时崩溃。
这是我的应用程序中的一个日志。
[error] - com.websudos.phantom - All host(s) tried for query failed (tried: /127.0.0.1:9042 (com.datastax.driver.core.OperationTimedOutException: [/127.0.0.1
浏览 5提问于2015-10-12得票数 2
在本教程之后，尝试使用phantom-dsl在cassandra中创建一个模式以进行单元测试：
我在尝试自动生成模式时遇到了这个问题。
[ERROR] /home/.../test/BaseCassandraSpec.scala:54: error: not enough arguments for method autocreate: (keySpace: com.websudos.phantom.connectors.KeySpace)
com.websudos.phantom.builder.query.CreateQuery.Default[com.neruti.db.models.
浏览 0提问于2017-01-10得票数 0
每当我在Cassandra表中插入超过1000的数据并按id获取数据时，它就会抛出以下异常：
com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: localhost/127.0.0.1:9042 (com.datastax.driver.core.exceptions.BusyPoolException: [localhost/127.0.0.1] Pool is busy (no available connection and the
浏览 1提问于2017-12-20得票数 6
回答已采纳
我是不是完全漏掉了什么？尝试使用phantom构建绝对最基本的项目会导致以下错误：
could not find implicit value for parameter helper: com.outworkers.phantom.macros.TableHelper[models.Accounts,models.Account]
build.sbt使用的是版本2.12.1。
Account.scala是这样的：
package models
import com.outworkers.phantom.dsl._
case class Account(username: String)
浏览 6提问于2017-06-27得票数 1
我正在使用Cassandra 3.x和Phantom驱动程序(scala)，并将Cassandra部署从简单的三个节点集群修改为由两个数据中心组成的多数据中心Cassandra部署：
事务性-“主”数据中心，所有的读/写都会发生(除了一些分析工作所做的读/写)。
分析-仅用于分析目的的数据中心。分析工作应该对这个数据中心进行操作(即读/写)。
两个数据中心都配置了适当的告密者和复制因子策略。
基于 (“工作负载分离”部分)，我应该能够从“事务”数据中心读取/写入数据，并在“分析”数据中心上运行分析作业，但是，我不知道如何使它与幻影驱动程序一起工作。
如何将驱动程序配置为从正确的
浏览 4提问于2021-05-02得票数 1
回答已采纳
我正在使用Cassandra驱动程序来构建一个Scala和Cassandra应用程序。我的代码如下所示：
case class User(id: UUID, name:String)
abstract class Users extends CassandraTable[Users, User] with RootConnector {
object id extends UUIDColumn(this) with PartitionKey
object name extends StringColumn(this)
def save(user: User): Future[R
浏览 0提问于2017-05-14得票数 2
回答已采纳
我对scala (长时间的java开发人员)很陌生。我试图理解隐式，我认为我理解基本知识，但是我不明白为什么它找不到隐式值session。我尽量用尽可能多的信息来描述我的问题。
下面是我的博客文章：
一切都进行得很顺利，直到我想测试为止。获取以下错误：
Error:(15, 46) could not find implicit value for parameter session: com.datastax.driver.core.Session
Await.result(Database.autocreate().future(), 5.seconds)
浏览 2提问于2015-09-23得票数 3
回答已采纳
我有一个Kafka主题，每分钟获得10K个事件，还有一个scala中的Spark Streaming 2.3消费者，用来接收和摄取Cassandra。传入事件是JSON，其中包含一个'userid‘字段。但是，如果具有相同userid的事件再次出现(即使具有不同的消息体)，我仍然不希望它被摄取到Cassandra中。Cassandra表每天每分钟都在增长，因此通过将表检索到内存中的spark dataframe来查找遇到的所有userid是不可能的，因为表将变得很大。我如何才能最好地只接收唯一的记录？
updateStateByKey能工作吗？状态能维持多久？因为如果相同的userid
浏览 0提问于2018-11-09得票数 1
我正在使用Cassandra 3.x和Phantom驱动程序(scala)，并将Cassandra部署从简单的三个节点集群修改为由两个数据中心组成的多数据中心Cassandra部署：
Transactional --“主”数据中心，所有的读/写都会发生(除了某些分析工作所做的读/写之外)。
analytics -一个仅用于分析目的的数据中心。分析工作应该对这个数据中心进行操作(即读/写)。
我将分析任务上的客户端配置为对分析数据中心进行读/写，以及从事务数据中心读取/写入所有其他服务。
如何检查客户端的实际行为是否符合预期，并将数据读写到正确的数据中心？
浏览 3提问于2021-05-18得票数 2
回答已采纳
2回答
是否可以使用phantom在一个事务中执行多个查询？我不是指批量插入/更新，而是指根据一个查询的结果执行另一个查询。
在文件里没有找到任何关于这件事的东西。猜猜看，由于Cassandra和NoSQL的特殊性，它的意思是这样的。
浏览 2提问于2018-07-17得票数 0
我有以下幻影表定义：
package myPackage
import com.outworkers.phantom.CassandraTable
import com.outworkers.phantom.connectors.RootConnector
import com.outworkers.phantom.dsl._
import com.outworkers.phantom.keys.{PartitionKey, PrimaryKey}
import scala.concurrent.Future
case class KeysTwoThreeAndFour(myKeyTwo
浏览 1提问于2017-05-15得票数 0
回答已采纳
// Input Identifiers
val ids = List("4723847392423894", "4329479647236423", "42348726782684")
import spark.implicits._
val settings = Map("table" -> "table_name", "keyspace" -> "keyspace_name")
val tableDF = spark.re
浏览 2提问于2021-08-10得票数 3
1回答
我想在我的scala IDE.So中使用幻影，为此，我克隆了git集线器存储库，并使用sbt ->编译->包创建了幻影的.jar文件。
import com.websudos.phantom.connectors._
是抛错
object connector is not a member of com.websudos.phantom。
在使用scala的自动完成功能时，它只显示了
import com.websudos.phantom.example
例如，.I不知道是否创建了jar文件，那么为什么不为其他人创建jar文件。我在互联网上搜索，但所有其他选
浏览 2提问于2015-12-28得票数 0
我有一个如下所示的数据框架，并希望将此数据插入到cassandra表中
+---------+------+-----------+
| name | id | city |
+---------+------+-----------+
| sam | 123 | Atlanta |
| John | 456 | Texas |
+---------+------+-----------+
我使用下面的代码，但它只插入最后一行。
df.write.format("org.apache.spark.sql.cassandra")
浏览 0提问于2017-11-02得票数 0
1回答
我是拉格姆和持久性实体数据库概念的新手。
我正在构建流式分析引擎。我的每一个分析都将作为独立的微型服务工作，对于每一个个体的微型服务，根据其设计理念，结果将保存在自己的数据库中(我的案例卡桑德拉)。我使用Flink &，结果是Sink到Cassandra，使用幻影Flink(Scala驱动程序，为Cassandra)。我无法理解拉格姆框架中的以下挑战。
为了存储分析结果，我仍然需要实现持久性实体(P.E)来将记录存储在Cassandra中，还是应该购买-传递它，并且可以直接存储到Cassandra？我的应用程序既不支持删除也不支持更新。只插入以可视化结果。Flink & S
浏览 6提问于2017-04-19得票数 0
回答已采纳
1回答
在定义函数时，我可以创建一个隐式参数列表，它引用前面显式参数列表中的变量，但在定义类时不能。我做错了什么吗？
为了举例说明，让我们做几个对象。这里的目的是使幻影类型的层次结构“标记”对象的层次结构。我希望隐式ev保证对象来自正确的层次结构。
trait Token {
type Phantom
}
object TopToken extends Token {
trait Phantom
}
object SubToken extends Token {
trait Phantom <: TopToken.Phantom
}
object ForeignToken e
浏览 3提问于2015-08-17得票数 2
1回答
当我试图从Spark向Cassandra表中插入一些数据时，我得到了下面的错误。
com.google.common.util.concurrent.ExecutionError: java.lang.NoClassDefFoundError: Could not initialize class com.datastax.driver.core.Cluster
at com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2261)
at com.google.common.cache.Lo
浏览 11提问于2017-08-04得票数 0
在使用Cassandra 3.0.5和Scala 2.10时，我得到了以下错误：
Exception in thread "main" java.util.NoSuchElementException: key not found: 'int'
at scala.collection.MapLike$class.default(MapLike.scala:228)
at scala.collection.AbstractMap.default(Map.scala:58)
at scala.collection.Ma
浏览 0提问于2016-06-05得票数 1
我在这里遵循教程：
Cassandra版本: 2.1.8
PhatomVersion 1.10.1
Scala版本: 2.11.2
sbt-版本: 0.13.8
除了文章中给出的代码之外，我还提供了以下代码：
object App {
def main(args: Array[String]) {
val user = new User(UUID.fromString("00000000-0000-0000-0000-000000000000"), "test@test.com", "Dan", DateTime.now)
va
浏览 5提问于2015-07-26得票数 1
自从我们升级到Scala2.13之后，访问Cassandra中Date列的查询失败，并出现异常: Unable to make unsigned int (for date) from：'1601856000000‘ 这个值显然太大了，不适合无符号整型。根据Cassandra documentation，date以无符号整数的形式存储，表示自纪元以来的天数 但是，当我查看幻影- Date代码时，我发现它故意从所有支持的DateSerializer类型中获取millisSinceEpoch值，这是异常中的值 专栏：object date extends DateColumn with
浏览 7提问于2020-11-04得票数 0
我正试图在Scala中实现幻影引用，以替换finalize()。我有一个文件对象，它需要使用幻影引用进行GC编辑。虽然java中有一些代码示例，但我无法在Scala中找到任何东西。我试着用Scala这样写：
val q = new ReferenceQueue()
val phantom = new PhantomReference(file,q)
但是我得到了以下错误
found : java.lang.ref.ReferenceQueue[Nothing]
[error] required: java.lang.ref.ReferenceQueue[_ >: java.io.F
浏览 3提问于2016-02-03得票数 0
回答已采纳
1回答
请找到下面的卡桑德拉表。
我试图将数据从1个Cassandra表复制到另一个具有相同结构的Cassandra表中。
请帮帮我。
CREATE TABLE data2 (
d_no text,
d_type text,
sn_perc int,
tse_dt timestamp,
f_lvl text,
ign_f boolean,
lk_loc text,
lk_ts timestamp,
mi_rem text,
nr_fst tex
浏览 0提问于2018-08-20得票数 3
回答已采纳
我在读取包含>800 k行的表时遇到了问题。我需要从上到下读取行，以便处理它们。
我使用Scala和Phantom来实现这个目的。
这是我桌子的样子。
CREATE TABLE raw (
id uuid PRIMARY KEY,
b1 text,
b2 timestamp,
b3 text,
b4 text,
b5 text
) WITH bloom_filter_fp_chance = 0.01
AND caching = '{"keys":"ALL", "rows_per_par
浏览 0提问于2016-01-29得票数 0
回答已采纳
我们最近启动了使用Scala、Spark和Cassandra的大数据项目，而我对所有这些技术都是新手。我试图做一个简单的任务，写和读卡桑德拉表。如果我将属性名和列名都保留在小写或蛇形大小写(unserscores)中，我就能够做到这一点，但我希望在scala代码中使用camel大小写。是否有更好的方法来实现这一点，使用camel case格式在Scala和蛇案例在cassandra。
我们正在使用
Scala-2.10.5火花- 1.6.2 datastax火花- cassandra -连接器- 1.6.0 cassandra- 3.0.9.1346 datastax企业- 5.0.3
浏览 3提问于2016-10-22得票数 2
回答已采纳
我使用的是星星之火-sql.2.4.1v，datastax-java-cassandra-connector_2.11-2.4.1.jar和java8。
我创建cassandra表如下所示：
create company(company_id int PRIMARY_KEY, company_name text);
JavaBean如下所示：
class CompanyRecord(
Integer company_id;
String company_name;
//getter and setters
//default & parametarized constructors
浏览 2提问于2019-10-28得票数 1
我已经安装并配置了DSE 4.8.5，并尝试运行一些Spark查询。然而，我从Spark查询中得到了预期的结果；每个查询都在java堆栈错误之后进行转储。
>>> rdd.first()
WARN 2016-05-03 16:14:14,245 com.datastax.driver.core.NettyUtil: Found Netty's native epoll transport in the classpath, but epoll is not available. Using NIO instead.
java.lang.UnsatisfiedLink
浏览 2提问于2016-05-03得票数 0
我正在尝试使用幻影创建以下Cassandra表
object itemId extends StringColumn(this) with PartitionKey[String]
object anotherItemId extends StringColumn(this) with PrimaryKey[String]
object similarity extends DoubleColumn(this) with ClusteringOrder[Double] with Descending
所以我希望能够通过itemId获得所有的记录。我希望similarity命令他们。
浏览 3提问于2016-10-14得票数 0
回答已采纳
我有一个Scala模型类，它的对象我想将它存储到Cassandra table.there中，这是一个与Cassandra和Scala类变量声明的列名顺序不匹配的结果。
在Cassandra表中还有一个额外的列，它不在Scala类变量列表中，比如(tr_tag Text)，但是我不能这样做。
数据不会被插入。请帮我解决这个问题。
scala类模型：
class THData() extends Serializable{
var s_id: java.lang.Long = null
var a_id: String = null
var s_typ: Strin
浏览 0提问于2018-09-24得票数 1
Spark version:3.00
scala:2.12
Cassandra::3.11.4
spark-cassandra-connector_2.12-3.0.0-alpha2.jar 我没有使用DSE。下面是我将数据帧写入Cassandra数据库的测试代码。 spark = SparkSession \
.builder \
.config("spark.jars","spark-streaming-kafka-0-10_2.12-3.0.0.jar,spark-sql-kafka-0-10_2.12-3.0.0
浏览 27提问于2020-06-27得票数 2
回答已采纳
我在使用datastacks/ Spark - Cassandra -connector将cassandra (Scylla)数据加载到Apache spark时遇到了问题：
scala> val rdd = sc.cassandraTable[(String)](keyspace, table).select("url").limit(10).collect()
java.util.NoSuchElementException: key not found: duration
at scala.collection.MapLike$class.default(MapLi
浏览 3提问于2020-02-27得票数 0
1回答
我想在scala项目中使用幻影cassandra包装器，但是当我试图更新sbt构建时，我会得到一个依赖错误。
我的build.sbt：
version := "1.0"
scalaVersion := "2.11.2"
seq(lsSettings :_*)
libraryDependencies ++= Seq(
"org.clapper" %% "grizzled-scala" % "1.2",
"commons-io" % "commons-io" %
浏览 1提问于2014-08-23得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
