aboutsummaryrefslogtreecommitdiff
path: root/streaming/src
diff options
context:
space:
mode:
authorShivansh <shiv4nsh@gmail.com>2016-09-04 12:39:26 +0100
committerSean Owen <sowen@cloudera.com>2016-09-04 12:39:26 +0100
commite75c162e9e510d74b07f28ccf6c7948ac317a7c6 (patch)
tree3d424bc7733e9d7ccca8e929e914ceeced4c8e19 /streaming/src
parent6b156e2fcf9c0c1ed0770a7ad9c54fa374760e17 (diff)
downloadspark-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/src')
-rw-r--r--streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairDStream.scala7
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