aboutsummaryrefslogtreecommitdiff
path: root/examples
diff options
context:
space:
mode:
authorAzeem Jiva <azeemj@gmail.com>2016-04-26 11:49:04 +0100
committerSean Owen <sowen@cloudera.com>2016-04-26 11:49:04 +0100
commitde6e633420aba1fe5d806a2725a95e610699ae7d (patch)
tree4d7d0ddc183404e27f56f723efa7929c981b78ea /examples
parentf70e4fff0e7adb8d6fe774daf11fb0dfb080cf31 (diff)
downloadspark-de6e633420aba1fe5d806a2725a95e610699ae7d.tar.gz
spark-de6e633420aba1fe5d806a2725a95e610699ae7d.tar.bz2
spark-de6e633420aba1fe5d806a2725a95e610699ae7d.zip
[SPARK-14756][CORE] Use parseLong instead of valueOf
## What changes were proposed in this pull request? Use Long.parseLong which returns a primative. Use a series of appends() reduces the creation of an extra StringBuilder type ## How was this patch tested? Unit tests Author: Azeem Jiva <azeemj@gmail.com> Closes #12520 from javawithjiva/minor.
Diffstat (limited to 'examples')
-rw-r--r--examples/src/main/java/org/apache/spark/examples/mllib/JavaStreamingTestExample.java8
1 files changed, 4 insertions, 4 deletions
diff --git a/examples/src/main/java/org/apache/spark/examples/mllib/JavaStreamingTestExample.java b/examples/src/main/java/org/apache/spark/examples/mllib/JavaStreamingTestExample.java
index df901997e1..cfaa577b51 100644
--- a/examples/src/main/java/org/apache/spark/examples/mllib/JavaStreamingTestExample.java
+++ b/examples/src/main/java/org/apache/spark/examples/mllib/JavaStreamingTestExample.java
@@ -66,8 +66,8 @@ public class JavaStreamingTestExample {
}
String dataDir = args[0];
- Duration batchDuration = Seconds.apply(Long.valueOf(args[1]));
- int numBatchesTimeout = Integer.valueOf(args[2]);
+ Duration batchDuration = Seconds.apply(Long.parseLong(args[1]));
+ int numBatchesTimeout = Integer.parseInt(args[2]);
SparkConf conf = new SparkConf().setMaster("local").setAppName("StreamingTestExample");
JavaStreamingContext ssc = new JavaStreamingContext(conf, batchDuration);
@@ -80,8 +80,8 @@ public class JavaStreamingTestExample {
@Override
public BinarySample call(String line) {
String[] ts = line.split(",");
- boolean label = Boolean.valueOf(ts[0]);
- double value = Double.valueOf(ts[1]);
+ boolean label = Boolean.parseBoolean(ts[0]);
+ double value = Double.parseDouble(ts[1]);
return new BinarySample(label, value);
}
});