diff options
| author | Sandeep Singh <sandeep@techaddict.me> | 2016-06-10 13:06:51 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2016-06-10 13:06:51 -0700 |
| commit | 865ec32dd997e63aea01a871d1c7b4947f43c111 (patch) | |
| tree | 62ddb4dba84262c8efe35d1c2d9157c7b2a1624f /streaming/src | |
| parent | 667d4ea7b35f285954ea7cb719b7c80581e31f4d (diff) | |
| download | spark-865ec32dd997e63aea01a871d1c7b4947f43c111.tar.gz spark-865ec32dd997e63aea01a871d1c7b4947f43c111.tar.bz2 spark-865ec32dd997e63aea01a871d1c7b4947f43c111.zip | |
[MINOR][X][X] Replace all occurrences of None: Option with Option.empty
## What changes were proposed in this pull request?
Replace all occurrences of `None: Option[X]` with `Option.empty[X]`
## How was this patch tested?
Exisiting Tests
Author: Sandeep Singh <sandeep@techaddict.me>
Closes #13591 from techaddict/minor-7.
Diffstat (limited to 'streaming/src')
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceivedBlockHandler.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceivedBlockHandler.scala b/streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceivedBlockHandler.scala index c4bc5cf3f6..80c07958b4 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceivedBlockHandler.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceivedBlockHandler.scala @@ -170,7 +170,7 @@ private[streaming] class WriteAheadLogBasedBlockHandler( */ def storeBlock(blockId: StreamBlockId, block: ReceivedBlock): ReceivedBlockStoreResult = { - var numRecords = None: Option[Long] + var numRecords = Option.empty[Long] // Serialize the block so that it can be inserted into both val serializedBlock = block match { case ArrayBufferBlock(arrayBuffer) => |