diff options
author | Shivansh <shiv4nsh@gmail.com> | 2016-09-04 12:39:26 +0100 |
---|---|---|
committer | Sean Owen <sowen@cloudera.com> | 2016-09-04 12:39:26 +0100 |
commit | e75c162e9e510d74b07f28ccf6c7948ac317a7c6 (patch) | |
tree | 3d424bc7733e9d7ccca8e929e914ceeced4c8e19 /streaming | |
parent | 6b156e2fcf9c0c1ed0770a7ad9c54fa374760e17 (diff) | |
download | spark-e75c162e9e510d74b07f28ccf6c7948ac317a7c6.tar.gz spark-e75c162e9e510d74b07f28ccf6c7948ac317a7c6.tar.bz2 spark-e75c162e9e510d74b07f28ccf6c7948ac317a7c6.zip |
[SPARK-17308] Improved the spark core code by replacing all pattern match on boolean value by if/else block.
## What changes were proposed in this pull request?
Improved the code quality of spark by replacing all pattern match on boolean value by if/else block.
## How was this patch tested?
By running the tests
Author: Shivansh <shiv4nsh@gmail.com>
Closes #14873 from shiv4nsh/SPARK-17308.
Diffstat (limited to 'streaming')
-rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairDStream.scala | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairDStream.scala b/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairDStream.scala index dec983165f..da9ff85885 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairDStream.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairDStream.scala @@ -471,9 +471,10 @@ class JavaPairDStream[K, V](val dstream: DStream[(K, V)])( val list: JList[V] = values.asJava val scalaState: Optional[S] = JavaUtils.optionToOptional(state) val result: Optional[S] = in.apply(list, scalaState) - result.isPresent match { - case true => Some(result.get()) - case _ => None + if (result.isPresent) { + Some(result.get()) + } else { + None } } scalaFunc |