Skip to content

Commit

Permalink
[CORE]codeStyle: uniform ConcurrentHashMap define in StorageLevel.scala
Browse files Browse the repository at this point in the history
  • Loading branch information
liyezhang556520 committed Oct 14, 2014
1 parent 186b497 commit 5884735
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@
package org.apache.spark.storage

import java.io.{Externalizable, IOException, ObjectInput, ObjectOutput}
import java.util.concurrent.ConcurrentHashMap

import org.apache.spark.annotation.DeveloperApi

Expand Down Expand Up @@ -219,8 +220,7 @@ object StorageLevel {
getCachedStorageLevel(obj)
}

private[spark] val storageLevelCache =
new java.util.concurrent.ConcurrentHashMap[StorageLevel, StorageLevel]()
private[spark] val storageLevelCache = new ConcurrentHashMap[StorageLevel, StorageLevel]()

private[spark] def getCachedStorageLevel(level: StorageLevel): StorageLevel = {
storageLevelCache.putIfAbsent(level, level)
Expand Down

0 comments on commit 5884735

Please sign in to comment.