File tree Expand file tree Collapse file tree 1 file changed +7
-4
lines changed
core/src/main/scala/org/apache/spark/storage Expand file tree Collapse file tree 1 file changed +7
-4
lines changed Original file line number Diff line number Diff line change @@ -39,10 +39,13 @@ import org.apache.spark.util.Utils
39
39
* The implementation throttles the remote fetches to they don't exceed maxBytesInFlight to avoid
40
40
* using too much memory.
41
41
*
42
- * @param context
43
- * @param blockManager
44
- * @param blocksByAddress
45
- * @param serializer
42
+ * @param context [[TaskContext ]], used for metrics update
43
+ * @param blockTransferService [[BlockTransferService ]] for fetching remote blocks
44
+ * @param blockManager [[BlockManager ]] for reading local blocks
45
+ * @param blocksByAddress list of blocks to fetch grouped by the [[BlockManagerId ]].
46
+ * For each block we also require the size (in bytes as a long field) in
47
+ * order to throttle the memory usage.
48
+ * @param serializer serializer used to deserialize the data.
46
49
* @param maxBytesInFlight max size (in bytes) of remote blocks to fetch at any given point.
47
50
*/
48
51
private [spark]
You can’t perform that action at this time.
0 commit comments