我试图在apache spark上使用scala运行自包含的应用程序,例如:http: //spark.apache.org/docs/latest/ml-pipeline.html
这是我的完整代码:
import org.apache.spark.ml.classification.LogisticRegression
import org.apache.spark.ml.linalg.{Vector, Vectors}
import org.apache.spark.ml.param.ParamMap
import org.apache.spark.sql.Row
object mllibexample1 {
def main(args: Array[String]) {
val spark = SparkSession
.builder()
.master("local[*]")
.appName("logistic regression example 1")
.getOrCreate()
val training = spark.createDataFrame(Seq(
(1.0, Vectors.dense(0.0, 1.1, 0.1)),
(0.0, Vectors.dense(2.0, 1.0, -1.0)),
(0.0, Vectors.dense(2.0, 1.3, 1.0)),
(1.0, Vectors.dense(0.0, 1.2, -0.5))
)).toDF("label", "features")
val lr = new LogisticRegression()
println("LogisticRegression parameters:\n" + lr.explainParams() + "\n")
lr.setMaxIter(100)
.setRegParam(0.01)
val model1 = lr.fit(training)
println("Model 1 was fit using parameters: " + …Run Code Online (Sandbox Code Playgroud)
我在Windows 64位上使用R 3.1.2.
安装devtools(版本1.6.1)后,我无法调用parenvs()函数.
这是我重新创建问题的方法:
> library(devtools)
> parenvs(all = TRUE)
错误:找不到函数"parenvs"
我错过了什么 ?
谢谢
Yusata