Skip to content

Commit

Permalink
Updated comment for ShuffleBlockFetcherIterator.
Browse files Browse the repository at this point in the history
  • Loading branch information
rxin committed Sep 3, 2014
1 parent 8a1046e commit e29c721
Showing 1 changed file with 7 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -39,10 +39,13 @@ import org.apache.spark.util.Utils
* The implementation throttles the remote fetches to they don't exceed maxBytesInFlight to avoid
* using too much memory.
*
* @param context
* @param blockManager
* @param blocksByAddress
* @param serializer
* @param context [[TaskContext]], used for metrics update
* @param blockTransferService [[BlockTransferService]] for fetching remote blocks
* @param blockManager [[BlockManager]] for reading local blocks
* @param blocksByAddress list of blocks to fetch grouped by the [[BlockManagerId]].
* For each block we also require the size (in bytes as a long field) in
* order to throttle the memory usage.
* @param serializer serializer used to deserialize the data.
* @param maxBytesInFlight max size (in bytes) of remote blocks to fetch at any given point.
*/
private[spark]
Expand Down

0 comments on commit e29c721

Please sign in to comment.