当前位置: 首页 > 知识库问答 >
问题:

EMRSpark ERORR:Value couchbase不是org.apache.spark.sql.DataFrameReader的成员

邹高峻
2023-03-14

我试图将couchBase服务器连接到EMR Spark 1.4.1,但遇到了

val airlines = sqlContext.read.couchbase(schemaFilter = org.apache.spark.sql.sources.EqualTo("type", "airline"))

<console>:24: error: value couchbase is not a member of org.apache.spark.sql.DataFrameReader

我还需要配置什么吗?因为我使用的是AWS EMR,所以我假设我不需要修改.sbt文件?我想我已经在指定连接到spark-shell时导入了包,或者在line(command)7中导入了包?

共有1个答案

郎羽
2023-03-14

文档说明您必须导入以下内容:

scala> import com.couchbase.spark._
import com.couchbase.spark._

scala> import com.couchbase.spark.sql._
import com.couchbase.spark.sql._

完整文档可在以下网址获得:http://developer.couchbase.com/documentation/server/current/connectors/spark-1.0/spark-shell.html

 类似资料:
  • 问题内容: 好吧,我有 tmp.cpp: 但是当我尝试编译时,我得到: 我正在运行g ++版本4.8.1。与我在那里发现的所有其他对此错误的引用不同,我 没有 使用MinGW,而是在Linux(3.11.2)上。 任何想法为什么会这样?这是标准行为,我做错了什么,还是某个地方有错误? 问题答案: 您可能需要指定C ++版本 我手头没有gcc 4.8.1,但是在旧版GCC中,您可以使用 至少我相信g

  • 我使用的是hadoop 2.7.2、hbase 1.4.9、spark 2.2.0、scala 2.11.8和java 1.8。我运行此命令时没有任何错误: 然后我运行这个命令: 我只是有这个错误: : 57:错误:value createOrReplace eTempView不是org.apache.spark.rdd.RDD[(org.apache.hadoop.hbase.io.ImMuta

  • 它可能是重复的,但我尝试了所有我在StackOverflow上找到的解决方案。 我不能使用但我不能。我尝试修改我的makefile太多次了。我的最后一个配置是: Android.mk LOCAL_PATH:=$(调用my-dir) 包括$(LOCAL_PATH)/jsoncpp/android.mk 包括/users/rafaelruizmunoz/desktop/androiddevelopme

  • 注释InjectMocks为我们提供了存根/填充私有成员和重用测试用例的方法。这是我们填充假成员时发生问题的概念代码。 问题是当我们模拟假的组件B时。然后,someShimmedMethod将返回null。似乎InjectMock无法将

  • 我正在尝试使用spark df读取spark中的CSV文件。文件没有标题列,但我想有标题列。如何做到这一点?我不知道我是否正确,我写了这个命令- 并将列名作为列的_c0和_c1。然后我尝试使用:val df1=df.with列重命名("_c0","系列")将列名更改为所需的名称,但我得到"with列重命名"不是单元上的成员。 PS:我已经导入了spark.implicits._和spark.sql