Skip to content
Snippets Groups Projects
Commit cb2f5046 authored by Shivaram Venkataraman's avatar Shivaram Venkataraman
Browse files

Pass in bufferSize to BufferedOutputStream

parent c851957f
No related branches found
No related tags found
No related merge requests found
Hide whitespace changes
Inline Side-by-side
core/src/main/scala/spark/storage/DiskStore.scala
+ 1
− 1
View file @ cb2f5046
...@@ -40,7 +40,7 @@ private class DiskStore(blockManager: BlockManager, rootDirs: String) ...@@ -40,7 +40,7 @@ private class DiskStore(blockManager: BlockManager, rootDirs: String)
override def open(): DiskBlockObjectWriter = { override def open(): DiskBlockObjectWriter = {
val fos = new FileOutputStream(f, true) val fos = new FileOutputStream(f, true)
channel = fos.getChannel() channel = fos.getChannel()
bs = blockManager.wrapForCompression(blockId, new FastBufferedOutputStream(fos)) bs = blockManager.wrapForCompression(blockId, new FastBufferedOutputStream(fos, bufferSize))
objOut = serializer.newInstance().serializeStream(bs) objOut = serializer.newInstance().serializeStream(bs)
initialized = true initialized = true
this this
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment