Skip to content

Commit

Permalink
fix style
Browse files Browse the repository at this point in the history
  • Loading branch information
lianhuiwang committed May 10, 2016
1 parent 6724482 commit c3eeedf
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -412,7 +412,7 @@ public long getMemoryConsumptionForThisTask() {
/**
* Returns Tungsten memory mode
*/
public MemoryMode getTungstenMemoryMode(){
public MemoryMode getTungstenMemoryMode() {
return tungstenMemoryMode;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -584,7 +584,7 @@ class ExternalAppendOnlyMap[K, V, C](
s"it will release ${org.apache.spark.util.Utils.bytesToString(getUsed())} memory")
nextUpstream = spillMemoryIteratorToDisk(upstream)
hasSpilled = true
true
true
}
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ private[spark] abstract class Spillable[C](taskMemoryManager: TaskMemoryManager)
protected def forceSpill(): Boolean

// Number of elements read from input since last spill
@volatile protected def elementsRead: Long = _elementsRead
protected def elementsRead: Long = _elementsRead

// Called by subclasses every time a record is read
// It's used for checking spilling frequency
Expand All @@ -61,7 +61,7 @@ private[spark] abstract class Spillable[C](taskMemoryManager: TaskMemoryManager)
@volatile private[this] var myMemoryThreshold = initialMemoryThreshold

// Number of elements read from input since last spill
private[this] var _elementsRead = 0L
@volatile private[this] var _elementsRead = 0L

// Number of bytes spilled in total
@volatile private[this] var _memoryBytesSpilled = 0L
Expand Down

0 comments on commit c3eeedf

Please sign in to comment.