我正在尝试集成Cassandra和Spark Thrift服务器。我遵循了中的步骤下面是我运行的查询
CREATE TABLE test_data USING org.apache.spark.sql.cassandra
浏览 5提问于2018-07-10得票数 1
我阅读了，它告诉我服务器与有关，这是一种二进制通信协议。Spark Thrift服务器是Hive的接口，但是Spark Thrift服务器如何使用Apache Thrift通过二进制协议/rpc与Hive通信？
浏览 27提问于2017-08-14得票数 5
回答已采纳
我有一个Cassandra集群，它有一个位于同一位置的星火集群，我可以通过编译它们、复制它们并使用./ Spark submit脚本来运行通常的星火作业。我编写了一个小作业，它接受SQL作为命令行参数，将它作为Spark提交给Spark，Spark针对Cassandra运行该SQL，并将输出写入csv文件。现在，我觉得我在兜圈子，试图找出是否可以在JDBC连接中通过Spark直接查询Cassandra (例如来自松鼠SQL)。Spar
浏览 4提问于2015-12-10得票数 1
回答已采纳
我的存储后端是Cassandra，4000万个点和1.2亿个边。janusgraphmr.ioformat.conf.storage.cql.keyspace=probe
cassandra.input.partitioner.class=org.apache.cassandra.dht.Murmur
浏览 1提问于2018-11-15得票数 0
所以我和Tableau，Spark1.2和Cassandra2.1.2一起工作。我成功地做了许多事情。
通过从shell连接到Cassandra实例。通过前面提到的指向Cassandra实例的连接器进行SparkSQL查询。使用Tableau (最新的CQL3兼容Simba驱动程序，用于Cassandra：)在Cassandra实例上运行查询和可视化。for jdbc:hive2://192.168.56.11
浏览 2提问于2015-01-20得票数 6
2回答
我使用datastax + spark集成和spark SQL节俭服务器，这为我提供了一个Hive SQL接口来查询Cassandra中的表。:ExecuteStatement:ThriftCLIService.java:437'，'org.apache.hive.service.cli.thrift.TCLIService$Processor$ExecuteStatement:getResult:TCLIService.java:1313'
浏览 7提问于2017-06-16得票数 8
通过为maven依赖项提供火花- classPath来减少应用程序jar的大小：
我的集群有3个ec2实例，其中hadoop和spark是running.If --我构建了带有maven依赖项的jar，/com/datastax/cassandra/cassandra-driver-core/2.1.5/cassandra-driver-core-2.1.5.jar:/home/spark/.m2&
浏览 4提问于2015-07-29得票数 10
回答已采纳
我正在考虑Cassandra是否可以为我们的服务器软件提供分布式数据库存储。
服务器软件是用Delphi编写的，但我很难找到如何从Delphi访问Cassandra数据库的描述。
浏览 1提问于2010-03-17得票数 2
我已经启动了spark-thrift服务器，并使用beeline连接到了thrift服务器。在尝试查询时，在配置单元元存储中创建一个表时，我收到以下错误。创建表 create table meeting_details using org.apache.spark.sql.cassandra options (keyspace ‘TravelData’,org.apache.spark.sql.cassandra不是有效的Sp
浏览 36提问于2021-05-08得票数 1
回答已采纳
1回答
我正试图在创建JanusGraph的集群上运行Spark作业。 at org.janusgraph.diskstorage.cassandra.thrift.CassandraThriftStoreManagerat org.janusgraph.diskstorage.cassandra.<e
浏览 0提问于2018-04-12得票数 2
回答已采纳
1回答
通过运行以下命令： --class+= "datastax" % "spark-cassandra-connector" % "1.6.0-s_2.10"
libraryDependencies ++= Seq("org.apache.cas
浏览 2提问于2016-09-06得票数 1
回答已采纳
是否可以在Kubernetes上运行Apache Hive (不在Kubernetes上运行YARN )？
浏览 4提问于2018-05-28得票数 5
3回答
我是Spark和Cassandra的新手。我面临着一个主要的性能问题，我在Spark中每隔5秒流式传输来自Kafka的数据，然后使用JRI对R语言中的数据进行分析，最后将数据保存到Cassandra各自的列族中。将数据保存到Cassandra的持续时间(以毫秒为单位)随着输入请求的数量增加非常快，每个请求为200KB。 sessionData.foreachRDD(new Function<JavaRDD<NormalizedDa
浏览 0提问于2015-11-10得票数 0
1回答
我的环境:我正在尝试通过Spark Thrift服务器连接Cassandra。然后，我在Hive Metastore中创建一个Meta-Table，其中包含Cassandra表数据。我已经为Spark Thrift服务器启用了公平调度。
问题:当我通过JMeter为100个用户执行持续300秒的并发负载测试时，初始请求的响应时间不到几秒(比如前30秒)。当我检查Spark UI时，所有作业的执行时间都不到100毫秒。我还注意到，当收到
浏览 10提问于2018-08-16得票数 0
我们需要同时从hive和spark (使用thrift服务器)访问表格。然而，我们的问题是在spark上运行spark和thrift服务器导致一个表的查找。我们在Amazon AWS EMR集群上运行，其中包含Hive、Spark和thrift Server2。
我们希望使用hive更新s3存储，并定期在后台将这些聚合数据加载到spark中。同时，Spar
浏览 2提问于2015-12-22得票数 0
3回答
我想通过使用spark-cassandra-connector执行一个spark项目来连接卡桑德拉，如下所示：
sparkCassandra.scala
import com.datastax.spark.co
浏览 6提问于2014-12-04得票数 0
我在Cassandra上安装了Twissandra --一个python示例。。在Lubuntu 10.04 (使用Thrift 4.0，然后尝试使用2.0)上成功编译和构建所有依赖项后--当我使用when服务器运行最后一步时-它崩溃并发布以下Apache Thrift错误：这是节俭问题(4.0)还是Cassandra问题(7.0
浏览 3提问于2010-09-13得票数 1
回答已采纳
我正在尝试在不同的端口上运行Spark thrift服务器，比如12000。我引用了Spark sql文档和其他port.It，但我不能在不同的urls上运行Spark thrift服务器，也不能在端口10000上运行，因为它正在被Hive使用。
我还引用了并进行了更改。已尝试从Spark_home/sbin>导出HIVE_SERVER2_THRIFT_PORT=12000启动Spark</e
浏览 0提问于2015-04-17得票数 4
1回答
我运行的是cassandra 1.2.6和Apache Spark 0.8.0。INFO 21:36:28,629 Listening for thrift clients...at org.apache.thrift.transport.TIOStream
浏览 7提问于2014-01-07得票数 5
我有一个包含8个节点的cassandra集群，cassandra 1.0.8。org.apache.thrift.transport.TTransportException: java.net.SocketException)
at org.apache.thrift.transport.TFramedTransport.flush(TFramedTransport
浏览 4提问于2012-07-12得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
