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
3939 * The implementation throttles the remote fetches to they don't exceed maxBytesInFlight to avoid
4040 * using too much memory.
4141 *
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.
4649 * @param maxBytesInFlight max size (in bytes) of remote blocks to fetch at any given point.
4750 */
4851private [spark]
You can’t perform that action at this time.
0 commit comments