From f416d02a61918cb151a405b77569e8fcced19628 Mon Sep 17 00:00:00 2001 From: Cheng Lian Date: Fri, 11 Mar 2016 16:11:24 +0800 Subject: [PATCH] Fixes compilation failure --- .../apache/spark/examples/ml/JavaMaxAbsScalerExample.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/examples/src/main/java/org/apache/spark/examples/ml/JavaMaxAbsScalerExample.java b/examples/src/main/java/org/apache/spark/examples/ml/JavaMaxAbsScalerExample.java index b1e3b9137f213..a2a072b253f39 100644 --- a/examples/src/main/java/org/apache/spark/examples/ml/JavaMaxAbsScalerExample.java +++ b/examples/src/main/java/org/apache/spark/examples/ml/JavaMaxAbsScalerExample.java @@ -22,7 +22,8 @@ // $example on$ import org.apache.spark.ml.feature.MaxAbsScaler; import org.apache.spark.ml.feature.MaxAbsScalerModel; -import org.apache.spark.sql.DataFrame; +import org.apache.spark.sql.Dataset; +import org.apache.spark.sql.Row; // $example off$ import org.apache.spark.sql.SQLContext; @@ -34,7 +35,7 @@ public static void main(String[] args) { SQLContext jsql = new SQLContext(jsc); // $example on$ - DataFrame dataFrame = jsql.read().format("libsvm").load("data/mllib/sample_libsvm_data.txt"); + Dataset dataFrame = jsql.read().format("libsvm").load("data/mllib/sample_libsvm_data.txt"); MaxAbsScaler scaler = new MaxAbsScaler() .setInputCol("features") .setOutputCol("scaledFeatures"); @@ -43,7 +44,7 @@ public static void main(String[] args) { MaxAbsScalerModel scalerModel = scaler.fit(dataFrame); // rescale each feature to range [-1, 1]. - DataFrame scaledData = scalerModel.transform(dataFrame); + Dataset scaledData = scalerModel.transform(dataFrame); scaledData.show(); // $example off$ jsc.stop();