diff options
author | Azeem Jiva <azeemj@gmail.com> | 2016-04-26 11:49:04 +0100 |
---|---|---|
committer | Sean Owen <sowen@cloudera.com> | 2016-04-26 11:49:04 +0100 |
commit | de6e633420aba1fe5d806a2725a95e610699ae7d (patch) | |
tree | 4d7d0ddc183404e27f56f723efa7929c981b78ea /examples/src/main | |
parent | f70e4fff0e7adb8d6fe774daf11fb0dfb080cf31 (diff) | |
download | spark-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/src/main')
-rw-r--r-- | examples/src/main/java/org/apache/spark/examples/mllib/JavaStreamingTestExample.java | 8 |
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); } }); |