setwd("/mnt/mountpoint/abc/")
sqlServerConnString <- "SERVER=server;DATABASE=sqldwdb;UID=xyz;PWD=abc;"
sqlServerDataDS <- RxSqlServerData(sqlQuery = "SELECT * FROM xyz",
connectionString = sqlServerConnString)
sqlServerDataDF <- rxImport(sqlServerDataDS)
Run Code Online (Sandbox Code Playgroud)
这是我的代码.我在R中得到了跟随错误
[unixODBC] [驱动程序管理器]无法打开lib'SQL Server':找不到文件
[unixODBC] [驱动程序管理器]连接不存在SQLDisconnect中的ODBC错误无法打开doTryCatch中的数据源.错误(return(expr),name,parentenv,handler):无法打开数据源.
我在我的linux机器上安装了MSSQL和unixODBC驱动程序,它也在/etc/odbc.ini文件中被重新选中
有人可以帮我吗?
我的角色对象如下所示:
"ID,MONTH_ID,FLAG\n70,201001,1\n71,201001,1\n94,201001,1\n95,201001,1\n102,201001,
1\n110,201001,1\n124,201001,1"
Run Code Online (Sandbox Code Playgroud)
我想将它转换为数据框,每\n一个新行都应该创建.
有人可以帮我吗?
我正在尝试在 Python 中初始化 Spark Context 变量。
from pyspark import SparkContext, SparkConf
conf = SparkConf().setAppName("test").setMaster("local")
sc = SparkContext(conf=conf)
Run Code Online (Sandbox Code Playgroud)
但我收到以下错误:
py4j.protocol.Py4JJavaError:调用 None.org.apache.spark.api.java.JavaSparkContext 时出错。: java.lang.NoClassDefFoundError: 无法初始化类 org.apache.spark.internal.config.package$
在 org.apache.spark.SparkConf.validateSettings(SparkConf.scala:546) 在 org.apache.spark.SparkContext.(SparkContext.scala:373) 在 org.apache.spark.api.java.JavaSparkContext.(JavaSparkContext.scala :58) at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:247) 上的reflect.Constructor.newInstance(Constructor.java:423) py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357) 上的py4j.Gateway.invoke(Gateway) .java:236) 在 py4j.commands。ConstructorCommand.invokeConstructor(ConstructorCommand.java:80) at py4j.commands.ConstructorCommand.execute(ConstructorCommand.java:69) at py4j.GatewayConnection.run(GatewayConnection.java:214) at java.lang.Thread.run(Thread.java) :748)
我四处寻找解决方案,但没有得到确切的解决方案。请帮忙。