Skip to content

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:

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.

Back to top