diff options
| author | Shivaram Venkataraman <shivaram@eecs.berkeley.edu> | 2013-06-05 15:09:02 -0700 |
|---|---|---|
| committer | Shivaram Venkataraman <shivaram@eecs.berkeley.edu> | 2013-06-05 15:09:02 -0700 |
| commit | cb2f5046ee99582a5038a78478c23468b14c134e (patch) | |
| tree | 9c21caf0ada84aa1df1ec9302c195843a7fa5390 /core/src | |
| parent | c851957fe4798d5dfb8deba7bf79a035a0543c74 (diff) | |
| download | spark-cb2f5046ee99582a5038a78478c23468b14c134e.tar.gz spark-cb2f5046ee99582a5038a78478c23468b14c134e.tar.bz2 spark-cb2f5046ee99582a5038a78478c23468b14c134e.zip | |
Pass in bufferSize to BufferedOutputStream
Diffstat (limited to 'core/src')
| -rw-r--r-- | core/src/main/scala/spark/storage/DiskStore.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/storage/DiskStore.scala b/core/src/main/scala/spark/storage/DiskStore.scala index c1cff25552..0af6e4a359 100644 --- a/core/src/main/scala/spark/storage/DiskStore.scala +++ b/core/src/main/scala/spark/storage/DiskStore.scala @@ -40,7 +40,7 @@ private class DiskStore(blockManager: BlockManager, rootDirs: String) override def open(): DiskBlockObjectWriter = { val fos = new FileOutputStream(f, true) channel = fos.getChannel() - bs = blockManager.wrapForCompression(blockId, new FastBufferedOutputStream(fos)) + bs = blockManager.wrapForCompression(blockId, new FastBufferedOutputStream(fos, bufferSize)) objOut = serializer.newInstance().serializeStream(bs) initialized = true this |