Skip to content

[Core][Doc]:remove redundant comment #15091

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
wants to merge 3 commits into from
Closed

[Core][Doc]:remove redundant comment #15091

Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
f031bd9
remove redundant comment
wangmiao1981 Sep 14, 2016
c8afcb8
adjust format
wangmiao1981 Sep 14, 2016
47c6ec3
remove one more redundant comment
wangmiao1981 Sep 14, 2016
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 9 additions & 9 deletions core/src/main/scala/org/apache/spark/storage/memory/MemoryStore.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -169,12 +169,12 @@ private[spark] class MemoryStore(
* temporary unroll memory used during the materialization is "transferred" to storage memory,
* so we won't acquire more memory than is actually needed to store the block.
*
* @return in case of success, the estimated the estimated size of the stored data. In case of
* failure, return an iterator containing the values of the block. The returned iterator
* will be backed by the combination of the partially-unrolled block and the remaining
* elements of the original input iterator. The caller must either fully consume this
* iterator or call `close()` on it in order to free the storage memory consumed by the
* partially-unrolled block.
* @return in case of success, the estimated size of the stored data. In case of failure, return
* an iterator containing the values of the block. The returned iterator will be backed
* by the combination of the partially-unrolled block and the remaining elements of the
* original input iterator. The caller must either fully consume this iterator or call
* `close()` on it in order to free the storage memory consumed by the partially-unrolled
* block.
*/
private[storage] def putIteratorAsValues[T](
blockId: BlockId,
Expand Down Expand Up @@ -298,9 +298,9 @@ private[spark] class MemoryStore(
* temporary unroll memory used during the materialization is "transferred" to storage memory,
* so we won't acquire more memory than is actually needed to store the block.
*
* @return in case of success, the estimated the estimated size of the stored data. In case of
* failure, return a handle which allows the caller to either finish the serialization
* by spilling to disk or to deserialize the partially-serialized block and reconstruct
* @return in case of success, the estimated size of the stored data. In case of failure,
* return a handle which allows the caller to either finish the serialization by
* spilling to disk or to deserialize the partially-serialized block and reconstruct
* the original input iterator. The caller must either fully consume this result
* iterator or call `discard()` on it in order to free the storage memory consumed by the
* partially-unrolled block.
Expand Down