com.datastax.spark.connector.writer.RichBoundStatement@58aafafcom.datastax.driver.core.exceptions.InvalidQueryException
浏览 21提问于2016-09-22得票数 1
回答已采纳
我正在尝试使用Spark-cassandra连接器连接到spark shell中的远程cassandra集群。但是它抛出了一些不寻常的错误。我做了spark-cassandra连接器的github页面上提到的通常的事情 $SPARK_HOME/bin/spark-shell --packages datastax:spark-cassandra-connector:2.0.0-s_2.11import com.
浏览 0提问于2018-09-17得票数 3
为了创建表，我使用cassandra-driver、Python-Cassandra连接器删除并创建表。然后，我使用spark-cassandra连接器将数据帧写入到表中。只使用spark-cassandra连接器创建和删除表并不是一个很好的选择。 在Spark 2.4中，drop-create-write流程没有问题。execute table creation session.shutdown()
浏览 42提问于2020-10-19得票数 1
我在Spark 2.1.0 / Cassandra 3.10集群(4台机器* 12个内核* 256个RAM *2个SSD)上工作，并在相当长的一段时间内努力提高使用spark- Cassandra -connector 2.0.1向cassandra写入特定大数据帧的性能。CREATE TABLE sample_table ( field1 int, field3 boolean, field5 big
浏览 2提问于2017-05-12得票数 1
1回答
有没有可能更新我搜索的cassandra中的列值(是我的主键的一部分)？因此，我搜索这些列的原因是我想要更新它们，并且在更新它们之后，我想将时间戳设置为当前日期。
浏览 1提问于2017-03-08得票数 0
我正在尝试将spark数据帧加载到Cassandra表中，该数据帧具有两个具有集合数据类型的属性。 在传入的提要文件中，这些属性是文本/字符串。我使用下面的代码将String类型分别转换为List和Map类型： spark.udf.register("getLst", (input: String) => input.split(",").toList)
spark.udf.register("getMap", (input:String) => parse(input).values.asInstanceOf[M
浏览 18提问于2019-01-23得票数 0
回答已采纳
1回答
我们使用的是datastax的spark-cassandra连接器。我尝试了不同的方法，但都没有帮助提高性能。
浏览 3提问于2017-03-15得票数 2
我有一个用例，在这个用例中，我希望序列化Cassandra BoundStatement，并将其转换为byte[]数组，并通过网络发送它，并将其反序列化回Bound Statement对象。但是的问题是 BoundStatement没有实现Serializable接口。
浏览 2提问于2017-07-15得票数 0
我想将数据从hortonworks hive导出到Cassandra，有没有一种方法可以不使用ETL工具将数据从Horton works Hive导出到datastax Cassandra？
浏览 3提问于2016-03-23得票数 0
我的数据最初在拼图中，我用Spark SQL读取它，有一个大数据框架，然后我使用Spark-Cassandra连接器将其写入C*。
浏览 0提问于2016-08-27得票数 1
我使用的是Spark版本1.6.2，Spark-Cassandra连接器1.6.0，Cassandra-Driver-Core 3.0.3那么，有没有人能帮我交叉验证一下Spark-Cassandra Connector用来在Cassandra
浏览 1提问于2017-01-24得票数 2
在java中使用spark-cassandra连接器时出现以下错误：
Exception in thread "main" java.lang.NoSuchMethodError: com.datastax.driver.core.ColumnMetadata.isStatic
浏览 1提问于2014-08-24得票数 0
一般来说，我遵循‘安装卡桑德拉/星火开放源码软件栈’由艾米托比为“使用火花卡桑德拉连接器”部分。控制台输出：$ /usr/local/src/spark/spark-1.1.0/bin/spark-shell --jars /usr/local/src
浏览 0提问于2015-03-29得票数 0
回答已采纳
我已经创建了一个JavaPairInputDStream，并尝试将消耗的数据保存到Cassandra表中。但是面临着问题，并且不确定如何从代码开始：package com.test.anna.KafkaSpark;
import static com.datastax.spark.connector.japi.CassandraStreamingJavaUtil.*;
import j
浏览 0提问于2017-10-05得票数 0
我使用的是Lagom持久化，在尝试持久化Cassandra中的事件时，我使用的是thenPersistAll，但在DC/OS集群上运行该服务时，偶尔会抛出InvalidQueryException -
浏览 2提问于2018-04-14得票数 0
1回答
host(s) tried for query failed (tried: localhost/127.0.0.1:9042 (com.datastax.driver.core.exceptions.InvalidQueryException
浏览 0提问于2016-05-25得票数 0
回答已采纳
1回答
spark-cassandra连接器是如何工作的？它和cqlsh不同吗？请告诉我。
谢谢。
浏览 5提问于2017-05-15得票数 1
回答已采纳
我正在使用Azure上的Jupyter Spark clusters，而HDInsight无法添加外部依赖项。我试过了：但是，如果我故意犯了一个错误：{ "packages":["com.websudos:phantom_2.10:1.27.111111111111"] }
浏览 1提问于2016-08-26得票数 0
回答已采纳
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号