TempFileBasedBlockStoreUpdater¶

TempFileBasedBlockStoreUpdater is a BlockStoreUpdater (that BlockManager uses for storing a block from bytes in a local temporary file).

Creating Instance¶

TempFileBasedBlockStoreUpdater takes the following to be created:

• BlockId
• StorageLevel
• ClassTag (Scala)
• Temporary File
• Block Size
• tellMaster flag (default: true)
• keepReadLock flag (default: false)

TempFileBasedBlockStoreUpdater is created when:

• BlockManager is requested to putBlockDataAsStream
• PythonBroadcast is requested to readObject

Block Data¶

blockData(): BlockData

blockData requests the DiskStore (of the parent BlockManager) to getBytes (with the temp file and the block size).

blockData is part of the BlockStoreUpdater abstraction.

Storing Block to Disk¶

saveToDiskStore(): Unit

saveToDiskStore requests the DiskStore (of the parent BlockManager) to moveFileToBlock.

saveToDiskStore is part of the BlockStoreUpdater abstraction.