如何从String Spark Java列表的数据集创建String数据集
从String Spark Java列表的数据集创建String数据集可以通过以下步骤实现：
- 导入必要的Spark Java库和类：
import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;
import org.apache.spark.sql.SparkSession;- 创建SparkSession对象：
SparkSession spark = SparkSession.builder()
.appName("StringDatasetCreation")
.master("local")
.getOrCreate();这里使用本地模式，你可以根据实际情况选择合适的master地址。
- 创建JavaSparkContext对象：
JavaSparkContext jsc = new JavaSparkContext(spark.sparkContext());- 创建String列表：
List<String> stringList = Arrays.asList("String1", "String2", "String3");- 将String列表转换为JavaRDD对象：
JavaRDD<String> stringRDD = jsc.parallelize(stringList);- 将JavaRDD转换为String数据集：
Dataset<Row> stringDataset = spark.createDataset(stringRDD, Encoders.STRING());现在你已经成功从String Spark Java列表的数据集创建了String数据集。你可以根据需要对该数据集进行进一步的处理和分析。
注意：这里使用了Spark的Java API，如果你熟悉其他编程语言，可以使用相应的API进行类似的操作。
相关·内容
1回答
我正在尝试从sql服务器数据库中获取数据，并创建一个spark数据集。当我将数据集持久化到orientdb时，无法做到这一点。
下降到误差以下
线程“主”'jdbc:orient:REMOTE:localhost/test'中的异常:连接异常发生:打开数据库java.lang.RuntimeException时出错
这是我的代码：
Map<String, String> options = new HashMap<>();
options.put("driver", "com.microsoft.sqlserver
浏览 2提问于2017-02-28得票数 0
我试着用spark将数据从Oracle数据库读取到dataset中，然后将数据集转换为javaRDD进行地图操作，我的代码只能存储数据集火花官方文档显示：
// Apply a schema to an RDD of JavaBeans to get a DataFrame
Dataset<Row> peopleDF = spark.createDataFrame(peopleRDD, Person.class);
我们的数据是从Oracle中读取的，如何定义，如何存储，以将转换为dataset？或者如何使用Java直接对数据集进行地图操作？当我的代码是这样的时候，我应该做什么？
浏览 10提问于2017-01-09得票数 3
我已经构建了一个Java应用程序来显示从数据库中获取的数据。我构建了一个JavaSpark应用程序，并将其构建为一个jar。我通过星火发射器作为参数输入Spark应用程序。我的javaSpark应用程序从数据库中获取数据并将其存储为一个列表。如何将列表返回到我的主Java程序
Main.java：
public Static void Main(String[] args){
String query = select fname,lname from people;
SparkLauncher sl = new SparkLauncher();
sl.Laun
浏览 1提问于2016-03-11得票数 0
回答已采纳
1回答
我正在使用，并尝试从文本文件中创建数据和数据集。
要从文本文件获取数据集，有两个选项，文本和textFile方法，如下所示：
scala> spark.read.
csv format jdbc json load option options orc parquet schema table text textFile
下面是如何从这两种方法获取数据集和数据：
scala> val df = spark.read.text("/Users/karanverma/Documents/logs1.txt")
df: or
浏览 0提问于2019-03-28得票数 1
回答已采纳
我使用的是Spark2.1，我想编写一个Person列表，因为dataframe.Person类有一个嵌套的java bean类Address 人员： public class Person {
private String name;
private Address address;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public Addre
浏览 23提问于2019-05-14得票数 2
我正在使用java spark，下面是我的代码。
JavaRDD<MyComplexEntity> myObjectJavaRDD = resultJavaRDD.flatMap(result -> result.getMyObjects());
DataFrame df = sqlContext.createDataFrame(myObjectJavaRDD, MyComplexEntity.class);
df.saveAsParquetFile("s3a://mybucket/test.parquet");
MyComplexEntity.java
浏览 2提问于2020-09-11得票数 0
我想做一个简单的Spark代码，它读取一个名为u.data的文件，该文件包含电影分级，创建一个Dataset of Rows，然后打印数据集的第一行。
我的前提是将文件读取到JavaRDD，并根据ratingsObject映射RDD (对象有两个参数，movieID和rating)。所以我只想打印这个数据集中的第一行。
我使用Java语言和Spark。
public static void main(String[] args){
App obj = new App();
SparkSession spark = SparkSession.builder().appName(&
浏览 0提问于2018-07-31得票数 4
回答已采纳
1回答
我的工作是通过SparkSQL实现HDFS到弹性搜索的集成。我可以从HDFS读取csv数据并创建弹性搜索索引。为了创建Elastic search Index ID，我使用了csv数据中的一个唯一列。现在我的要求是弹性搜索索引ID应该是2个CSV列的组合。有没有人知道我该如何做到这一点？我正在使用elasticsearch-spark库创建索引。以下是示例代码。
SparkSession sparkSession = SparkSession.builder().config(config).getOrCreate();
SQLContext ctx = sparkSession.sqlCon
浏览 0提问于2017-09-13得票数 1
我使用的是Java。
我正在接收Kafka消息上的文件路径。我需要将这个文件加载到spark RDD中，对其进行处理，然后将其转储到HDFS。
我能够从Kafka消息中检索到文件路径。我希望在此文件上创建一个dataset / RDD。
我不能在Kafka消息数据集上运行map函数。由于sparkContext在worker上不可用，因此出现NPE错误。
我不能在Kafka消息数据集上运行foreach。它会出错，并显示以下消息：
Queries with streaming sources must be executed with writeStream.start();"
我不
浏览 0提问于2017-09-26得票数 4
1回答
我正在尝试创建一个基于我有4个列表的数据。我只能使用scala (由于各种原因我们不能使用SQL )。
所有列表都有3个值，column_head列表是列名的列表。
column_head =["a","b","c"]
master_in =[1,2,"dog"]
master_out =[3,4,"cat"]
master_max = [5,6,"llama"]
我试过：
val values
=Seq(columns_head,master_in,master_out,master_ma
浏览 1提问于2019-03-17得票数 1
回答已采纳
1回答
我正在尝试使用spark_apply将R函数应用于Spark DataFrame。在我最初的问题中，我有一个列表列表，我已经将其转换为R数据帧，我将能够将其转换为Spark DataFrame。
但是在我的R函数中，我需要使用一个列表列表，而我不知道如何从数据帧中取回我的初始列表列表。
我已经找到了如何将dataFrame转换为列表的方法：
lapply(seq(along = rownames(testP)),
function(i) as.list(testP[i, ]))
我终于有了24个列表的列表，但我正在寻找8个列表的3个列表。
感谢您的帮助！
浏览 10提问于2019-07-05得票数 2
回答已采纳
当我尝试连接来自数据库和csv文件的两个数据集时，我遇到了一个错误，错误消息如下： org.apache.spark.SparkException: Job aborted due to stage failure: Task 0 in stage 14.0 failed 1 times, most recent failure: Lost task 0.0 in stage 14.0 (TID 14, localhost, executor driver): java.lang.RuntimeException: Error while encoding: java.lang.ArrayI
浏览 23提问于2019-10-11得票数 2
2回答
我正在尝试测试pyspark是否在我的系统上正常运行，但是当我尝试对我的数据调用fit时，我得到了错误，"Requirement : Nothing is but to this summarizer“
import findspark
import os
spark_location='/usr/local/spark/'
java8_location= '/usr/lib/jvm/java-8-openjdk-amd64'
os.environ['JAVA_HOME'] = java8_location
findspark.init(
浏览 1提问于2019-11-13得票数 2
在Java中，我有一个带有java.util.ArrayList<Short>类型列的Spark (Spark结构化流)，我希望将数据集写入一个具有相应list<smallint>的Cassandra表中。
每次我用Cassandra写行时，它都会更新一个现有的行，并且我希望自定义list的写行为，以便控制
书面列表将覆盖现有列表或，书面列表的内容将被附加到已保存在Cassandra<code>F 212</code>中的列表的内容中。
我在spark-cassandra-connector源代码中找到了一个由CollectionAppend和C
浏览 5提问于2019-09-26得票数 0
我正在检查将星火GraphX图输出到土卫六图形数据库的可行性。
***Used below code to construct graph in Spark GraphX and writing graph to a json file :***
val conf = new SparkConf()
val sc = new SparkContext(conf.setAppName("========= GraphXTest ======="))
// Create an RDD for the verti
浏览 2提问于2016-02-10得票数 1
嗨，我正在spark上下文中读取拼图文件，然后合并各种拼图文件的模式。然后，我保存从read parquet函数返回的数据帧，并使用write.parquet命令保存。
Here is the code:
options:Map[String,String] = Map[String,String]()
val options2 = options.+("mergeSchema" -> "true")
df = sqc.read.options(options2).schema(schemaObj).parquet(paths:
浏览 1提问于2016-03-16得票数 1
我试图从包含列表中单词的数据行中提取:下面是粘贴我的代码：
from pyspark.ml.feature import Tokenizer, RegexTokenizer
from pyspark.sql.functions import col, udf
from pyspark.sql.types import IntegerType
from pyspark.sql.types import IntegerType
import findspark
findspark.init()
conf = SparkConf().setAppName("nlp").setMast
浏览 3提问于2021-06-16得票数 2
回答已采纳
1回答
我创建了一个DataFrame，如下图所示，我想为列“title”应用map- some算法，但是当我使用reduceByKey函数时，我遇到了一些问题。
+-------+--------------------+------------+-----------+
|project| title|requests_num|return_size|
+-------+--------------------+------------+-----------+
| aa|%CE%92%CE%84_%CE%...| 1| 4854
浏览 0提问于2018-04-08得票数 1
回答已采纳
我有一个流，它为不同的区域并行执行Dataproc集群上的火花作业。对于每个区域，它创建一个集群，执行星火作业，并在集群完成后删除它。
spark作业使用传递org.apache.spark.rdd.PairRDDFunctions.saveAsNewAPIHadoopDataset的方法将数据保存到BigQuery表中。作业将数据保存在多个表中，每个作业调用saveAsNewAPIHadoopDataset方法不止一次。
问题是，有时我会在Hadoop临时BigQuery数据集中得到一个错误，这个冲突是它内部为运行作业而创建的：
Exception in thread "main&#
浏览 0提问于2018-03-13得票数 0
回答已采纳
1回答
我有下面的案例类
case class Station(id: Long, name: String) extends Node
和星星点点的站点数据
vertices: org.apache.spark.sql.Dataset[Station] = [id: bigint, name: string]
我想将顶点数据集转换为SeqStation。我发现了很多关于如何从序列创建数据集的教程，但反之亦然。你有什么提示给我吗？
浏览 2提问于2019-04-04得票数 2
回答已采纳
Exception in thread "main" java.lang.IllegalArgumentException: Field "features" does not exist.
at org.apache.spark.sql.types.StructType$$anonfun$apply$1.apply(StructType.scala:264)
at org.apache.spark.sql.types.StructType$$anonfun$apply$1.apply(StructType.scala:264)
at s
浏览 2提问于2017-06-13得票数 2
我试着理解如何使用Spark，但总是有一些问题，所以也许有人可以建议我读什么等等。我试着阅读火花文档和学习火花-O‘’Reilly媒体书，但找不到任何解释，我们需要多少内存来处理不同大小的网络等等。
在我的测试中，我使用了几个示例数据集。我在Spark中的一个主节点(~16 on )上运行它们：
./bin/spark-shell --master spark://192.168.0.12:7077 --executor-memory 2900m --driver-memory 10g
3-5名工人(每1台机器有1台工人，每台机器有4Gb内存)：
./bin/spark-class org.a
浏览 1提问于2015-05-04得票数 0
我刚接触过Java和，并试图找出如何从spark中的数据集中作为一个平面列表来获取单个列的值。
Dataset<Row> sampleData = sparkSession.read()
.....
.option("query", "SELECT COLUMN1, column2 from table1")
.load();
List<Row> columnsList = samp
浏览 3提问于2020-04-06得票数 0
回答已采纳
1回答
我正在尝试使用JDBC处理Presto上的查询，并将结果集传回Spark，以便在其上创建临时表。我的结果集在列表中
我正在收到来自卡夫卡制片人的json Msg形式的查询。因此，创造了卡夫卡消费者在火花中得到的信息，并做进一步的处理。
以下是我的主要职能：
public static void main(String[] args) throws InterruptedException {
SparkConf conf = new SparkConf();
conf.setAppName("Wordcount Background");
conf
浏览 0提问于2019-05-30得票数 1
我正在阅读Spark2.2.0文档，发现这是对Static DataFrames 的奇怪引用
因为Spark2.0，DataFrames和数据集可以表示静态的、有界的数据，以及流的、无界的数据。与静态数据集/DataFrames类似，您可以使用公共入口点SparkSession (Scala/Java/Python/R )从流源创建流DataFrames/Datasets，并对它们应用与静态DataFrames/Datasets相同的操作。
这尤其令人困惑，因为Datasets (我理解为静态类型的数据格式)、Static DataFrame和Dataset的概念在我的脑海中似乎是重叠
浏览 1提问于2017-12-24得票数 1
回答已采纳
1回答
我正在使用一个Dataframe，它有一个类似于此的复杂模式：
root
|-- NPAData: struct (nullable = true)
| |-- NPADetails: struct (nullable = true)
| | |-- location: string (nullable = true)
| | |-- manager: string (nullable = true)
| |-- usersDetails: array (nullable = true)
| | |-- element: struc
浏览 2提问于2017-09-26得票数 1
回答已采纳
1回答
我正在使用Scala和Spark来分析一些数据。对不起，我是这方面的新手。
我有以下格式的数据(下面)，我想要创建RDD来过滤数据、分组和转换数据。
目前，我有一个包含未解析字符串列表的rdd，我已经从rawData:字符串列表创建了它。
val rawData ( this is ListBuffer[String] )
val rdd = sc.parallelize(rawData)
如何创建数据集来操作数据？我希望在Rdd中有带有命名字段的对象，行ob.name，obj.year等等，什么是正确的方法？
我应该为此创建数据框架吗？
原始数据字符串如下所示:这是字符串列表，其中空格分隔
浏览 1提问于2018-05-16得票数 0
回答已采纳
1回答
运行示例时出错
、、、
我有下面的，可以在官方的apache/spark上找到。我花了很多时间了解如何在Hortonworks Hadoop Sandbox中运行这个示例，但没有成功。
目前，我正在做以下工作：
导入作为我的Maven-项目，这是很好的工作，我没有任何问题的礼仪，所以这里没有问题，我想。
下一步是准备在我的Hadoop中运行的代码--问题从这里开始，我可能设置了一些错误。这就是我要做的：
将SparkSession设置为主从本地，将spark.sql.warehouse.dir更改为hive.metastore.uris，并将节俭://localhost:9083(如我在安巴里的蜂巢中
浏览 2提问于2017-12-18得票数 1
回答已采纳
我在执行星火应用程序时遇到了问题。
源代码：
// Read table From HDFS
val productInformation = spark.table("temp.temp_table1")
val dict = spark.table("temp.temp_table2")
// Custom UDF
val countPositiveSimilarity = udf[Long, Seq[String], Seq[String]]((a, b) =>
dict.filter(
(($"first"
浏览 3提问于2017-11-04得票数 10
回答已采纳
我有一个文本文件格式的数据集，我正在尝试使用case类创建一个dataframe，但我得到了下面提到的错误：
线程main java.lang.IllegalArgumentException异常:要求失败:列数不匹配。旧列名(1)：值新列名(4)：名称、年龄、部门、薪资
这是我的数据集的前三行：
Name,Age,Department,Salary
Sohom,30,TD,9000000
Aminul,32,AC,10000000
我使用的代码如下：
import org.apache.log4j.Logger
import org.apache.log4j.Level
import
浏览 17提问于2021-02-12得票数 0
回答已采纳
1回答
我正在使用readStream阅读kafka主题，并尝试在控制台上显示数据。
df = spark.readStream.format("kafka")\.option("kafka.bootstrap.servers", kafkaServer)\.option("subscribe", topic_name_read)\.option("includeHeaders", "true")\.option("startingOffsets", "latest")\.load()\.s
浏览 5提问于2022-03-30得票数 0
我已经创建了一个IBM服务实例，其中包含5个节点的BigInsights集群(包括Apache Spark)。我尝试使用SparkR连接Cloudant数据库，获取一些数据，并进行一些处理。
我已经启动了一个SparkR外壳(终端)，并运行了以下代码：
sparkR.stop()
# Creating SparkConext and connecting to Cloudant DB
sc <- sparkR.init(sparkEnv = list("cloudant.host"="<<cloudant-host-name>>",
浏览 8提问于2016-08-06得票数 2
我正在尝试从宇宙数据库(MongoDB API)创建一个火花数据格式。但我得到了一个例外：
*com.mongodb.MongoCommandException:命令失败，错误16501：“查询超过了40 MB的最大允许内存使用量。请考虑添加更多的过滤器以减少查询响应的大小。”在服务器*****.documents.azure.com:10255上。完整响应为{"_t"："OKMongoResponse“、"ok"：0、”代码“：16501、"errmsg"：”查询超出了40 MB的最大允许内存使用量。请考虑添加更多筛选器以减少查询响应大
浏览 3提问于2020-12-23得票数 0
我正在使用Spark2.0来分析一个数据集。有一列包含如下字符串数据：
A,C
A,B
A
B
B,C
我希望得到一个包含列中所有不同项的JavaRDD，如下所示：
A
B
C
如何在火花中有效地做到这一点？我在Java中使用Spark，但是Scala示例或指针是有用的。
编辑:我尝试过使用flatMap，但是我的实现非常慢。
JavaRDD<String> d = dataset.flatMap(s -> Arrays.asList(s.split(",")).iterator())
浏览 6提问于2016-10-13得票数 2
回答已采纳
我使用Azure Databricks解决方案连接到Cassandra。我的Cassandra实例在某个特定端口公开，并可从cqlsh访问。Cassandra显示版本返回：
[cqlsh 6.0.0 | Cassandra 3.11.10 | CQL spec 3.4.4 | Native protocol v4]
我创建了运行在运行时上的Cluster：
7.3 LTS (includes Apache Spark 3.0.1, Scala 2.12)
我安装了以下库：com.datastax.oss:java-driver-core:4.12.0和com.datastax.spark:sp
浏览 13提问于2022-04-25得票数 1
回答已采纳
1回答
在云Datafusion中，我使用一个合并转换来连接两个表。
其中一张是一张大桌子，约合87M，而另一张是一张较小的桌子，只有250张记录。我在接合器中使用200个分区。
这将导致以下失败：
org.apache.spark.SparkException:由于阶段失败而中止作业:阶段7.0中的任务50失败4次，最近一次失败:阶段7.0中丢失的任务50.3 (TID，cluster_workerx.c.project.internal，执行器6)：ExecutorLostFailure (执行器6由于运行中的任务之一退出)原因:执行器心跳在133355 ms之后超时java.util.conc
浏览 4提问于2020-01-10得票数 1
我已经创建了一个JavaPairInputDStream，并尝试将消耗的数据保存到Cassandra表中。但是面临着问题，并且不确定如何从代码开始：
这是我为SparkStreaming编写的代码：
package com.test.anna.KafkaSpark;
import static com.datastax.spark.connector.japi.CassandraJavaUtil.mapColumnTo;
import static com.datastax.spark.connector.japi.CassandraStreamingJavaUtil.*;
import j
浏览 0提问于2017-10-05得票数 0
我正在开发Java应用程序，它使用Spark 2.3.1将数据从Oracle加载到HDFS，反之亦然。我想在HDFS中创建CSV文件，然后将其加载到Oracle (12.2) BLOB中。
代码..
//create Dataset
Dataset<Row> dataset = SparkService.sql("select * from test_table");
String trgtFileWithPath = "/tmp/test_table.csv";
//sa
浏览 30提问于2020-05-19得票数 0
回答已采纳
我使用的是spark API spark.read.jdbc(String url,String table,java.util.Properties properties)。它使用从数据库表返回的模式创建数据帧。 每次我调用上述API时，它都会创建一个到DB集群的连接请求。有没有办法在上面的API中传递或创建单例类的东西？
浏览 15提问于2020-04-27得票数 0
1回答
火花UDF过载
、、
我有一个要求，星火UDF必须过载，我知道UDF超载是不支持在星火。因此，为了克服spark的这个限制，我尝试创建一个接受任何类型的UDF，并在UDF中找到实际的数据类型，并调用相应的方法进行计算并返回相应的值。当我这样做时，我得到了一个错误
Exception in thread "main" java.lang.UnsupportedOperationException: Schema for type Any is not supported
at org.apache.spark.sql.catalyst.ScalaReflection$$anonfun$sche
浏览 3提问于2020-09-28得票数 0
1回答
我正在使用火花从卡夫卡获得数据，并将其插入卡桑德拉。我的程序是
public static void fetchAndValidateData() {
SparkConf sparkConf = new SparkConf().setAppName("name")
.set("spark.cassandra.connection.host", "127.0.0.1")
.set("spark.cleaner.ttl", "3600");
JavaStr
浏览 3提问于2016-08-25得票数 1
回答已采纳
1回答
我正在使用Scala绑定创建一个Spark应用程序。但是我的一些模型(类)是用Java编写的。当我试图创建一个基于Scala的数据集时，它工作得很好，当我执行show()时，所有的列都是可见的。但是，当我创建一个基于Java的数据集时，所有的列都打包在一个名为value的列中。
Scala案例类示例：
case class Person(name: String, age: Int)
处决：
sqlContext.createDataset(Seq(Person("abcd", 10))).show()
输出：
name | age
abcd | 1
浏览 1提问于2019-07-31得票数 2
回答已采纳
在下面的代码中，有一个PairFunction，它将数组列表拆分为键和值。
private static PairFunction<String,String,Integer> getNameAndAgePair() {
return (PairFunction<String,String,Integer>) s ->
new Tuple2<>(
s.split(" ")[0],
Integer.valueOf(s.split(" ")[1]));
}
有人能解释一下这到底是怎么回事
浏览 1提问于2020-06-12得票数 1
1回答
对于我的一个类，我必须分析一个“大数据”数据集。我在AWS开放数据注册表上发现了以下数据集，这似乎很有趣：
我如何创建连接并将此数据集加载到Databricks？我试过以下几种方法：
df = spark.read.format("text").load("s3://openaq-fetches/")
但是，我收到以下错误：
java.lang.AssertionError: assertion failed: Conflicting directory structures detected. Suspicious paths:
而且，这个数据集似乎有多个文
浏览 1提问于2021-04-02得票数 0
回答已采纳
我有一个包含json行的文本文件，其结构如下所示。
{"city": "London","street": null, "place": "Pizzaria", "foo": "Bar"}
我需要将其读入为JSON，并将其转换为以下scala代码的case类。我只需要在json的case类中定义字段。
import org.apache.spark.sql.SparkSession
import spray.json.DefaultJsonProtocol
import spr
浏览 0提问于2018-05-21得票数 2
回答已采纳
我有一个火花数据集的列(在java中)，我希望这个列的所有值都成为新列的列名(新列可以用一个常量值填充)。
For example I have:
+------------+
| Column |
+------------+
| a |
| b |
| c |
+------------+
And I want:
+------+----+----+---+
|Column| a | b | c |
+------+----+----+---+
| a | 0 | 0 |0 |
| b | 0 |
浏览 1提问于2019-08-08得票数 1
回答已采纳
我有下面的Scala代码引用第三方库，
package com.protegrity.spark
import org.apache.spark.sql.api.java.UDF2
import com.protegrity.spark.udf.ptyProtectStr
import com.protegrity.spark.udf.ptyProtectInt
class ptyProtectStr extends UDF2[String, String, String] {
def call(input: String, dataElement: String): Strin
浏览 14提问于2020-07-18得票数 0
1回答
我试图在s3文件上创建JAVARDD，但是无法创建rdd.Can，有人帮助我解决了这个问题。
代码:
SparkConf conf = new SparkConf().setAppName(appName).setMaster("local");
JavaSparkContext javaSparkContext = new JavaSparkContext(conf);
javaSparkContext.hadoopConfiguration().set("fs.s3.awsAccessKeyId",
浏览 1提问于2015-05-06得票数 2
回答已采纳
3回答
快速地，我的需求:从T( Server)中或多或少复杂的查询和/或从Server存储过程的输出中创建一个Spark数据。
据我所知，Spark不允许以基础数据源的方言执行查询。是的，有来获取低级对象并执行存储过程，但以这种方式，输出中没有Spark。
因此，我想以经典的pyodbc方式执行一个查询，获得结果，然后使用提供数据和模式的函数构建Spark。我可以获得数据，但不能从输出游标构建模式(一对(列名、数据类型)的列表)。遵循一个工作示例，从Server的本地实例中(生成和)提取示例数据：
import pyodbc
connection_string = "Driver={SQL
浏览 10提问于2022-11-16得票数 0
我在使用sparkCassandraConnector从Cassandra表中检索数据时遇到了问题。我在Cassandra中创建了一个名为“k”的名称空间，并创建了“学生”表。这张表如下：
id _名称
10凯瑟琳
我在本地开始运行start-all.sh
然后我创建了这个类"SparkCassandraConnector“，它有一个用于连接spark的命令，我试图做的Cassandra.What是从学生表中检索数据并在屏幕上打印出来。
我得到的错误是"java.lang.ClassNotFoundException: SparkCassandraConnector$Stud
浏览 1提问于2014-10-28得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
